Skip to content

Commit 1b81e2b

Browse files
committed
Review suggestions
1 parent 371fa38 commit 1b81e2b

File tree

1 file changed

+21
-17
lines changed

1 file changed

+21
-17
lines changed

controllers/metricstorage_controller.go

Lines changed: 21 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -666,15 +666,16 @@ func (r *MetricStorageReconciler) createScrapeConfigs(
666666
}
667667

668668
// compute nodes' exporters
669-
err = r.createComputeScrapeConfig(ctx, instance, helper, telemetry.ServiceName, "node-exporter", telemetryv1.DefaultNodeExporterPort, true)
669+
err = r.createComputeScrapeConfig(ctx, instance, helper, telemetry.ServiceName, "node-exporter", telemetryv1.DefaultNodeExporterPort, false)
670670
if err != nil {
671671
return ctrl.Result{}, err
672672
}
673-
err = r.createComputeScrapeConfig(ctx, instance, helper, telemetry.ServiceName, "podman-exporter", telemetryv1.DefaultPodmanExporterPort, true)
673+
err = r.createComputeScrapeConfig(ctx, instance, helper, telemetry.ServiceName, "podman-exporter", telemetryv1.DefaultPodmanExporterPort, false)
674674
if err != nil {
675675
return ctrl.Result{}, err
676676
}
677-
err = r.createComputeScrapeConfig(ctx, instance, helper, telemetryv1.TelemetryPowerMonitoring, "kepler", telemetryv1.DefaultKeplerPort, false) // Currently Kepler doesn't support TLS
677+
// Currently Kepler doesn't support TLS
678+
err = r.createComputeScrapeConfig(ctx, instance, helper, telemetryv1.TelemetryPowerMonitoring, "kepler", telemetryv1.DefaultKeplerPort, true)
678679
if err != nil {
679680
return ctrl.Result{}, err
680681
}
@@ -707,7 +708,7 @@ func (r *MetricStorageReconciler) createComputeScrapeConfig(
707708
serviceName string,
708709
exporterName string,
709710
exporterPort int,
710-
tls bool,
711+
suppressTLS bool,
711712
) error {
712713
Log := r.GetLogger(ctx)
713714

@@ -718,22 +719,25 @@ func (r *MetricStorageReconciler) createComputeScrapeConfig(
718719
targetsTLS, targetsNonTLS := getExporterTargets(connectionInfo, exporterPort)
719720

720721
// ScrapeConfig for non-tls nodes
721-
if len(targetsNonTLS) > 0 {
722-
fullServiceName := fmt.Sprintf("%s-%s", telemetry.ServiceName, exporterName)
723-
desiredScrapeConfig := metricstorage.ScrapeConfig(
724-
instance,
725-
serviceLabels,
726-
targetsNonTLS,
727-
false,
728-
)
729-
err = r.createServiceScrapeConfig(ctx, instance, Log, exporterName, fullServiceName, desiredScrapeConfig)
730-
if err != nil {
731-
return err
732-
}
722+
//NOTE(mmagr): remove TLS suppression functionality once Kepler supports TLS
723+
targets := targetsNonTLS
724+
if suppressTLS {
725+
targets = targetsTLS
726+
}
727+
fullServiceName := fmt.Sprintf("%s-%s", telemetry.ServiceName, exporterName)
728+
desiredScrapeConfig := metricstorage.ScrapeConfig(
729+
instance,
730+
serviceLabels,
731+
targets,
732+
false,
733+
)
734+
err = r.createServiceScrapeConfig(ctx, instance, Log, exporterName, fullServiceName, desiredScrapeConfig)
735+
if err != nil {
736+
return err
733737
}
734738

735739
// ScrapeConfig for tls nodes
736-
if tls && len(targetsTLS) > 0 {
740+
if !suppressTLS {
737741
fullServiceName := fmt.Sprintf("%s-%s-tls", telemetry.ServiceName, exporterName)
738742
desiredScrapeConfig := metricstorage.ScrapeConfig(
739743
instance,

0 commit comments

Comments
 (0)