kubernetes/staging/src/k8s.io/apiserver/pkg/registry/generic/registry/decorated_watcher_test.go

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

func expectPodEvent(t *testing.T, dw *decoratedWatcher, watchType watch.EventType) { … }

func expectErrorEvent(t *testing.T, dw *decoratedWatcher) { … }