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