kubernetes/staging/src/k8s.io/kubelet/pkg/cri/streaming/remotecommand/websocket.go

const stdinChannel …

const stdoutChannel …

const stderrChannel …

const errorChannel …

const resizeChannel …

const preV4BinaryWebsocketProtocol …

const preV4Base64WebsocketProtocol …

const v4BinaryWebsocketProtocol …

const v4Base64WebsocketProtocol …

// createChannels returns the standard channel types for a shell connection (STDIN 0, STDOUT 1, STDERR 2)
// along with the approximate duplex value. It also creates the error (3) and resize (4) channels.
func createChannels(opts *Options) []wsstream.ChannelType { … }

// readChannel returns wsstream.ReadChannel if real is true, or wsstream.IgnoreChannel.
func readChannel(real bool) wsstream.ChannelType { … }

// writeChannel returns wsstream.WriteChannel if real is true, or wsstream.IgnoreChannel.
func writeChannel(real bool) wsstream.ChannelType { … }

// createWebSocketStreams returns a connectionContext containing the websocket connection and
// streams needed to perform an exec or an attach.
func createWebSocketStreams(req *http.Request, w http.ResponseWriter, opts *Options, idleTimeout time.Duration) (*connectionContext, bool) { … }