X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fconfiguration%2Fconfiguration.go;h=5e4c31e10f9b55369b1c3196722be0766ef34376;hb=27feca449ac9a0693b37ff22a900f2534c244387;hp=9ef7c330145a57ce3df7dfe1816baa8a02489447;hpb=dbf8e0032295fac936779b0f117d0600b94c85fc;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/configuration/configuration.go b/E2Manager/configuration/configuration.go index 9ef7c33..5e4c31e 100644 --- a/E2Manager/configuration/configuration.go +++ b/E2Manager/configuration/configuration.go @@ -38,9 +38,12 @@ type Configuration struct { RoutingManager struct { BaseUrl string } +/* Kubernetes struct { + ConfigPath string + KubeNamespace string + }*/ NotificationResponseBuffer int BigRedButtonTimeoutSec int - MaxConnectionAttempts int MaxRnibConnectionAttempts int RnibRetryIntervalMs int KeepAliveResponseTimeoutMs int @@ -69,9 +72,9 @@ func ParseConfiguration() *Configuration { config.populateHttpConfig(viper.Sub("http")) config.populateLoggingConfig(viper.Sub("logging")) config.populateRoutingManagerConfig(viper.Sub("routingManager")) + //config.populateKubernetesConfig(viper.Sub("kubernetes")) config.NotificationResponseBuffer = viper.GetInt("notificationResponseBuffer") config.BigRedButtonTimeoutSec = viper.GetInt("bigRedButtonTimeoutSec") - config.MaxConnectionAttempts = viper.GetInt("maxConnectionAttempts") config.MaxRnibConnectionAttempts = viper.GetInt("maxRnibConnectionAttempts") config.RnibRetryIntervalMs = viper.GetInt("rnibRetryIntervalMs") config.KeepAliveResponseTimeoutMs = viper.GetInt("keepAliveResponseTimeoutMs") @@ -110,6 +113,14 @@ func (c *Configuration) populateRoutingManagerConfig(rmConfig *viper.Viper) { c.RoutingManager.BaseUrl = rmConfig.GetString("baseUrl") } +/*func (c *Configuration) populateKubernetesConfig(rmConfig *viper.Viper) { + if rmConfig == nil { + panic(fmt.Sprintf("#configuration.populateKubernetesConfig - failed to populate Kubernetes configuration: The entry 'kubernetes' not found\n")) + } + c.Kubernetes.ConfigPath = rmConfig.GetString("configPath") + c.Kubernetes.KubeNamespace = rmConfig.GetString("kubeNamespace") +}*/ + func (c *Configuration) populateGlobalRicIdConfig(globalRicIdConfig *viper.Viper) { if globalRicIdConfig == nil { panic(fmt.Sprintf("#configuration.populateGlobalRicIdConfig - failed to populate Global RicId configuration: The entry 'globalRicId' not found\n")) @@ -120,9 +131,9 @@ func (c *Configuration) populateGlobalRicIdConfig(globalRicIdConfig *viper.Viper func (c *Configuration) String() string { return fmt.Sprintf("{logging.logLevel: %s, http.port: %d, rmr: { port: %d, maxMsgSize: %d}, routingManager.baseUrl: %s, "+ - "notificationResponseBuffer: %d, bigRedButtonTimeoutSec: %d, maxConnectionAttempts: %d, maxRnibConnectionAttempts: %d, "+ + "notificationResponseBuffer: %d, bigRedButtonTimeoutSec: %d, maxRnibConnectionAttempts: %d, "+ "rnibRetryIntervalMs: %d, keepAliveResponseTimeoutMs: %d, keepAliveDelayMs: %d, e2tInstanceDeletionTimeoutMs: %d, "+ - "globalRicId: { plmnId: %s, ricNearRtId: %s}}", + "globalRicId: { plmnId: %s, ricNearRtId: %s}",//, kubernetes: {configPath: %s, kubeNamespace: %s}}", c.Logging.LogLevel, c.Http.Port, c.Rmr.Port, @@ -130,7 +141,6 @@ func (c *Configuration) String() string { c.RoutingManager.BaseUrl, c.NotificationResponseBuffer, c.BigRedButtonTimeoutSec, - c.MaxConnectionAttempts, c.MaxRnibConnectionAttempts, c.RnibRetryIntervalMs, c.KeepAliveResponseTimeoutMs, @@ -138,5 +148,7 @@ func (c *Configuration) String() string { c.E2TInstanceDeletionTimeoutMs, c.GlobalRicId.PlmnId, c.GlobalRicId.RicNearRtId, +/* c.Kubernetes.ConfigPath, + c.Kubernetes.KubeNamespace,*/ ) }