kubernetes/staging/src/k8s.io/client-go/tools/remotecommand/v2.go

type streamProtocolV2 …

var _ …

func newStreamProtocolV2(options StreamOptions) streamProtocolHandler { … }

func (p *streamProtocolV2) createStreams(conn streamCreator) error { … }

func (p *streamProtocolV2) copyStdin() { … }

func (p *streamProtocolV2) copyStdout(wg *sync.WaitGroup) { … }

func (p *streamProtocolV2) copyStderr(wg *sync.WaitGroup) { … }

func (p *streamProtocolV2) stream(conn streamCreator) error { … }

type errorDecoderV2 …

func (d *errorDecoderV2) decode(message []byte) error { … }