kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go

var testDebugLogs …

func TestMain(m *testing.M) { … }

var mandPLs …

// in general usage, the boolean returned may be inaccurate by the time the caller examines it.
func (cfgCtlr *configController) hasPriorityLevelState(plName string) bool { … }

type ctlrTestState …

type heldRequest …

var _ …

type ctlrTestQueueSetCompleter …

type ctlrTestQueueSet …

type ctlrTestRequest …

func (cts *ctlrTestState) BeginConstruction(qc fq.QueuingConfig, rip metrics.RatioedGaugePair, eso metrics.RatioedGauge, sdi metrics.Gauge) (fq.QueueSetCompleter, error) { … }

func (cqs *ctlrTestQueueSet) BeginConfigChange(qc fq.QueuingConfig) (fq.QueueSetCompleter, error) { … }

func (cqs *ctlrTestQueueSet) Dump(bool) debug.QueueSetDump { … }

func (cqc ctlrTestQueueSetCompleter) Complete(dc fq.DispatchingConfig) fq.QueueSet { … }

func (cqs *ctlrTestQueueSet) IsIdle() bool { … }

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

func (ctr *ctlrTestRequest) Finish(execute func()) bool { … }

func (cts *ctlrTestState) getQueueSetNames() sets.String { … }

func (cts *ctlrTestState) getNonIdleQueueSetNames() sets.String { … }

func (cts *ctlrTestState) hasNonIdleQueueSet(name string) bool { … }

func (cts *ctlrTestState) addHeldRequest(plName string, rd RequestDigest, finishCh chan struct{ … }

func (cts *ctlrTestState) popHeldRequest() (plName string, hr *heldRequest, nCount int) { … }

var mandQueueSetNames …

func TestConfigConsumer(t *testing.T) { … }

func TestAPFControllerWithGracefulShutdown(t *testing.T) { … }

func unsynced(status map[reflect.Type]bool) []string { … }

func checkNewFS(cts *ctlrTestState, rng *rand.Rand, trialName string, ftr *fsTestingRecord, catchAlls map[bool]*flowcontrol.FlowSchema) { … }

func genPLs(rng *rand.Rand, trial string, oldPLNames sets.String, n int) (pls []*flowcontrol.PriorityLevelConfiguration, plMap map[string]*flowcontrol.PriorityLevelConfiguration, goodNames, badNames sets.String) { … }

func genFSs(t *testing.T, rng *rand.Rand, trial string, goodPLNames, badPLNames sets.String, n int) (newFSs []*flowcontrol.FlowSchema, newFSMap map[string]*flowcontrol.FlowSchema, newFTRs map[string]*fsTestingRecord, catchAlls map[bool]*flowcontrol.FlowSchema) { … }

func fsPrecedes(a, b *flowcontrol.FlowSchema) bool { … }