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