Skip to content

Commit 105fe81

Browse files
committed
fix fhpa metrics issue introduced by #6300
Signed-off-by: tangzr1 <tangzr1@chinatelecom.cn>
1 parent c719555 commit 105fe81

File tree

3 files changed

+18
-6
lines changed

3 files changed

+18
-6
lines changed

pkg/controllers/cronfederatedhpa/cronfederatedhpa_controller.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,9 @@ func (c *CronFHPAController) Reconcile(ctx context.Context, req controllerruntim
7878

7979
var err error
8080
startTime := time.Now()
81-
defer metrics.ObserveProcessCronFederatedHPALatency(err, startTime)
81+
defer func() {
82+
metrics.ObserveProcessCronFederatedHPALatency(err, startTime)
83+
}()
8284

8385
origRuleSets := sets.New[string]()
8486
for _, history := range cronFHPA.Status.ExecutionHistories {

pkg/controllers/federatedhpa/federatedhpa_controller.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,9 @@ func (c *FHPAController) Reconcile(ctx context.Context, req controllerruntime.Re
176176
// observe process FederatedHPA latency
177177
var err error
178178
startTime := time.Now()
179-
defer metrics.ObserveProcessFederatedHPALatency(err, startTime)
179+
defer func() {
180+
metrics.ObserveProcessFederatedHPALatency(err, startTime)
181+
}()
180182

181183
err = c.reconcileAutoscaler(ctx, hpa)
182184
if err != nil {

pkg/controllers/federatedhpa/metrics/client.go

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,9 @@ func (c *resourceMetricsClient) GetResourceMetric(ctx context.Context, resource
7070
// observe pull ResourceMetric latency
7171
var err error
7272
startTime := time.Now()
73-
defer metrics.ObserveFederatedHPAPullMetricsLatency(err, "ResourceMetric", startTime)
73+
defer func() {
74+
metrics.ObserveFederatedHPAPullMetricsLatency(err, "ResourceMetric", startTime)
75+
}()
7476

7577
podMetrics, err := c.client.PodMetricses(namespace).List(ctx, metav1.ListOptions{LabelSelector: selector.String()})
7678
if err != nil {
@@ -154,7 +156,9 @@ func (c *customMetricsClient) GetRawMetric(metricName string, namespace string,
154156
// observe pull RawMetric latency
155157
var err error
156158
startTime := time.Now()
157-
defer metrics.ObserveFederatedHPAPullMetricsLatency(err, "RawMetric", startTime)
159+
defer func() {
160+
metrics.ObserveFederatedHPAPullMetricsLatency(err, "RawMetric", startTime)
161+
}()
158162

159163
metricList, err := c.client.NamespacedMetrics(namespace).GetForObjects(schema.GroupKind{Kind: "Pod"}, selector, metricName, metricSelector)
160164
if err != nil {
@@ -191,7 +195,9 @@ func (c *customMetricsClient) GetObjectMetric(metricName string, namespace strin
191195
// observe pull ObjectMetric latency
192196
var err error
193197
startTime := time.Now()
194-
defer metrics.ObserveFederatedHPAPullMetricsLatency(err, "ObjectMetric", startTime)
198+
defer func() {
199+
metrics.ObserveFederatedHPAPullMetricsLatency(err, "ObjectMetric", startTime)
200+
}()
195201

196202
gvk := schema.FromAPIVersionAndKind(objectRef.APIVersion, objectRef.Kind)
197203
var metricValue *customapi.MetricValue
@@ -223,7 +229,9 @@ func (c *externalMetricsClient) GetExternalMetric(metricName, namespace string,
223229
// observe pull ExternalMetric latency
224230
var err error
225231
startTime := time.Now()
226-
defer metrics.ObserveFederatedHPAPullMetricsLatency(err, "ExternalMetric", startTime)
232+
defer func() {
233+
metrics.ObserveFederatedHPAPullMetricsLatency(err, "ExternalMetric", startTime)
234+
}()
227235

228236
externalMetrics, err := c.client.NamespacedMetrics(namespace).List(metricName, selector)
229237
if err != nil {

0 commit comments

Comments
 (0)