- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewQueueSetFactory (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats_test.go
ServerConcurrencyLimit: testcase.nominalCL, ReqsGaugeVec: metrics.PriorityLevelConcurrencyGaugeVec, ExecSeatsGaugeVec: metrics.PriorityLevelExecutionSeatsGaugeVec, QueueSetFactory: fqs.NewQueueSetFactory(clk), }) testPriorityLevel := &flowcontrolv1.PriorityLevelConfiguration{ ObjectMeta: metav1.ObjectMeta{ Name: "test-pl", }, Spec: flowcontrolv1.PriorityLevelConfigurationSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 4.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go
ServerConcurrencyLimit: 24, ReqsGaugeVec: metrics.PriorityLevelConcurrencyGaugeVec, ExecSeatsGaugeVec: metrics.PriorityLevelExecutionSeatsGaugeVec, QueueSetFactory: fqs.NewQueueSetFactory(clk), }) stopCh := make(chan struct{}) defer close(stopCh) informerFactory.Start(stopCh) status := informerFactory.WaitForCacheSync(stopCh) if names := unsynced(status); len(names) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
ServerConcurrencyLimit: serverConcurrencyLimit, ReqsGaugeVec: metrics.PriorityLevelConcurrencyGaugeVec, ExecSeatsGaugeVec: metrics.PriorityLevelExecutionSeatsGaugeVec, QueueSetFactory: fqs.NewQueueSetFactory(clk), }) } // TestableConfig carries the parameters to an implementation that is testable type TestableConfig struct { // Name of the controller Name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go
ServerConcurrencyLimit: 24, ReqsGaugeVec: metrics.PriorityLevelConcurrencyGaugeVec, ExecSeatsGaugeVec: metrics.PriorityLevelExecutionSeatsGaugeVec, QueueSetFactory: fqs.NewQueueSetFactory(clk), }) ctx, cancel := context.WithTimeout(context.Background(), 50*time.Second) stopCh := ctx.Done() controllerCompletionCh := make(chan error) informerFactory.Start(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
totRequestsTimedout int // totRequestsCancelled is the total number of requests of this // queueSet that have been cancelled. totRequestsCancelled int } // NewQueueSetFactory creates a new QueueSetFactory object func NewQueueSetFactory(c eventclock.Interface) fq.QueueSetFactory { return newTestableQueueSetFactory(c, ordinaryPromiseFactoryFactory) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0)