Controller code for creating all resources.

Controller code for creating all resources like deployment ,services,
configmap.

Change-Id: Idc7114ceb0ef1605c72ac4a0b07e672f404731c4
Signed-off-by: naman.gupta <naman.gupta@samsung.com>

diff --git a/depRicKubernetesOperator/internal/controller/create_controller.go b/depRicKubernetesOperator/internal/controller/create_controller.go
new file mode 100644 (file)
index 0000000..8c94658
--- /dev/null
+++ b/depRicKubernetesOperator/internal/controller/create_controller.go
@@ -0,0 +1,51 @@
+package controller\r
+\r
+import (\r
+       "context"\r
+       "fmt"\r
+)\r
+\r
+func (r *RicPlatformReconciler) CreateAll() {\r
+       var err error\r
+       namespaceProvided := "ricplt"\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
+       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 GetDeployment()| 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
+       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
+}\r