commit e71a5a56e10d27e263fb380ea43a4d89f18e2f03
author Mohamed Abukar <abukar.mohamed@nokia.com> Thu Dec 05 08:26:30 2019 +0200
committer Mohamed Abukar <abukar.mohamed@nokia.com> Thu Dec 05 08:26:36 2019 +0200
tree bb9956e09763374f7de2e9bac271e5f414c223ef
parent b3048135f7118568098dcbc4081b4f7f4b2c589e

Add support for RT policies

Change-Id: I8845d7d296634d3b06465385fd35c4ffabac9ee0
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>

pkg/cm/cm_test.go

diff --git a/pkg/cm/cm_test.go b/pkg/cm/cm_test.go
index be600bb..21d1d61 100755
--- a/pkg/cm/cm_test.go
+++ b/pkg/cm/cm_test.go
@@ -52,7 +52,8 @@
        "maxSize": 2072,
        "numWorkers": 1,
        "txMessages": ["RIC_X2_LOAD_INFORMATION"],
-       "rxMessages": ["RIC_X2_LOAD_INFORMATION"]
+       "rxMessages": ["RIC_X2_LOAD_INFORMATION"],
+	   "policies":   [11, 22, 33]
     },
     "db": {
         "namespace": "ricxapp",
@@ -114,7 +115,7 @@
 	return
 }
 
-func (cm *MockedConfigMapper) GetMessages(name string) (msgs appmgr.MessageTypes) {
+func (cm *MockedConfigMapper) GetRtmData(name string) (msgs appmgr.RtmData) {
 	return
 }
 
@@ -135,19 +136,20 @@
 	os.Exit(code)
 }
 
-func TestGetMessages(t *testing.T) {
-	expectedMsgs := appmgr.MessageTypes{
+func TestGetRtmData(t *testing.T) {
+	expectedMsgs := appmgr.RtmData{
 		TxMessages: []string{"RIC_X2_LOAD_INFORMATION"},
 		RxMessages: []string{"RIC_X2_LOAD_INFORMATION"},
+		Policies:   []int64{11, 22, 33},
 	}
 
 	util.KubectlExec = func(args string) (out []byte, err error) {
 		return []byte(kubectlConfigmapOutput), nil
 	}
 
-	result := NewCM().GetMessages("dummy-xapp")
+	result := NewCM().GetRtmData("dummy-xapp")
 	if !reflect.DeepEqual(result, expectedMsgs) {
-		t.Errorf("TestGetMessages failed: expected: %v, got: %v", expectedMsgs, result)
+		t.Errorf("TestGetRtmData failed: expected: %v, got: %v", expectedMsgs, result)
 	}
 }