Skip to content

Commit c6ca0e4

Browse files
committed
do not fallback to kubernetes service URL querying if aggregating metrics from all kubernetes service endpoints fail for whatever reason
see #6565 (comment) Signed-off-by: julian GUINARD <[email protected]>
1 parent 75db0f7 commit c6ca0e4

File tree

1 file changed

+5
-12
lines changed

1 file changed

+5
-12
lines changed

pkg/scalers/metrics_api_scaler.go

+5-12
Original file line numberDiff line numberDiff line change
@@ -522,19 +522,12 @@ func (s *metricsAPIScaler) getMetricValue(ctx context.Context) (float64, error)
522522
if s.metadata.aggregateFromKubeServiceEndpoints {
523523
endpointsUrls, err := s.getEndpointsUrlsFromServiceURL(ctx, s.metadata.url)
524524
if err != nil {
525-
s.logger.Error(err, "Failed to get kubernetes endpoints urls from configured service URL. Falling back to querying url configured in metadata")
526-
} else {
527-
if len(endpointsUrls) == 0 {
528-
s.logger.Error(err, "No endpoints URLs were given for the service name. Falling back to querying url configured in metadata")
529-
} else {
530-
aggregatedMetric, err := s.aggregateMetricsFromMultipleEndpoints(ctx, endpointsUrls)
531-
if err != nil {
532-
s.logger.Error(err, "No aggregated metrics could be computed from service endpoints. Falling back to querying url configured in metadata")
533-
} else {
534-
return aggregatedMetric, err
535-
}
536-
}
525+
return 0, fmt.Errorf("failed to get kubernetes endpoints urls from configured service URL")
526+
}
527+
if len(endpointsUrls) == 0 {
528+
return 0, fmt.Errorf("no endpoints URLs were given for the service name")
537529
}
530+
return s.aggregateMetricsFromMultipleEndpoints(ctx, endpointsUrls)
538531
}
539532
// get single/unaggregated metric
540533
metric, err := s.getMetricValueFromURL(ctx, nil)

0 commit comments

Comments
 (0)