Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewWorkEstimator (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top