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

const dataChannel …

const errorChannel …

const v4BinaryWebsocketProtocol …

const v4Base64WebsocketProtocol …

type V4Options …

// NewV4Options creates a new options from the Request.
func NewV4Options(req *http.Request) (*V4Options, error) { … }

// BuildV4Options returns a V4Options based on the given information.
func BuildV4Options(ports []int32) (*V4Options, error) { … }

// handleWebSocketStreams handles requests to forward ports to a pod via
// a PortForwarder. A pair of streams are created per port (DATA n,
// ERROR n+1). The associated port is written to each stream as a unsigned 16
// bit integer in little endian format.
func handleWebSocketStreams(req *http.Request, w http.ResponseWriter, portForwarder PortForwarder, podName string, uid types.UID, opts *V4Options, supportedPortForwardProtocols []string, idleTimeout, streamCreationTimeout time.Duration) error { … }

type websocketStreamPair …

type websocketStreamHandler …

// run invokes the websocketStreamHandler's forwarder.PortForward
// function for the given stream pair.
func (h *websocketStreamHandler) run() { … }

func (h *websocketStreamHandler) portForward(p *websocketStreamPair) { … }