X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=cmd%2Fappmgr%2Fdesc.go;h=8cc39a59f80c478bd5a471bcc8a6e9ec5c460cd5;hb=4703b1a7457cf072640adbc0f5487a0675f5b6d3;hp=7f3344405487f0dbbad06bfb0549349ffe56bc0c;hpb=b6e413571bf3f44d4cd076815334449831d84e28;p=ric-plt%2Fappmgr.git diff --git a/cmd/appmgr/desc.go b/cmd/appmgr/desc.go index 7f33444..8cc39a5 100755 --- a/cmd/appmgr/desc.go +++ b/cmd/appmgr/desc.go @@ -72,7 +72,7 @@ func (cm *ConfigMap) UploadConfig() (cfg []XAppConfig) { } c := XAppConfig{ - Metadata: ConfigMetadata{Name: name, Namespace: ns, ConfigName: name + "-appconfig"}, + Metadata: ConfigMetadata{Name: name, Namespace: ns, ConfigName: cm.GetConfigMapName(name, ns)}, } err := cm.ReadSchema(name, &c) @@ -162,7 +162,7 @@ func (cm *ConfigMap) ApplyConfigMap(r XAppConfig, action string) (err error) { func (cm *ConfigMap) GetConfigMap(m XappDeploy, c *interface{}) (err error) { if m.ConfigName == "" { - m.ConfigName = m.Name + "-appconfig" + m.ConfigName = cm.GetConfigMapName(m.Name, m.Namespace) } return cm.ReadConfigMap(m.ConfigName, m.Namespace, c) } @@ -196,7 +196,7 @@ func (cm *ConfigMap) DeleteConfigMap(r XAppConfig) (c interface{}, err error) { func (cm *ConfigMap) PurgeConfigMap(m XappDeploy) (c interface{}, err error) { if m.ConfigName == "" { - m.ConfigName = m.Name + "-appconfig" + m.ConfigName = cm.GetConfigMapName(m.Name, m.Namespace) } md := ConfigMetadata{Name: m.Name, Namespace: m.Namespace, ConfigName: m.ConfigName} @@ -205,7 +205,7 @@ func (cm *ConfigMap) PurgeConfigMap(m XappDeploy) (c interface{}, err error) { func (cm *ConfigMap) RestoreConfigMap(m XappDeploy, c interface{}) (err error) { if m.ConfigName == "" { - m.ConfigName = m.Name + "-appconfig" + m.ConfigName = cm.GetConfigMapName(m.Name, m.Namespace) } md := ConfigMetadata{Name: m.Name, Namespace: m.Namespace, ConfigName: m.ConfigName} time.Sleep(time.Duration(10 * time.Second)) @@ -293,7 +293,7 @@ func (cm *ConfigMap) GetMessages(name string) (msgs MessageTypes) { log.Println("Fetching tx/rx messages for: ", name) ns := cm.GetNamespace("") - args := fmt.Sprintf("get configmap -o jsonpath='{.data.config-file\\.json}' -n %s %s-appconfig", ns, name) + args := fmt.Sprintf("get configmap -o jsonpath='{.data.config-file\\.json}' -n %s %s", ns, cm.GetConfigMapName(name, ns)) out, err := KubectlExec(args) if err != nil { return @@ -316,6 +316,10 @@ func (cm *ConfigMap) GetMessages(name string) (msgs MessageTypes) { return } +func (cm *ConfigMap) GetConfigMapName(xappName, namespace string) string { + return " configmap-" + namespace + "-" + xappName + "-appconfig" +} + func (cm *ConfigMap) GetNamespace(ns string) string { if ns != "" { return ns