kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go

func newMutatingWorkEstimator(countFn watchCountGetterFunc, config *WorkEstimatorConfig, maxSeatsFn maxSeatsFunc) WorkEstimatorFunc { … }

type mutatingWorkEstimator …

func (e *mutatingWorkEstimator) estimate(r *http.Request, flowSchemaName, priorityLevelName string) WorkEstimate { … }

func isRequestExemptFromWatchEvents(requestInfo *apirequest.RequestInfo) bool { … }