Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Remove DMaaP Mediator Producer from repo
[nonrtric.git]
/
test
/
usecases
/
odusliceassurance
/
goversion
/
main.go
diff --git
a/test/usecases/odusliceassurance/goversion/main.go
b/test/usecases/odusliceassurance/goversion/main.go
index
05b5edf
..
337e4e0
100644
(file)
--- a/
test/usecases/odusliceassurance/goversion/main.go
+++ b/
test/usecases/odusliceassurance/goversion/main.go
@@
-22,13
+22,14
@@
package main
import (
"fmt"
import (
"fmt"
+ "net/http"
log "github.com/sirupsen/logrus"
"oransc.org/usecase/oduclosedloop/internal/config"
"oransc.org/usecase/oduclosedloop/internal/sliceassurance"
)
log "github.com/sirupsen/logrus"
"oransc.org/usecase/oduclosedloop/internal/config"
"oransc.org/usecase/oduclosedloop/internal/sliceassurance"
)
-const TOPIC string = "/events/unauthenticated.
PERFORMANCE_MEASUREMENTS
"
+const TOPIC string = "/events/unauthenticated.
VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT/myG/C1
"
var configuration *config.Config
var configuration *config.Config
@@
-36,18
+37,21
@@
func main() {
configuration = config.New()
log.SetLevel(configuration.LogLevel)
configuration = config.New()
log.SetLevel(configuration.LogLevel)
- log.
Debug("Using configuration: ", configuration
)
+ log.
SetFormatter(&log.JSONFormatter{}
)
- dmaapUrl := configuration.MRHost + ":" + configuration.MRPort
+ log.Debug("Using configuration: ", configuration)
if err := validateConfiguration(configuration); err != nil {
log.Fatalf("Unable to start consumer due to configuration error: %v", err)
}
a := sliceassurance.App{}
if err := validateConfiguration(configuration); err != nil {
log.Fatalf("Unable to start consumer due to configuration error: %v", err)
}
a := sliceassurance.App{}
- a.Initialize(dmaapUrl, configuration.SDNRAddress)
- a.Run(TOPIC, configuration.Polltime)
+ a.Initialize(configuration)
+ go a.Run(TOPIC, configuration.Polltime)
+
+ http.HandleFunc("/status", statusHandler)
+ log.Fatal(http.ListenAndServe(":40936", nil))
}
func validateConfiguration(configuration *config.Config) error {
}
func validateConfiguration(configuration *config.Config) error {
@@
-56,3
+60,7
@@
func validateConfiguration(configuration *config.Config) error {
}
return nil
}
}
return nil
}
+
+func statusHandler(w http.ResponseWriter, r *http.Request) {
+ // Just respond OK to show the service is alive for now. Might be extended later.
+}