<RIC-340><RIC-317> Automation for setup failure and update gnb

[ric-plt/e2mgr.git] / E2Manager / managers / kubernetes_manager.go

diff --git a/E2Manager/managers/kubernetes_manager.go b/E2Manager/managers/kubernetes_manager.go
index 5c3e8ee..09a64b7 100644 (file)
--- a/E2Manager/managers/kubernetes_manager.go
+++ b/E2Manager/managers/kubernetes_manager.go
@@ -44,27 +44,7 @@ func NewKubernetesManager(logger *logger.Logger, config *configuration.Configura
        }
 }
 
-/*func (km KubernetesManager) GetAndDeletePod(namespace string, podName string) {
-       km.logger.Infof("#KubernetesManager.GetAndDeletePod - namespace: %s, POD name: %s ", namespace, podName)
-
-       config, err := clientcmd.BuildConfigFromFlags("", "kubeConfigPath")
-       if err != nil {
-               log.Fatal(err)
-       }
-
-       clientSet, _ := kubernetesManager.NewForConfig(config)
-
-       podInterface := km.GetPodInterface(clientSet.CoreV1(), namespace, podName)
-
-       if podInterface == nil{
-               return
-       }
-
-       km.DeletePod(podInterface, podName)
-}*/
-
 func createClientSet(logger *logger.Logger, config *configuration.Configuration) kubernetes.Interface {
-       ////path := os.Getenv("HOME") + "/.kube/config"
 
        absConfigPath,err := filepath.Abs(config.Kubernetes.ConfigPath)
        if err != nil {
@@ -86,18 +66,6 @@ func createClientSet(logger *logger.Logger, config *configuration.Configuration)
        return clientSet
 }
 
-/*func (km KubernetesManager) DeletePod(podInterface v1.PodInterface, podName string) {
-       km.logger.Infof("#KubernetesManager.DeletePod - POD name %s ", podName)
-
-       err := podInterface.Delete(podName, &metaV1.DeleteOptions{})
-
-       if err != nil{
-               km.logger.Warnf("#KubernetesManager.DeletePod - POD %s can't be deleted", podName)
-               return
-       }
-       km.logger.Infof("#KubernetesManager.DeletePod - POD %s was deleted", podName)
-}
-*/
 func (km KubernetesManager) DeletePod(podName string) error {
        km.Logger.Infof("#KubernetesManager.DeletePod - POD name: %s ", podName)
 
@@ -111,7 +79,7 @@ func (km KubernetesManager) DeletePod(podName string) error {
                return e2managererrors.NewInternalError()
        }
 
-       err := km.ClientSet.CoreV1().Pods(km.Config.Kubernetes.Namespace).Delete(podName, &metaV1.DeleteOptions{})
+       err := km.ClientSet.CoreV1().Pods(km.Config.Kubernetes.KubeNamespace).Delete(podName, &metaV1.DeleteOptions{})
 
        if err != nil {
                km.Logger.Errorf("#KubernetesManager.DeletePod - POD %s can't be deleted, error: %s", podName, err)
@@ -120,21 +88,4 @@ func (km KubernetesManager) DeletePod(podName string) error {
 
        km.Logger.Infof("#KubernetesManager.DeletePod - POD %s was deleted", podName)
        return nil
-}
-
-/*func (km KubernetesManager) GetPodInterface(client v1.CoreV1Interface, namespace string, podName string) v1.PodInterface{
-       km.logger.Infof("#KubernetesManager.GetPodInterface - namespace: %s, POD name: %s ", namespace, podName)
-
-
-       podInterface := client.Pods(namespace)
-       pod, err := podInterface.Get(podName, metaV1.GetOptions{})
-
-       if err != nil{
-               km.logger.Warnf("#KubernetesManager.GetPodInterface - POD name: %s not found", podName)
-               return nil
-       }
-
-       km.logger.Infof("#KubernetesManager.GetPodInterface - POD status: %s ", pod.Status.String())
-
-       return podInterface
-}*/
+}
\ No newline at end of file