Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewWatchTracker (0.18 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    	fakeFilter := fakeApfFilter{
    		mockDecision:    decision,
    		postEnqueue:     postEnqueue,
    		postDequeue:     postDequeue,
    		WatchTracker:    utilflowcontrol.NewWatchTracker(),
    		MaxSeatsTracker: utilflowcontrol.NewMaxSeatsTracker(),
    	}
    	return newApfServerWithFilter(t, fakeFilter, time.Minute/4, onExecute, postExecute)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    		serverConcurrencyLimit: config.ServerConcurrencyLimit,
    		flowcontrolClient:      config.FlowcontrolClient,
    		priorityLevelStates:    make(map[string]*priorityLevelState),
    		WatchTracker:           NewWatchTracker(),
    		MaxSeatsTracker:        NewMaxSeatsTracker(),
    	}
    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