kubernetes/staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go

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

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

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

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

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

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

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

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

var expectedContentLengthHeaders …

const contentLengthHeaders …

const contentLengthBody …

var contentLengthHeadersAndBody …

var expectedResponseHeaders …

const responseHeaders …

const responseBody …

var responseHeadersAndBody …

const invalidResponseData …

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

type mockConnInitializer …

func (m *mockConnInitializer) InitializeWrite(backendResponse *http.Response, backendResponseBytes []byte) error { … }

var _ …

type mockConn …

func (mc *mockConn) Write(p []byte) (int, error) { … }

func (mc *mockConn) Read(p []byte) (int, error) { … }

func (mc *mockConn) Close() error               { … }

func (mc *mockConn) LocalAddr() net.Addr        { … }

func (mc *mockConn) RemoteAddr() net.Addr       { … }

func (mc *mockConn) SetDeadline(t time.Time) error { … }

func (mc *mockConn) SetReadDeadline(t time.Time) error  { … }

func (mc *mockConn) SetWriteDeadline(t time.Time) error { … }

type mockResponseWriter …

func (mrw *mockResponseWriter) Header() http.Header { … }

func (mrw *mockResponseWriter) Write(p []byte) (int, error) { … }

func (mrw *mockResponseWriter) WriteHeader(statusCode int) { … }

var _ …

type fakeResponder …

func (fr *fakeResponder) Object(statusCode int, obj runtime.Object) { … }

func (fr *fakeResponder) Error(err error)                           { … }

// justQueueStream skips the usual stream validation before
// queueing the stream on the stream channel.
func justQueueStream(streams chan httpstream.Stream) func(httpstream.Stream, <-chan struct{ … }