From 9b21e11cf9f4cda7c985a588f60925f0766fac02 Mon Sep 17 00:00:00 2001 From: Abu Kashem Date: Fri, 1 Oct 2021 10:18:19 -0400 Subject: [PATCH] apf: print watch init latency in httplog --- .../apiserver/pkg/server/filters/priority-and-fairness.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go b/staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go index 2c2eebcb206..fd5a3ab9d1a 100644 --- a/staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go +++ b/staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go @@ -22,6 +22,7 @@ import ( "net/http" "runtime" "sync/atomic" + "time" flowcontrol "k8s.io/api/flowcontrol/v1beta2" apitypes "k8s.io/apimachinery/pkg/types" @@ -176,6 +177,10 @@ func WithPriorityAndFairness( }() execute := func() { + startedAt := time.Now() + defer func() { + httplog.AddKeyValue(ctx, "apf_init_latency", time.Now().Sub(startedAt)) + }() noteExecutingDelta(1) defer noteExecutingDelta(-1) served = true