)
// For testing purpose go version 1.13 ->
+
var _ = func() bool {
testing.Init()
return true
// XApp is an application instance
Rmr *RMRClient
Sdl *SDLClient
+ SdlStorage *SDLStorage
Rnib *RNIBClient
Resource *Router
Metric *Metrics
)
func IsReady() bool {
- return Rmr != nil && Rmr.IsReady() && Sdl != nil && Sdl.IsReady()
+ return Rmr != nil && Rmr.IsReady() && SdlStorage != nil && SdlStorage.IsReady()
}
func SetReadyCB(cb ReadyCB, params interface{}) {
for {
time.Sleep(5 * time.Second)
if !IsHealthProbeReady() {
- Logger.Info("Application='%s' is not ready yet, waiting ...", viper.GetString("name"))
+ Logger.Debug("Application='%s' is not ready yet, waiting ...", viper.GetString("name"))
continue
}
Config = Configurator{}
Metric = NewMetrics(viper.GetString("metrics.url"), viper.GetString("metrics.namespace"), Resource.router)
Subscription = NewSubscriber(viper.GetString("controls.subscription.host"), viper.GetInt("controls.subscription.timeout"))
+ SdlStorage = NewSdlStorage()
Sdl = NewSDLClient(viper.GetString("controls.db.namespace"))
- Rnib = NewRNIBClient()
+ Rnib = GetNewRnibClient(SdlStorage.db)
Util = NewUtils()
InstallSignalHandler()
if ipString == "<nil>" {
host = fmt.Sprintf(":%d", GetPortData("http").Port)
} else {
- host = fmt.Sprintf("%s:%d", ipString, GetPortData("http").Port)
+ host = fmt.Sprintf("[%s]:%d", ipString, GetPortData("http").Port)
}
go http.ListenAndServe(host, Resource.router)
Logger.Info(fmt.Sprintf("Xapp started, listening on: %s", host))
if sdlcheck {
- Sdl.TestConnection()
+ SdlStorage.TestConnection(viper.GetString("controls.db.namespace"))
}
go registerXapp()