Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for FlowSchemaName (0.13 sec)

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

    }
    
    type listWorkEstimator struct {
    	config        *WorkEstimatorConfig
    	countGetterFn objectCountGetterFunc
    	maxSeatsFn    maxSeatsFunc
    }
    
    func (e *listWorkEstimator) estimate(r *http.Request, flowSchemaName, priorityLevelName string) WorkEstimate {
    	minSeats := e.config.MinimumSeats
    	maxSeats := e.maxSeatsFn(priorityLevelName)
    	if maxSeats == 0 || maxSeats > e.config.MaximumSeatsLimit {
    		maxSeats = e.config.MaximumSeatsLimit
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    // shouldDelayUpdate checks to see if a flowschema has been updated too often and returns true if a delay is needed.
    // Only invoke this in the one and only worker goroutine
    func (cfgCtlr *configController) shouldDelayUpdate(flowSchemaName string) bool {
    	numUpdatesInPastMinute := 0
    	oneMinuteAgo := cfgCtlr.clock.Now().Add(-1 * time.Minute)
    	for idx, update := range cfgCtlr.mostRecentUpdates {
    		if oneMinuteAgo.After(update.timeUpdated) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (1)
Back to top