kubernetes/test/integration/apimachinery/watch_namespace_test.go

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

func generateAndWatchNamespaceEvent(ctx context.Context, t *testing.T, clientSet *kubernetes.Clientset, ns *corev1.Namespace, watcher watch.Interface) { … }

func waitForEvent(w watch.Interface, expectType watch.EventType, expectObject runtime.Object, duration time.Duration) (watch.Event, bool) { … }