Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for DefaultWorkEstimatorConfig (0.38 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/config.go

    	EventAdditionalDuration metav1.Duration `json:"eventAdditionalDurationMs,omitempty"`
    	WatchesPerSeat          float64         `json:"watchesPerSeat,omitempty"`
    }
    
    // DefaultWorkEstimatorConfig creates a new WorkEstimatorConfig with default values.
    func DefaultWorkEstimatorConfig() *WorkEstimatorConfig {
    	return &WorkEstimatorConfig{
    		MinimumSeats:                minimumSeats,
    		MaximumSeatsLimit:           maximumSeatsLimit,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 19:26:52 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width_test.go

    )
    
    func TestWorkEstimator(t *testing.T) {
    	featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.WatchList, true)
    
    	defaultCfg := DefaultWorkEstimatorConfig()
    
    	tests := []struct {
    		name                      string
    		requestURI                string
    		requestInfo               *apirequest.RequestInfo
    		counts                    map[string]int64
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/config.go

    	handler = filterlatency.TrackStarted(handler, c.TracerProvider, "authorization")
    
    	if c.FlowControl != nil {
    		workEstimatorCfg := flowcontrolrequest.DefaultWorkEstimatorConfig()
    		requestWorkEstimator := flowcontrolrequest.NewWorkEstimator(
    			c.StorageObjectCountTracker.Get, c.FlowControl.GetInterestedWatchCount, workEstimatorCfg, c.FlowControl.GetMaxSeats)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
Back to top