From: Thoralf Czichy <thoralf.czichy@nokia.com>
Date: Thu, 7 Dec 2023 09:39:10 +0000 (+0000)
Subject: Merge "Adding creation of resources for RIC."
X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=d8554d0c65a787eda1a1f38b66c8c7a97295fc0b;hp=9fb18847091767093c624c715137c621113d71c4;p=ric-plt%2Fric-dep.git

Merge "Adding creation of resources for RIC."
---

diff --git a/depRicKubernetesOperator/internal/controller/create_controller.go b/depRicKubernetesOperator/internal/controller/create_controller.go
index de4cdb6..ed47a57 100644
--- a/depRicKubernetesOperator/internal/controller/create_controller.go
+++ b/depRicKubernetesOperator/internal/controller/create_controller.go
@@ -9,17 +9,27 @@ func (r *RicPlatformReconciler) CreateAll() {
 	var err error
 	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.Create(context.TODO(), resource)
 		if err != nil {
-			fmt.Println("Erorr During Creating resource of GetConfigMap()| Error --> |", err)
+			fmt.Println("Erorr During Creating resource of GetCustomResourceDefinition()| Error --> |", err)
 		}
 	}
 
-	for _, resource := range getDeployment() {
+	for _, resource := range GetJob() {
+		if resource.GetNamespace() == "" {
+			resource.SetNamespace(namespaceProvided)
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetJob()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetDeployment() {
 		if resource.ObjectMeta.Namespace == "" {
 			resource.ObjectMeta.Namespace = namespaceProvided
 		}
@@ -29,33 +39,56 @@ func (r *RicPlatformReconciler) CreateAll() {
 		}
 	}
 
-	for _, resource := range GetService() {
+	for _, resource := range GetPersistentVolume() {
+		if resource.GetNamespace() == "" {
+			resource.SetNamespace(namespaceProvided)
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetPersistentVolume()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetClusterRole() {
 		if resource.ObjectMeta.Namespace == "" {
 			resource.ObjectMeta.Namespace = namespaceProvided
 		}
 		err = r.Create(context.TODO(), resource)
 		if err != nil {
-			fmt.Println("Erorr During Creating resource of GetService()| Error --> |", err)
+			fmt.Println("Erorr During Creating resource of GetClusterRole()| Error --> |", err)
 		}
 	}
-	for _, resource := range GetIngress() {
+
+	for _, resource := range GetEndpoints() {
 		if resource.GetNamespace() == "" {
 			resource.SetNamespace(namespaceProvided)
 		}
 		err = r.Create(context.TODO(), resource)
 		if err != nil {
-			fmt.Println("Erorr During Creating resource of GetIngress()| Error --> |", err)
+			fmt.Println("Erorr During Creating resource of GetEndpoints()| Error --> |", err)
 		}
 	}
-	for _, resource := range GetPersistentVolume() {
-		if resource.GetNamespace() == "" {
-			resource.SetNamespace(namespaceProvided)
+
+	for _, resource := range GetConfigMap() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
 		}
 		err = r.Create(context.TODO(), resource)
 		if err != nil {
-			fmt.Println("Erorr During Creating resource of GetPersistentVolume()| Error --> |", err)
+			fmt.Println("Erorr During Creating resource of GetConfigMap()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetService() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetService()| Error --> |", err)
 		}
 	}
+
 	for _, resource := range GetRoleBinding() {
 		if resource.ObjectMeta.Namespace == "" {
 			resource.ObjectMeta.Namespace = namespaceProvided
@@ -65,6 +98,27 @@ func (r *RicPlatformReconciler) CreateAll() {
 			fmt.Println("Erorr During Creating resource of GetRoleBinding()| Error --> |", err)
 		}
 	}
+
+	for _, resource := range GetStatefulSet() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetStatefulSet()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetIngress() {
+		if resource.GetNamespace() == "" {
+			resource.SetNamespace(namespaceProvided)
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetIngress()| Error --> |", err)
+		}
+	}
+
 	for _, resource := range GetPersistentVolumeClaim() {
 		if resource.ObjectMeta.Namespace == "" {
 			resource.ObjectMeta.Namespace = namespaceProvided
@@ -95,4 +149,24 @@ func (r *RicPlatformReconciler) CreateAll() {
 		}
 	}
 
-}
+	for _, resource := range GetSecret() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetSecret()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetClusterRoleBinding() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetClusterRoleBinding()| Error --> |", err)
+		}
+	}
+
+}
\ No newline at end of file