Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewNoRestraintFactory (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top