kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/no-restraint.go

// 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 { … }

type noRestraintFactory …

type noRestraintCompleter …

type noRestraint …

type noRestraintRequest …

func (noRestraintFactory) BeginConstruction(fq.QueuingConfig, metrics.RatioedGaugePair, metrics.RatioedGauge, metrics.Gauge) (fq.QueueSetCompleter, error) { … }

func (noRestraintCompleter) Complete(dCfg fq.DispatchingConfig) fq.QueueSet { … }

func (noRestraint) BeginConfigChange(qCfg fq.QueuingConfig) (fq.QueueSetCompleter, error) { … }

func (noRestraint) IsIdle() bool { … }

func (noRestraint) StartRequest(ctx context.Context, workEstimate *fcrequest.WorkEstimate, hashValue uint64, flowDistinguisher, fsName string, descr1, descr2 interface{ … }

func (noRestraint) Dump(bool) debug.QueueSetDump { … }

func (noRestraintRequest) Finish(execute func()) (idle bool) { … }