- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newMutatingWorkEstimator (0.35 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width.go
minimumSeats: config.MinimumSeats, maximumSeatsLimit: config.MaximumSeatsLimit, listWorkEstimator: newListWorkEstimator(objectCountFn, config, maxSeatsFn), mutatingWorkEstimator: newMutatingWorkEstimator(watchCountFn, config, maxSeatsFn), } return estimator.estimate } // WorkEstimatorFunc returns the estimated work of a given request. // This function will be used by the Priority & Fairness filter to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
*/ package request import ( "math" "net/http" "time" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/util/flowcontrol/metrics" ) func newMutatingWorkEstimator(countFn watchCountGetterFunc, config *WorkEstimatorConfig, maxSeatsFn maxSeatsFunc) WorkEstimatorFunc { estimator := &mutatingWorkEstimator{ config: config, countFn: countFn, maxSeatsFn: maxSeatsFn, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0)