X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fusecases%2Fodusliceassurance%2Fgoversion%2Fmain.go;h=8366843978c07437506d9d811e015e0ad9a67914;hb=6b43426c2b52daa5ace5205b98d09e1871fa41d6;hp=05b5edf3372d090072069a114a5a9269fd8d76dd;hpb=9850e546f54b85fec121518828517f1643ef81f8;p=nonrtric.git diff --git a/test/usecases/odusliceassurance/goversion/main.go b/test/usecases/odusliceassurance/goversion/main.go index 05b5edf3..83668439 100644 --- a/test/usecases/odusliceassurance/goversion/main.go +++ b/test/usecases/odusliceassurance/goversion/main.go @@ -22,6 +22,7 @@ package main import ( "fmt" + "net/http" log "github.com/sirupsen/logrus" "oransc.org/usecase/oduclosedloop/internal/config" @@ -36,6 +37,8 @@ func main() { configuration = config.New() log.SetLevel(configuration.LogLevel) + log.SetFormatter(&log.JSONFormatter{}) + log.Debug("Using configuration: ", configuration) dmaapUrl := configuration.MRHost + ":" + configuration.MRPort @@ -46,8 +49,11 @@ func main() { a := sliceassurance.App{} a.Initialize(dmaapUrl, configuration.SDNRAddress) - a.Run(TOPIC, configuration.Polltime) + go a.Run(TOPIC, configuration.Polltime) + + http.HandleFunc("/status", statusHandler) + log.Fatal(http.ListenAndServe(":40936", nil)) } func validateConfiguration(configuration *config.Config) error { @@ -56,3 +62,7 @@ func validateConfiguration(configuration *config.Config) error { } 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. +}