kubernetes/test/integration/apimachinery/watch_restart_test.go

func noopNormalization(output []string) []string { … }

func normalizeInformerOutputFunc(initialVal string) func(output []string) []string { … }

func noop() { … }

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