Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SetDenominator (0.21 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/interface.go

    // The numerator is set/changed through the Gauge methods,
    // and the denominator can be updated through the SetDenominator method.
    // A ratio is tracked whenever the numerator or denominator is set/changed.
    type RatioedGauge interface {
    	Gauge
    
    	// SetDenominator sets the denominator to use until it is changed again
    	SetDenominator(float64)
    }
    
    // RatioedGaugeVec creates related observers that are
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 13 03:37:15 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go

    		if nonMutatingLimit != 0 {
    			watermark.readOnlyObserver.SetDenominator(float64(nonMutatingLimit))
    			klog.V(2).InfoS("Set denominator for readonly requests", "limit", nonMutatingLimit)
    		}
    		if mutatingLimit != 0 {
    			watermark.mutatingObserver.SetDenominator(float64(mutatingLimit))
    			klog.V(2).InfoS("Set denominator for mutating requests", "limit", mutatingLimit)
    		}
    	})
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 11:34:15 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram.go

    	trh.Add(-1)
    }
    
    func (trh *timingRatioHistogramInner) SetToCurrentTime() {
    	trh.Set(float64(trh.nowFunc().Sub(time.Unix(0, 0))))
    }
    
    func (trh *timingRatioHistogramInner) SetDenominator(denominator float64) {
    	trh.Lock()
    	defer trh.Unlock()
    	trh.denominator = denominator
    	ratio := trh.numerator / denominator
    	trh.getGaugeOfRatio().Set(ratio)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 03 06:51:04 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go

    	if qll < 1 {
    		qll = 1
    	}
    	if qCfg.DesiredNumQueues > 0 {
    		qll *= qCfg.DesiredNumQueues
    	}
    	qs.reqsGaugePair.RequestsWaiting.SetDenominator(float64(qll))
    	qs.reqsGaugePair.RequestsExecuting.SetDenominator(float64(dCfg.ConcurrencyDenominator))
    	qs.execSeatsGauge.SetDenominator(float64(dCfg.ConcurrencyDenominator))
    
    	qs.dispatchAsMuchAsPossibleLocked()
    }
    
    // A decision about a request
    type requestDecision int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 04 16:59:21 UTC 2024
    - 42.4K bytes
    - Viewed (0)
Back to top