kubernetes/staging/src/k8s.io/client-go/transport/websocket/roundtripper_test.go

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

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

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

type websocketStreams …

func webSocketServerStreams(req *http.Request, w http.ResponseWriter) (*websocketStreams, error) { … }