From 10084a2faf28da8f0bae71fcdc2f54247ed8d936 Mon Sep 17 00:00:00 2001 From: "naman.gupta" Date: Mon, 27 Nov 2023 15:23:33 +0530 Subject: [PATCH] Controller code for creating all resources. Controller code for creating all resources like deployment ,services, configmap. Change-Id: Idc7114ceb0ef1605c72ac4a0b07e672f404731c4 Signed-off-by: naman.gupta --- .../internal/controller/create_controller.go | 51 ++++++++++++++++++++++ 1 file changed, 51 insertions(+) create mode 100644 depRicKubernetesOperator/internal/controller/create_controller.go diff --git a/depRicKubernetesOperator/internal/controller/create_controller.go b/depRicKubernetesOperator/internal/controller/create_controller.go new file mode 100644 index 0000000..8c94658 --- /dev/null +++ b/depRicKubernetesOperator/internal/controller/create_controller.go @@ -0,0 +1,51 @@ +package controller + +import ( + "context" + "fmt" +) + +func (r *RicPlatformReconciler) CreateAll() { + var err error + namespaceProvided := "ricplt" + + 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) + } + } + + 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 GetDeployment()| 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 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) + } + } + +} -- 2.16.6