kubernetes/staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware_test.go

const fakeStatusCode …

type fakeResponder …

func (r *fakeResponder) Error(w http.ResponseWriter, req *http.Request, err error) { … }

type fakeConn …

func (f *fakeConn) Read([]byte) (int, error)        { … }

func (f *fakeConn) Write([]byte) (int, error)       { … }

func (f *fakeConn) Close() error                    { … }

func (fakeConn) LocalAddr() net.Addr                { … }

func (fakeConn) RemoteAddr() net.Addr               { … }

func (fakeConn) SetDeadline(t time.Time) error      { … }

func (fakeConn) SetReadDeadline(t time.Time) error  { … }

func (fakeConn) SetWriteDeadline(t time.Time) error { … }

type SimpleBackendHandler …

func (s *SimpleBackendHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) { … }

func validateParameters(t *testing.T, name string, actual url.Values, expected map[string]string) { … }

func validateHeaders(t *testing.T, name string, actual http.Header, expected map[string]string, notExpected []string) { … }

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

type RoundTripperFunc …

func (fn RoundTripperFunc) RoundTrip(req *http.Request) (*http.Response, error) { … }

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

type noErrorsAllowed …

func (r *noErrorsAllowed) Error(w http.ResponseWriter, req *http.Request, err error) { … }

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

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

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

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

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

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

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

type fakeRT …

func (frt *fakeRT) RoundTrip(*http.Request) (*http.Response, error) { … }

// TestErrorPropagation checks if the default transport doesn't swallow the errors by providing a fakeResponder that intercepts and stores the error.
func TestErrorPropagation(t *testing.T) { … }

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

var exampleCert …

var exampleKey …