Add observability feature flag to Kuadrant CRD

Signed-off-by: David Martin <[email protected]>

api/v1beta1/kuadrant_types.go

@@ -54,6 +54,11 @@ func (p *Kuadrant) GetLocator() string {
 
 // KuadrantSpec defines the desired state of Kuadrant
 type KuadrantSpec struct {
+	Observability Observability `json:"observability,omitempty"`
+}
+
+type Observability struct {
+	Enable bool `json:"enable,omitempty"`
 }
 
 // KuadrantStatus defines the observed state of Kuadrant

api/v1beta1/topology.go

@@ -5,6 +5,7 @@ import (
 	limitadorv1alpha1 "github.com/kuadrant/limitador-operator/api/v1alpha1"
 	"github.com/kuadrant/policy-machinery/controller"
 	"github.com/kuadrant/policy-machinery/machinery"
+	monitoringv1 "github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring/v1"
 	"github.com/samber/lo"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	gatewayapiv1 "sigs.k8s.io/gateway-api/apis/v1"
@@ -61,3 +62,33 @@ func LinkKuadrantToAuthorino(objs controller.Store) machinery.LinkFunc {
 		},
 	}
 }
+
+func LinkKuadrantToServiceMonitor(objs controller.Store) machinery.LinkFunc {
+	kuadrants := lo.Map(objs.FilterByGroupKind(KuadrantGroupKind), controller.ObjectAs[machinery.Object])
+
+	return machinery.LinkFunc{
+		From: KuadrantGroupKind,
+		To:   schema.GroupKind{Group: monitoringv1.SchemeGroupVersion.Group, Kind: monitoringv1.ServiceMonitorsKind},
+		Func: func(child machinery.Object) []machinery.Object {
+			return lo.Filter(kuadrants, func(kuadrant machinery.Object, _ int) bool {
+				// ServiceMonitors outside the Kuadrant namespace will be outside the topology tree
+				return kuadrant.GetNamespace() == child.GetNamespace()
+			})
+		},
+	}
+}
+
+func LinkKuadrantToPodMonitor(objs controller.Store) machinery.LinkFunc {
+	kuadrants := lo.Map(objs.FilterByGroupKind(KuadrantGroupKind), controller.ObjectAs[machinery.Object])
+
+	return machinery.LinkFunc{
+		From: KuadrantGroupKind,
+		To:   schema.GroupKind{Group: monitoringv1.SchemeGroupVersion.Group, Kind: monitoringv1.PodMonitorsKind},
+		Func: func(child machinery.Object) []machinery.Object {
+			return lo.Filter(kuadrants, func(kuadrant machinery.Object, _ int) bool {
+				// PodMonitors outside the Kuadrant namespace will be outside the topology tree
+				return kuadrant.GetNamespace() == child.GetNamespace()
+			})
+		},
+	}
+}

bundle/manifests/kuadrant-operator.clusterserviceversion.yaml

@@ -109,7 +109,7 @@ metadata:
     capabilities: Basic Install
     categories: Integration & Delivery
     containerImage: quay.io/kuadrant/kuadrant-operator:latest
-    createdAt: "2024-12-09T09:56:27Z"
+    createdAt: "2025-02-10T11:02:45Z"
     description: A Kubernetes Operator to manage the lifecycle of the Kuadrant system
     operators.operatorframework.io/builder: operator-sdk-v1.32.0
     operators.operatorframework.io/project_layout: go.kubebuilder.io/v3

bundle/manifests/kuadrant.io_kuadrants.yaml

@@ -49,6 +49,12 @@ spec:
             type: object
           spec:
             description: KuadrantSpec defines the desired state of Kuadrant
+            properties:
+              observability:
+                properties:
+                  enable:
+                    type: boolean
+                type: object
             type: object
           status:
             description: KuadrantStatus defines the observed state of Kuadrant

config/crd/bases/kuadrant.io_kuadrants.yaml

@@ -47,6 +47,12 @@ spec:
             type: object
           spec:
             description: KuadrantSpec defines the desired state of Kuadrant
+            properties:
+              observability:
+                properties:
+                  enable:
+                    type: boolean
+                type: object
             type: object
           status:
             description: KuadrantStatus defines the observed state of Kuadrant