From: naman.gupta Date: Fri, 1 Dec 2023 18:33:14 +0000 (+0530) Subject: Adding deletion of resources for RIC. X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=d618372bb7b6825defee29281f28ccaf75e0e637;p=ric-plt%2Fric-dep.git Adding deletion of resources for RIC. Adding deletion of resources for RIC. Change-Id: I633755f9f686a13ec8a99d6f9ddfda55283bce44 Signed-off-by: naman.gupta --- diff --git a/depRicKubernetesOperator/internal/controller/delete_controller.go b/depRicKubernetesOperator/internal/controller/delete_controller.go index 837a882..ab70274 100644 --- a/depRicKubernetesOperator/internal/controller/delete_controller.go +++ b/depRicKubernetesOperator/internal/controller/delete_controller.go @@ -7,15 +7,25 @@ import ( func (r *RicPlatformReconciler) DeleteAll() { var err error - namespaceProvided := "ricxapp" + namespaceProvided := "ricplt" - for _, resource := range GetConfigMap() { - if resource.ObjectMeta.Namespace == "" { - resource.ObjectMeta.Namespace = namespaceProvided + for _, resource := range GetCustomResourceDefinition() { + if resource.GetNamespace() == "" { + resource.SetNamespace(namespaceProvided) } err = r.Delete(context.TODO(), resource) if err != nil { - fmt.Println("Erorr During Deleting resource of GetConfigMap()| Error --> |", err) + fmt.Println("Erorr During Deleting resource of GetCustomResourceDefinition()| Error --> |", err) + } + } + + for _, resource := range GetJob() { + if resource.GetNamespace() == "" { + resource.SetNamespace(namespaceProvided) + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetJob()| Error --> |", err) } } @@ -29,6 +39,46 @@ func (r *RicPlatformReconciler) DeleteAll() { } } + for _, resource := range GetPersistentVolume() { + if resource.GetNamespace() == "" { + resource.SetNamespace(namespaceProvided) + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetPersistentVolume()| Error --> |", err) + } + } + + for _, resource := range GetClusterRole() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetClusterRole()| Error --> |", err) + } + } + + for _, resource := range GetEndpoints() { + if resource.GetNamespace() == "" { + resource.SetNamespace(namespaceProvided) + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetEndpoints()| Error --> |", err) + } + } + + for _, resource := range GetConfigMap() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetConfigMap()| Error --> |", err) + } + } + for _, resource := range GetService() { if resource.ObjectMeta.Namespace == "" { resource.ObjectMeta.Namespace = namespaceProvided @@ -39,6 +89,26 @@ func (r *RicPlatformReconciler) DeleteAll() { } } + for _, resource := range GetRoleBinding() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetRoleBinding()| Error --> |", err) + } + } + + for _, resource := range GetStatefulSet() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetStatefulSet()| Error --> |", err) + } + } + for _, resource := range GetIngress() { if resource.GetNamespace() == "" { resource.SetNamespace(namespaceProvided) @@ -49,4 +119,54 @@ func (r *RicPlatformReconciler) DeleteAll() { } } -} + for _, resource := range GetPersistentVolumeClaim() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetPersistentVolumeClaim()| Error --> |", err) + } + } + + for _, resource := range GetServiceAccount() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetServiceAccount()| Error --> |", err) + } + } + + for _, resource := range GetRole() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetRole()| Error --> |", err) + } + } + + for _, resource := range GetSecret() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetSecret()| Error --> |", err) + } + } + + for _, resource := range GetClusterRoleBinding() { + if resource.ObjectMeta.Namespace == "" { + resource.ObjectMeta.Namespace = namespaceProvided + } + err = r.Delete(context.TODO(), resource) + if err != nil { + fmt.Println("Erorr During Deleting resource of GetClusterRoleBinding()| Error --> |", err) + } + } + +} \ No newline at end of file