- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewWorkEstimator (0.25 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width.go
// allowed for the work estimator for a given priority level. type maxSeatsFunc func(priorityLevelName string) uint64 // NewWorkEstimator estimates the work that will be done by a given request, // if no WorkEstimatorFunc matches the given request then the default // work estimate of 1 seat is allocated to the request.
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/width_test.go
} watchCountsFn := func(_ *apirequest.RequestInfo) int { return test.watchCount } maxSeatsFn := func(_ string) uint64 { return test.maxSeats } estimator := NewWorkEstimator(countsFn, watchCountsFn, defaultCfg, maxSeatsFn) req, err := http.NewRequest("GET", test.requestURI, nil) if err != nil { t.Fatalf("Failed to create new HTTP request - %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
if c.FlowControl != nil { workEstimatorCfg := flowcontrolrequest.DefaultWorkEstimatorConfig() requestWorkEstimator := flowcontrolrequest.NewWorkEstimator( c.StorageObjectCountTracker.Get, c.FlowControl.GetInterestedWatchCount, workEstimatorCfg, c.FlowControl.GetMaxSeats) handler = filterlatency.TrackCompleted(handler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0)