kubernetes/staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination_test.go

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

type fakeServerShutdownSignal …

func (fakeServerShutdownSignal) ShuttingDown() <-chan struct{ … }

type fakeRequestWaitGroup …

func (f *fakeRequestWaitGroup) Add(delta int) error { … }

func (f *fakeRequestWaitGroup) Done() { … }

func retryAfterSent(resp *http.Response) bool { … }