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

func init() { … }

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

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

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

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

type fsBuilder …

func newFlowSchema(name, plName string, matchingPrecedence int32) *fsBuilder { … }

func (b *fsBuilder) Object() *flowcontrolv1.FlowSchema { … }

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

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

func setAnnotation(accessor metav1.Object, value string) { … }