Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for initMaxInFlight (0.29 sec)

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

    		metrics.UpdateInflightRequestMetrics(watermark.phase, readOnlyWatermark, mutatingWatermark)
    	}, inflightUsageMetricUpdatePeriod, stopCh)
    }
    
    var initMaxInFlightOnce sync.Once
    
    func initMaxInFlight(nonMutatingLimit, mutatingLimit int) {
    	initMaxInFlightOnce.Do(func() {
    		// Fetching these gauges is delayed until after their underlying metric has been registered
    		// so that this latches onto the efficient implementation.
    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/server/filters/priority-and-fairness.go

    	defaultRequestWaitLimit time.Duration,
    ) http.Handler {
    	if fcIfc == nil {
    		klog.Warningf("priority and fairness support not found, skipping")
    		return handler
    	}
    	initAPFOnce.Do(func() {
    		initMaxInFlight(0, 0)
    		// Fetching these gauges is delayed until after their underlying metric has been registered
    		// so that this latches onto the efficient implementation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.3K bytes
    - Viewed (0)
Back to top