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

type recorder …

func (r *recorder) Record() { … }

func (r *recorder) Count() int { … }

func newHandler(responseCh <-chan string, panicCh <-chan interface{ … }

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

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

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

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

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

type panicOnNonReuseTransport …

func (t *panicOnNonReuseTransport) RoundTrip(req *http.Request) (*http.Response, error) { … }

func (t *panicOnNonReuseTransport) GotConn(info httptrace.GotConnInfo) { … }

// TestErrConnKilledHTTP2 check if HTTP/2 connection is not closed when an HTTP handler panics
// The net/http library recovers the panic and sends an HTTP/2 RST_STREAM.
func TestErrConnKilledHTTP2(t *testing.T) { … }

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

func isStackTraceLoggedByRuntime(message string) bool { … }

var tsCrt …

var tsKey …