kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

apf: add initial and final seats to httplog 

Kubernetes-commit: be085b63455738d3f89fd804c84ae7ab0ac81008
This commit is contained in:
Abu Kashem 2021-11-23 10:26:10 -05:00 committed by Kubernetes Publisher
parent 623d4c094b
commit b88c96a347
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/server/filters/priority-and-fairness.go
View File

@ -111,6 +111,7 @@ func WithPriorityAndFairness(
httplog.AddKeyValue(ctx, "apf_pl", truncateLogField(pl.Name)) httplog.AddKeyValue(ctx, "apf_pl", truncateLogField(pl.Name))
httplog.AddKeyValue(ctx, "apf_fs", truncateLogField(fs.Name)) httplog.AddKeyValue(ctx, "apf_fs", truncateLogField(fs.Name))
httplog.AddKeyValue(ctx, "apf_fd", truncateLogField(flowDistinguisher)) httplog.AddKeyValue(ctx, "apf_fd", truncateLogField(flowDistinguisher))
<<<<<<< HEAD
} }
// estimateWork is called, if at all, after noteFn // estimateWork is called, if at all, after noteFn
estimateWork := func() flowcontrolrequest.WorkEstimate { estimateWork := func() flowcontrolrequest.WorkEstimate {
@ -123,7 +124,12 @@ func WithPriorityAndFairness(
return workEstimator(r, "", "") return workEstimator(r, "", "")
} }
return workEstimator(r, classification.FlowSchemaName, classification.PriorityLevelName) workEstimate := workEstimator(r, classification.FlowSchemaName, classification.PriorityLevelName)
if klog.V(4).Enabled() {
httplog.AddKeyValue(ctx, "apf_iseats", workEstimate.InitialSeats)
httplog.AddKeyValue(ctx, "apf_fseats", workEstimate.FinalSeats)
}
return workEstimate
} }
var served bool var served bool