[controller] Propagating Limitador's env vars

* limitador namespace
* limitador service name
* limitador service grpc port

* Using keyed values

Author: didierofrivia

controllers/kuadrant_controller.go

@@ -21,13 +21,13 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-
 	"github.com/go-logr/logr"
 	authorinov1beta1 "github.com/kuadrant/authorino-operator/api/v1beta1"
 	limitadorv1alpha1 "github.com/kuadrant/limitador-operator/api/v1alpha1"
 	istioapiv1alpha1 "istio.io/api/operator/v1alpha1"
 	iopv1alpha1 "istio.io/istio/operator/pkg/apis/istio/v1alpha1"
 	appsv1 "k8s.io/api/apps/v1"
+	v1 "k8s.io/api/core/v1"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
@@ -43,8 +43,15 @@ import (
 )
 
 const (
-	kuadrantFinalizer = "kuadrant.kuadrant.io/finalizer"
-	extAuthorizerName = "kuadrant-authorization"
+	kuadrantFinalizer    = "kuadrant.kuadrant.io/finalizer"
+	extAuthorizerName    = "kuadrant-authorization"
+	envLimitadorName     = "LIMITADOR_NAME"
+	envLimitadorGrpcPort = "LIMITADOR_GRPC_PORT"
+)
+
+var (
+	limitadorName     = common.FetchEnv(envLimitadorName, "limitador")
+	limitadorGrpcPort = common.FetchEnv(envLimitadorGrpcPort, "8081")
 )
 
 // KuadrantReconciler reconciles a Kuadrant object
@@ -341,7 +348,7 @@ func (r *KuadrantReconciler) reconcileLimitador(ctx context.Context, kObj *kuadr
 			APIVersion: "limitador.kuadrant.io/v1alpha1",
 		},
 		ObjectMeta: metav1.ObjectMeta{
-			Name:      "limitador",
+			Name:      limitadorName,
 			Namespace: kObj.Namespace,
 		},
 		Spec: limitadorv1alpha1.LimitadorSpec{},
@@ -386,14 +393,27 @@ func (r *KuadrantReconciler) createOnlyInKuadrantNSCb(ctx context.Context, kObj
 			return err
 		}
 
-		k8sObjKind := k8sObj.DeepCopyObject().GetObjectKind()
+		var newObj client.Object
+		newObj = k8sObj
+
+		switch obj := k8sObj.(type) {
+		case *appsv1.Deployment: // If it's a Deployment obj, it adds the required env vars
+			obj.Spec.Template.Spec.Containers[0].Env = []v1.EnvVar{
+				{Name: "LIMITADOR_NAMESPACE", Value: kObj.Namespace},
+				{Name: envLimitadorName, Value: limitadorName},
+				{Name: envLimitadorGrpcPort, Value: limitadorGrpcPort},
+			}
+			newObj = obj
+		default:
+		}
+		err = r.Client().Create(ctx, newObj)
 
-		err = r.Client().Create(ctx, k8sObj)
-		logger.V(1).Info("create resource", "GKV", k8sObjKind.GroupVersionKind(), "name", k8sObj.GetName(), "error", err)
+		k8sObjKind := newObj.DeepCopyObject().GetObjectKind()
+		logger.V(1).Info("create resource", "GKV", k8sObjKind.GroupVersionKind(), "name", newObj.GetName(), "error", err)
 		if err != nil {
 			if apierrors.IsAlreadyExists(err) {
 				// Omit error
-				logger.Info("Already exists", "GKV", k8sObjKind.GroupVersionKind(), "name", k8sObj.GetName())
+				logger.Info("Already exists", "GKV", k8sObjKind.GroupVersionKind(), "name", newObj.GetName())
 			} else {
 				return err
 			}