kubernetes/test/integration/controlplane/graceful_shutdown_test.go

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

type responseErrorPair …

func backgroundRoundtrip(transport http.RoundTripper, req *http.Request) <-chan responseErrorPair { … }

func newBlockingRequest(method, url string) (*http.Request, io.WriteCloser, error) { … }