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 GetCustomResourceDefinition() {\r
  13                 if resource.GetNamespace() == "" {\r
  14                         resource.SetNamespace(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 GetCustomResourceDefinition()| Error --> |", err)\r
  19                 }\r
  20         }\r
  21 \r
  22         for _, resource := range GetJob() {\r
  23                 if resource.GetNamespace() == "" {\r
  24                         resource.SetNamespace(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 GetJob()| Error --> |", err)\r
  29                 }\r
  30         }\r
  31 \r
  32         for _, resource := range GetDeployment() {\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 GetDeployment()| Error --> |", err)\r
  39                 }\r
  40         }\r
  41 \r
  42         for _, resource := range GetPersistentVolume() {\r
  43                 if resource.GetNamespace() == "" {\r
  44                         resource.SetNamespace(namespaceProvided)\r
  45                 }\r
  46                 err = r.Create(context.TODO(), resource)\r
  47                 if err != nil {\r
  48                         fmt.Println("Erorr During Creating resource of GetPersistentVolume()| Error --> |", err)\r
  49                 }\r
  50         }\r
  51 \r
  52         for _, resource := range GetClusterRole() {\r
  53                 if resource.ObjectMeta.Namespace == "" {\r
  54                         resource.ObjectMeta.Namespace = namespaceProvided\r
  55                 }\r
  56                 err = r.Create(context.TODO(), resource)\r
  57                 if err != nil {\r
  58                         fmt.Println("Erorr During Creating resource of GetClusterRole()| Error --> |", err)\r
  59                 }\r
  60         }\r
  61 \r
  62         for _, resource := range GetEndpoints() {\r
  63                 if resource.GetNamespace() == "" {\r
  64                         resource.SetNamespace(namespaceProvided)\r
  65                 }\r
  66                 err = r.Create(context.TODO(), resource)\r
  67                 if err != nil {\r
  68                         fmt.Println("Erorr During Creating resource of GetEndpoints()| Error --> |", err)\r
  69                 }\r
  70         }\r
  71 \r
  72         for _, resource := range GetConfigMap() {\r
  73                 if resource.ObjectMeta.Namespace == "" {\r
  74                         resource.ObjectMeta.Namespace = namespaceProvided\r
  75                 }\r
  76                 err = r.Create(context.TODO(), resource)\r
  77                 if err != nil {\r
  78                         fmt.Println("Erorr During Creating resource of GetConfigMap()| Error --> |", err)\r
  79                 }\r
  80         }\r
  81 \r
  82         for _, resource := range GetService() {\r
  83                 if resource.ObjectMeta.Namespace == "" {\r
  84                         resource.ObjectMeta.Namespace = namespaceProvided\r
  85                 }\r
  86                 err = r.Create(context.TODO(), resource)\r
  87                 if err != nil {\r
  88                         fmt.Println("Erorr During Creating resource of GetService()| Error --> |", err)\r
  89                 }\r
  90         }\r
  91 \r
  92         for _, resource := range GetRoleBinding() {\r
  93                 if resource.ObjectMeta.Namespace == "" {\r
  94                         resource.ObjectMeta.Namespace = namespaceProvided\r
  95                 }\r
  96                 err = r.Create(context.TODO(), resource)\r
  97                 if err != nil {\r
  98                         fmt.Println("Erorr During Creating resource of GetRoleBinding()| Error --> |", err)\r
  99                 }\r
 100         }\r
 101 \r
 102         for _, resource := range GetStatefulSet() {\r
 103                 if resource.ObjectMeta.Namespace == "" {\r
 104                         resource.ObjectMeta.Namespace = namespaceProvided\r
 105                 }\r
 106                 err = r.Create(context.TODO(), resource)\r
 107                 if err != nil {\r
 108                         fmt.Println("Erorr During Creating resource of GetStatefulSet()| Error --> |", err)\r
 109                 }\r
 110         }\r
 111 \r
 112         for _, resource := range GetIngress() {\r
 113                 if resource.GetNamespace() == "" {\r
 114                         resource.SetNamespace(namespaceProvided)\r
 115                 }\r
 116                 err = r.Create(context.TODO(), resource)\r
 117                 if err != nil {\r
 118                         fmt.Println("Erorr During Creating resource of GetIngress()| Error --> |", err)\r
 119                 }\r
 120         }\r
 121 \r
 122         for _, resource := range GetPersistentVolumeClaim() {\r
 123                 if resource.ObjectMeta.Namespace == "" {\r
 124                         resource.ObjectMeta.Namespace = namespaceProvided\r
 125                 }\r
 126                 err = r.Create(context.TODO(), resource)\r
 127                 if err != nil {\r
 128                         fmt.Println("Erorr During Creating resource of GetPersistentVolumeClaim()| Error --> |", err)\r
 129                 }\r
 130         }\r
 131 \r
 132         for _, resource := range GetServiceAccount() {\r
 133                 if resource.ObjectMeta.Namespace == "" {\r
 134                         resource.ObjectMeta.Namespace = namespaceProvided\r
 135                 }\r
 136                 err = r.Create(context.TODO(), resource)\r
 137                 if err != nil {\r
 138                         fmt.Println("Erorr During Creating resource of GetServiceAccount()| Error --> |", err)\r
 139                 }\r
 140         }\r
 141 \r
 142         for _, resource := range GetRole() {\r
 143                 if resource.ObjectMeta.Namespace == "" {\r
 144                         resource.ObjectMeta.Namespace = namespaceProvided\r
 145                 }\r
 146                 err = r.Create(context.TODO(), resource)\r
 147                 if err != nil {\r
 148                         fmt.Println("Erorr During Creating resource of GetRole()| Error --> |", err)\r
 149                 }\r
 150         }\r
 151 \r
 152         for _, resource := range GetSecret() {\r
 153                 if resource.ObjectMeta.Namespace == "" {\r
 154                         resource.ObjectMeta.Namespace = namespaceProvided\r
 155                 }\r
 156                 err = r.Create(context.TODO(), resource)\r
 157                 if err != nil {\r
 158                         fmt.Println("Erorr During Creating resource of GetSecret()| Error --> |", err)\r
 159                 }\r
 160         }\r
 161 \r
 162         for _, resource := range GetClusterRoleBinding() {\r
 163                 if resource.ObjectMeta.Namespace == "" {\r
 164                         resource.ObjectMeta.Namespace = namespaceProvided\r
 165                 }\r
 166                 err = r.Create(context.TODO(), resource)\r
 167                 if err != nil {\r
 168                         fmt.Println("Erorr During Creating resource of GetClusterRoleBinding()| Error --> |", err)\r
 169                 }\r
 170         }\r
 171 \r
 172 }