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 {}