- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewNoRestraintFactory (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/no-restraint.go
"k8s.io/apiserver/pkg/util/flowcontrol/metrics" fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request" ) // NewNoRestraintFactory makes a QueueSetFactory that produces // QueueSets that exert no restraint --- every request is dispatched // for execution as soon as it arrives. func NewNoRestraintFactory() fq.QueueSetFactory { return noRestraintFactory{} } type noRestraintFactory struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 17:37:20 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/gen_test.go
fqtesting "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing" fcfmt "k8s.io/apiserver/pkg/util/flowcontrol/format" "k8s.io/apiserver/pkg/util/flowcontrol/metrics" ) var noRestraintQSF = fqtesting.NewNoRestraintFactory() // genPL creates a valid PriorityLevelConfiguration with the given // name and randomly generated spec. The given name must not be one // of the mandatory ones.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 24.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
} for _, testCase := range testCases { t.Run(testCase.name, func(t *testing.T) { now := time.Now() clk, counter := testeventclock.NewFake(now, 0, nil) nrc, err := test.NewNoRestraintFactory().BeginConstruction(fq.QueuingConfig{}, newGaugePair(clk), newExecSeatsGauge(clk), fq.NewNamedIntegrator(clk, "TestNoRestraint")) if err != nil { t.Fatal(err) } nr := nrc.Complete(fq.DispatchingConfig{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0)