Add NodeSelector for MetricStorage

Author: vyzigold

api/bases/telemetry.openstack.org_metricstorages.yaml

@@ -1742,6 +1742,12 @@ spec:
                     default: true
                     description: AlertingEnabled allows to enable or disable alertmanager
                     type: boolean
+                  nodeSelector:
+                    additionalProperties:
+                      type: string
+                    description: NodeSelector to target subset of worker nodes running
+                      this service
+                    type: object
                   scrapeInterval:
                     default: 30s
                     description: ScrapeInterval sets the interval between scrapes

api/bases/telemetry.openstack.org_telemetries.yaml

@@ -3134,6 +3134,12 @@ spec:
                         default: true
                         description: AlertingEnabled allows to enable or disable alertmanager
                         type: boolean
+                      nodeSelector:
+                        additionalProperties:
+                          type: string
+                        description: NodeSelector to target subset of worker nodes
+                          running this service
+                        type: object
                       scrapeInterval:
                         default: 30s
                         description: ScrapeInterval sets the interval between scrapes

api/v1beta1/metricstorage_types.go

@@ -76,6 +76,10 @@ type MonitoringStack struct {
 	// +kubebuilder:validation:Optional
 	// +kubebuilder:default={strategy: persistent, retention: "24h", persistent: {pvcStorageRequest: "20G"}}
 	Storage `json:"storage"`
+
+	// +kubebuilder:validation:Optional
+	// NodeSelector to target subset of worker nodes running this service
+	NodeSelector *map[string]string `json:"nodeSelector,omitempty"`
 }
 
 // MetricStorageSpec defines the desired state of MetricStorage

api/v1beta1/zz_generated.deepcopy.go

@@ -1742,6 +1742,12 @@ spec:
                     default: true
                     description: AlertingEnabled allows to enable or disable alertmanager
                     type: boolean
+                  nodeSelector:
+                    additionalProperties:
+                      type: string
+                    description: NodeSelector to target subset of worker nodes running
+                      this service
+                    type: object
                   scrapeInterval:
                     default: 30s
                     description: ScrapeInterval sets the interval between scrapes

config/crd/bases/telemetry.openstack.org_metricstorages.yaml

@@ -3134,6 +3134,12 @@ spec:
                         default: true
                         description: AlertingEnabled allows to enable or disable alertmanager
                         type: boolean
+                      nodeSelector:
+                        additionalProperties:
+                          type: string
+                        description: NodeSelector to target subset of worker nodes
+                          running this service
+                        type: object
                       scrapeInterval:
                         default: 30s
                         description: ScrapeInterval sets the interval between scrapes

config/crd/bases/telemetry.openstack.org_telemetries.yaml

@@ -435,6 +435,10 @@ func (r TelemetryReconciler) reconcileMetricStorage(ctx context.Context, instanc
 		return ctrl.Result{}, nil
 	}
 
+	if instance.Spec.MetricStorage.MonitoringStack != nil && instance.Spec.MetricStorage.MonitoringStack.NodeSelector == nil {
+		instance.Spec.MetricStorage.MonitoringStack.NodeSelector = instance.Spec.NodeSelector
+	}
+
 	helper.GetLogger().Info("Reconciling MetricStorage", metricStorageNamespaceLabel, instance.Namespace, metricStorageNameLabel, telemetryv1.DefaultServiceName)
 	op, err := controllerutil.CreateOrPatch(ctx, helper.GetClient(), metricStorageInstance, func() error {
 		instance.Spec.MetricStorage.MetricStorageSpec.DeepCopyInto(&metricStorageInstance.Spec)

internal/controller/telemetry_controller.go

@@ -62,6 +62,10 @@ func MonitoringStack(
 			},
 		},
 	}
+
+	if instance.Spec.MonitoringStack.NodeSelector != nil {
+		monitoringStack.Spec.NodeSelector = *instance.Spec.MonitoringStack.NodeSelector
+	}
 	return monitoringStack, nil
 }
 

internal/metricstorage/monitoring_stack.go

@@ -183,6 +183,10 @@ apiVersion: telemetry.openstack.org/v1beta1
 kind: MetricStorage
 metadata:
   name: metric-storage
+spec:
+  monitoringStack:
+    nodeSelector:
+      kubernetes.io/os: linux
 status:
   conditions:
     - type: Ready

test/kuttl/tests/default/01-assert.yaml

@@ -3,6 +3,8 @@ kind: Telemetry
 metadata:
   name: telemetry-kuttl
 spec:
+  nodeSelector:
+    kubernetes.io/os: linux
   metricStorage:
     enabled: true
     monitoringStack: