kubernetes/pkg/kubelet/server/server_websocket_test.go

const dataChannel …

const errorChannel …

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

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

func wsWrite(conn *websocket.Conn, channel byte, data []byte) error { … }

func wsRead(conn *websocket.Conn) (byte, []byte, error) { … }