X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=depRicKubernetesOperator%2Finternal%2Fcontroller%2Fcreate_controller.go;h=ed47a57a500be744a76128014e464c219517b9d2;hb=d8554d0c65a787eda1a1f38b66c8c7a97295fc0b;hp=8c946580096b4432cdb344a748ab2c14df1a2737;hpb=e430af139f1db8bd6ea9902a8e1c5c07764b95ef;p=ric-plt%2Fric-dep.git

diff --git a/depRicKubernetesOperator/internal/controller/create_controller.go b/depRicKubernetesOperator/internal/controller/create_controller.go
index 8c94658..ed47a57 100644
--- a/depRicKubernetesOperator/internal/controller/create_controller.go
+++ b/depRicKubernetesOperator/internal/controller/create_controller.go
@@ -9,23 +9,73 @@ func (r *RicPlatformReconciler) CreateAll() {
 	var err error
 	namespaceProvided := "ricplt"
 
-	for _, resource := range GetConfigMap() {
+	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 GetCustomResourceDefinition()| Error --> |", err)
+		}
+	}
+
+	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
 		}
 		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 GetDeployment()| Error --> |", err)
+		}
+	}
+
+	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 getDeployment() {
+	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 GetDeployment()| Error --> |", err)
+			fmt.Println("Erorr During Creating resource of GetClusterRole()| Error --> |", err)
+		}
+	}
+
+	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 GetEndpoints()| Error --> |", err)
+		}
+	}
+
+	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 GetConfigMap()| Error --> |", err)
 		}
 	}
 
@@ -38,6 +88,27 @@ func (r *RicPlatformReconciler) CreateAll() {
 			fmt.Println("Erorr During Creating resource of GetService()| Error --> |", err)
 		}
 	}
+
+	for _, resource := range GetRoleBinding() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			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)
@@ -48,4 +119,54 @@ func (r *RicPlatformReconciler) CreateAll() {
 		}
 	}
 
-}
+	for _, resource := range GetPersistentVolumeClaim() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetPersistentVolumeClaim()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetServiceAccount() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetServiceAccount()| Error --> |", err)
+		}
+	}
+
+	for _, resource := range GetRole() {
+		if resource.ObjectMeta.Namespace == "" {
+			resource.ObjectMeta.Namespace = namespaceProvided
+		}
+		err = r.Create(context.TODO(), resource)
+		if err != nil {
+			fmt.Println("Erorr During Creating resource of GetRole()| Error --> |", err)
+		}
+	}
+
+	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