Skip to content

Commit b456ba6

Browse files
committed
Fixed labels for PodMonitor
Signed-off-by: Yuri Sa <[email protected]>
1 parent 32bf984 commit b456ba6

File tree

3 files changed

+7
-8
lines changed

3 files changed

+7
-8
lines changed

internal/manifests/collector/podmonitor.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ import (
2828
"github.com/open-telemetry/opentelemetry-operator/internal/naming"
2929
)
3030

31-
// ServiceMonitor returns the service monitor for the given instance.
31+
// PodMonitor returns the pod monitor for the given instance.
3232
func PodMonitor(params manifests.Params) (*monitoringv1.PodMonitor, error) {
3333
if !params.OtelCol.Spec.Observability.Metrics.EnableMetrics {
3434
params.Log.V(2).Info("Metrics disabled for this OTEL Collector",
@@ -42,9 +42,9 @@ func PodMonitor(params manifests.Params) (*monitoringv1.PodMonitor, error) {
4242
if params.OtelCol.Spec.Mode != v1alpha1.ModeSidecar {
4343
return nil, nil
4444
}
45-
name := naming.ServiceMonitor(params.OtelCol.Name)
45+
name := naming.PodMonitor(params.OtelCol.Name)
4646
labels := manifestutils.Labels(params.OtelCol.ObjectMeta, name, params.OtelCol.Spec.Image, ComponentOpenTelemetryCollector, []string{})
47-
selectorMatchLabels := manifestutils.SelectorMatchLabels(params.OtelCol.ObjectMeta, ComponentOpenTelemetryCollector)
47+
selectorLabels := manifestutils.SelectorLabels(params.OtelCol.ObjectMeta, ComponentOpenTelemetryCollector)
4848
pm = monitoringv1.PodMonitor{
4949
ObjectMeta: metav1.ObjectMeta{
5050
Namespace: params.OtelCol.Namespace,
@@ -58,7 +58,7 @@ func PodMonitor(params manifests.Params) (*monitoringv1.PodMonitor, error) {
5858
MatchNames: []string{params.OtelCol.Namespace},
5959
},
6060
Selector: metav1.LabelSelector{
61-
MatchLabels: selectorMatchLabels,
61+
MatchLabels: selectorLabels,
6262
},
6363
PodMetricsEndpoints: append(
6464
[]monitoringv1.PodMetricsEndpoint{

internal/manifests/collector/podmonitor_test.go

+2-4
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,6 @@ func TestDesiredPodMonitors(t *testing.T) {
4848
"app.kubernetes.io/instance": fmt.Sprintf("%s.%s", params.OtelCol.Namespace, params.OtelCol.Name),
4949
"app.kubernetes.io/managed-by": "opentelemetry-operator",
5050
"app.kubernetes.io/part-of": "opentelemetry",
51-
"app.kubernetes.io/name": fmt.Sprintf("%s-monitoring", params.OtelCol.Name),
5251
}
5352
assert.Equal(t, expectedSelectorLabels, actual.Spec.Selector.MatchLabels)
5453
}
@@ -67,11 +66,10 @@ func TestDesiredPodMonitorsWithPrometheus(t *testing.T) {
6766
assert.Equal(t, "prometheus-dev", actual.Spec.PodMetricsEndpoints[1].Port)
6867
assert.Equal(t, "prometheus-prod", actual.Spec.PodMetricsEndpoints[2].Port)
6968
expectedSelectorLabels := map[string]string{
70-
"app.kubernetes.io/component": "opentelemetry-collector",
71-
"app.kubernetes.io/instance": fmt.Sprintf("%s.%s", params.OtelCol.Namespace, params.OtelCol.Name),
7269
"app.kubernetes.io/managed-by": "opentelemetry-operator",
70+
"app.kubernetes.io/instance": fmt.Sprintf("%s.%s", params.OtelCol.Namespace, params.OtelCol.Name),
7371
"app.kubernetes.io/part-of": "opentelemetry",
74-
"app.kubernetes.io/name": fmt.Sprintf("%s-monitoring", params.OtelCol.Name),
72+
"app.kubernetes.io/component": "opentelemetry-collector",
7573
}
7674
assert.Equal(t, expectedSelectorLabels, actual.Spec.Selector.MatchLabels)
7775
}

internal/manifests/manifestutils/labels.go

+1
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ func SelectorLabels(instance metav1.ObjectMeta, component string) map[string]str
8383
}
8484
}
8585

86+
// SelectorMatchLabels return the common labels that should be used on ServiceMonitor when the Spec.Observability.Metrics.EnableMetrics is true.
8687
func SelectorMatchLabels(instance metav1.ObjectMeta, component string) map[string]string {
8788
return map[string]string{
8889
"app.kubernetes.io/managed-by": "opentelemetry-operator",

0 commit comments

Comments
 (0)