kubernetes/pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go

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

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

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

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

type plBuilder …

func newPLConfiguration(name string) *plBuilder { … }

func (b *plBuilder) Object() *flowcontrolv1.PriorityLevelConfiguration { … }

func (b *plBuilder) WithGeneration(value int64) *plBuilder { … }

func (b *plBuilder) WithAutoUpdateAnnotation(value string) *plBuilder { … }

func (b *plBuilder) WithLimited(nominalConcurrencyShares int32) *plBuilder { … }

// must be called after WithLimited
func (b *plBuilder) WithQueuing(queues, handSize, queueLengthLimit int32) *plBuilder { … }