kubernetes/test/integration/apiserver/flowcontrol/fight_test.go

type fightTest …

func newFightTest(t *testing.T, loopbackConfig *rest.Config, teamSize int) *fightTest { … }

func (ft *fightTest) createMainInformer() { … }

func (ft *fightTest) countWrite(fs *flowcontrol.FlowSchema) { … }

func (ft *fightTest) createController(invert bool, i int) { … }

func (ft *fightTest) evaluate(tBeforeCreate, tAfterCreate time.Time) { … }

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

func (ft *fightTest) foreach(visit func(invert bool, i int)) { … }