2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
18 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
19 // platform project (RICP).
26 "github.com/stretchr/testify/assert"
28 metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
29 "k8s.io/apimachinery/pkg/runtime"
30 "k8s.io/client-go/kubernetes/fake"
34 type TestStruct struct {
41 func initKubernetesManagerTest(t *testing.T) *KubernetesManager {
42 logger, err := logger.InitLogger(logger.DebugLevel)
44 t.Errorf("#... - failed to initialize logger, error: %s", err)
46 config := &configuration.Configuration{}
47 config.Kubernetes.Namespace = "oran"
48 config.Kubernetes.ConfigPath = "somePath"
50 kubernetesManager := NewKubernetesManager(logger, config)
52 return kubernetesManager
55 func TestDelete_NoPodName(t *testing.T) {
57 description: "2 namespace, 2 pods in oran",
59 objs: []runtime.Object{pod("oran", "POD_Test_1"), pod("oran", "POD_Test_2"), pod("some-namespace", "POD_Test_1")},
62 kubernetesManager := initKubernetesManagerTest(t)
64 t.Run(test.description, func(t *testing.T) {
65 kubernetesManager.ClientSet = fake.NewSimpleClientset(test.objs...)
67 err := kubernetesManager.DeletePod("")
72 func TestDelete_NoPods(t *testing.T) {
74 description: "no pods",
80 kubernetesManager := initKubernetesManagerTest(t)
82 t.Run(test.description, func(t *testing.T) {
83 kubernetesManager.ClientSet = fake.NewSimpleClientset(test.objs...)
85 err := kubernetesManager.DeletePod("POD_Test")
90 func TestDelete_PodExists(t *testing.T) {
92 description: "2 namespace, 2 pods in oran",
94 objs: []runtime.Object{pod("oran", "POD_Test_1"), pod("oran", "POD_Test_2"), pod("some-namespace", "POD_Test_1")},
97 kubernetesManager := initKubernetesManagerTest(t)
99 t.Run(test.description, func(t *testing.T) {
100 kubernetesManager.ClientSet = fake.NewSimpleClientset(test.objs...)
102 err := kubernetesManager.DeletePod("POD_Test_1")
107 func TestDelete_NoPodInNamespace(t *testing.T) {
109 description: "2 namespace, 2 pods in oran",
111 objs: []runtime.Object{pod("oran", "POD_Test_1"), pod("oran", "POD_Test_2"), pod("some-namespace", "POD_Test")},
114 kubernetesManager := initKubernetesManagerTest(t)
116 t.Run(test.description, func(t *testing.T) {
117 kubernetesManager.ClientSet = fake.NewSimpleClientset(test.objs...)
119 err := kubernetesManager.DeletePod("POD_Test")
120 assert.NotNil(t, err)
124 func TestDelete_NoNamespace(t *testing.T) {
126 description: "No oran namespace",
128 objs: []runtime.Object{pod("some-namespace", "POD_Test_1"), pod("some-namespace", "POD_Test_2"), pod("some-namespace", "POD_Test")},
131 kubernetesManager := initKubernetesManagerTest(t)
133 t.Run(test.description, func(t *testing.T) {
134 kubernetesManager.ClientSet = fake.NewSimpleClientset(test.objs...)
136 err := kubernetesManager.DeletePod("POD_Test")
137 assert.NotNil(t, err)
141 func pod(namespace, image string) *v1.Pod {
144 ObjectMeta: metaV1.ObjectMeta{
146 Namespace: namespace,
147 Annotations: map[string]string{},