Merge "Adding creation of resources for RIC."

[ric-plt/ric-dep.git] / depRicKubernetesOperator / internal / controller / create_controller.go

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