Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetExecutingReadonlyConcurrency (0.43 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go

    		// Fetching these gauges is delayed until after their underlying metric has been registered
    		// so that this latches onto the efficient implementation.
    		watermark.readOnlyObserver = fcmetrics.GetExecutingReadonlyConcurrency()
    		watermark.mutatingObserver = fcmetrics.GetExecutingMutatingConcurrency()
    		if nonMutatingLimit != 0 {
    			watermark.readOnlyObserver.SetDenominator(float64(nonMutatingLimit))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 11:34:15 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go

    var GetWaitingReadonlyConcurrency = waitingReadonly.getGauge
    
    // GetExecutingReadonlyConcurrency returns the gauge of number of executing readonly requests / limit on those.
    var GetExecutingReadonlyConcurrency = executingReadonly.getGauge
    
    // GetWaitingMutatingConcurrency returns the gauge of number of mutating requests waiting / limit on those.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 24 19:40:05 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    	metrics.GetWaitingReadonlyConcurrency().SetDenominator(float64(meal.maxWaitingRequests))
    	metrics.GetWaitingMutatingConcurrency().SetDenominator(float64(meal.maxWaitingRequests))
    	metrics.GetExecutingReadonlyConcurrency().SetDenominator(float64(meal.maxExecutingRequests))
    	metrics.GetExecutingMutatingConcurrency().SetDenominator(float64(meal.maxExecutingRequests))
    
    	return meal.fsStatusUpdates
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
Back to top