Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newTestableQueueSetFactory (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go

    			}.exercise(t)
    		})
    	}
    }
    
    func TestBaseline(t *testing.T) {
    	metrics.Register()
    	now := time.Now()
    
    	clk, counter := testeventclock.NewFake(now, 0, nil)
    	qsf := newTestableQueueSetFactory(clk, countingPromiseFactoryFactory(counter))
    	qCfg := fq.QueuingConfig{
    		Name:             "TestBaseline",
    		DesiredNumQueues: 9,
    		QueueLengthLimit: 8,
    		HandSize:         3,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 26 12:55:23 UTC 2023
    - 58.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go

    func NewQueueSetFactory(c eventclock.Interface) fq.QueueSetFactory {
    	return newTestableQueueSetFactory(c, ordinaryPromiseFactoryFactory)
    }
    
    // newTestableQueueSetFactory creates a new QueueSetFactory object with the given promiseFactoryFactory
    func newTestableQueueSetFactory(c eventclock.Interface, promiseFactoryFactory promiseFactoryFactory) fq.QueueSetFactory {
    	return &queueSetFactory{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 04 16:59:21 UTC 2024
    - 42.4K bytes
    - Viewed (0)
Back to top