File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
staging/src/k8s.io/apiserver/pkg/endpoints/request Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -274,6 +274,7 @@ func AuditAnnotationsFromLatencyTrackers(ctx context.Context) map[string]string
274
274
mutatingWebhookLatencyKey = "apiserver.latency.k8s.io/mutating-webhook"
275
275
validatingWebhookLatencyKey = "apiserver.latency.k8s.io/validating-webhook"
276
276
decodeLatencyKey = "apiserver.latency.k8s.io/decode-response-object"
277
+ apfQueueWaitLatencyKey = "apiserver.latency.k8s.io/apf-queue-wait"
277
278
)
278
279
279
280
tracker , ok := LatencyTrackersFrom (ctx )
@@ -303,6 +304,8 @@ func AuditAnnotationsFromLatencyTrackers(ctx context.Context) map[string]string
303
304
if latency := tracker .DecodeTracker .GetLatency (); latency != 0 {
304
305
annotations [decodeLatencyKey ] = latency .String ()
305
306
}
306
-
307
+ if latency := tracker .APFQueueWaitTracker .GetLatency (); latency != 0 {
308
+ annotations [apfQueueWaitLatencyKey ] = latency .String ()
309
+ }
307
310
return annotations
308
311
}
You can’t perform that action at this time.
0 commit comments