summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
d2666f9)
Issue-ID: NONRTRIC-740
Signed-off-by: ychacon <yennifer.chacon@est.tech>
Change-Id: I077b7aa74e31dc01d03eaa6e5b797afdb7a4a78a
)
var jobRegistrationInfo = struct {
)
var jobRegistrationInfo = struct {
- InfoTypeID string `json:"info_type_id"`
- JobResultURI string `json:"job_result_uri"`
- JobOwner string `json:"job_owner"`
- JobDefinition interface{} `json:"job_definition"`
+ InfoTypeID string `json:"info_type_id"`
+ JobResultURI string `json:"job_result_uri"`
+ JobOwner string `json:"job_owner"`
+ JobDefinition interface{} `json:"job_definition"`
+ StatusNotificationURI string `json:"status_notification_uri"`
- InfoTypeID: "Performance_Measurement_Streaming",
- JobResultURI: "",
- JobOwner: "O-DU Slice Assurance Usecase",
- JobDefinition: "{}",
+ InfoTypeID: "Performance_Measurement_Streaming",
+ JobResultURI: "",
+ JobOwner: "O-DU Slice Assurance Usecase",
func (a *App) Initialize(config *config.Configuration) {
consumerPort = fmt.Sprint(config.ConsumerPort)
jobRegistrationInfo.JobResultURI = config.ConsumerHost + ":" + consumerPort
func (a *App) Initialize(config *config.Configuration) {
consumerPort = fmt.Sprint(config.ConsumerPort)
jobRegistrationInfo.JobResultURI = config.ConsumerHost + ":" + consumerPort
+ jobRegistrationInfo.StatusNotificationURI = config.ConsumerHost + ":" + consumerPort
sdnrConfig = SdnrConfiguration{
SDNRAddress: config.SDNRAddress,
sdnrConfig = SdnrConfiguration{
SDNRAddress: config.SDNRAddress,
}
func (a *App) startHandler(w http.ResponseWriter, r *http.Request) {
}
func (a *App) startHandler(w http.ResponseWriter, r *http.Request) {
- log.Debug("startHandler: Register job in ICS.")
+ log.Debug("Register job in ICS.")
putErr := a.client.Put(icsAddr+"/data-consumer/v1/info-jobs/"+jobId, jobRegistrationInfo, nil)
if putErr != nil {
putErr := a.client.Put(icsAddr+"/data-consumer/v1/info-jobs/"+jobId, jobRegistrationInfo, nil)
if putErr != nil {
- if reqDump, error := httputil.DumpRequest(req, true); error != nil {
+ if reqDump, error := httputil.DumpRequestOut(req, true); error != nil {
fmt.Println(err)
} else {
fmt.Println(string(reqDump))
fmt.Println(err)
} else {
fmt.Println(string(reqDump))
a = sliceassurance.App{}
a.Initialize(configuration)
a = sliceassurance.App{}
a.Initialize(configuration)
+ go func() {
+ a.StartServer()
+ os.Exit(1) // If the startServer function exits, it is because there has been a failure in the server, so we exit.
+ }()