depRicKubernetesOperator/internal/controller/create_controller.go

   1 package controller\r
   2 \r
   3 import (\r
   4         "context"\r
   5         "fmt"\r
   6 )\r
   7 \r
   8 func (r *RicPlatformReconciler) CreateAll() {\r
   9         var err error\r
  10         namespaceProvided := "ricplt"\r
  11 \r
  12         for _, resource := range GetConfigMap() {\r
  13                 if resource.ObjectMeta.Namespace == "" {\r
  14                         resource.ObjectMeta.Namespace = namespaceProvided\r
  15                 }\r
  16                 err = r.Create(context.TODO(), resource)\r
  17                 if err != nil {\r
  18                         fmt.Println("Erorr During Creating resource of GetConfigMap()| Error --> |", err)\r
  19                 }\r
  20         }\r
  21 \r
  22         for _, resource := range getDeployment() {\r
  23                 if resource.ObjectMeta.Namespace == "" {\r
  24                         resource.ObjectMeta.Namespace = namespaceProvided\r
  25                 }\r
  26                 err = r.Create(context.TODO(), resource)\r
  27                 if err != nil {\r
  28                         fmt.Println("Erorr During Creating resource of GetDeployment()| Error --> |", err)\r
  29                 }\r
  30         }\r
  31 \r
  32         for _, resource := range GetService() {\r
  33                 if resource.ObjectMeta.Namespace == "" {\r
  34                         resource.ObjectMeta.Namespace = namespaceProvided\r
  35                 }\r
  36                 err = r.Create(context.TODO(), resource)\r
  37                 if err != nil {\r
  38                         fmt.Println("Erorr During Creating resource of GetService()| Error --> |", err)\r
  39                 }\r
  40         }\r
  41         for _, resource := range GetIngress() {\r
  42                 if resource.GetNamespace() == "" {\r
  43                         resource.SetNamespace(namespaceProvided)\r
  44                 }\r
  45                 err = r.Create(context.TODO(), resource)\r
  46                 if err != nil {\r
  47                         fmt.Println("Erorr During Creating resource of GetIngress()| Error --> |", err)\r
  48                 }\r
  49         }\r
  50 \r
  51 }\r