kubernetes/staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go

type StreamTranslatorHandler …

// NewStreamTranslatorHandler creates a new proxy handler. Responder is required for returning
// errors to the caller.
func NewStreamTranslatorHandler(location *url.URL, transport http.RoundTripper, maxBytesPerSec int64, opts Options) *StreamTranslatorHandler { … }

func (h *StreamTranslatorHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) { … }

type translatorSizeQueue …

func (t *translatorSizeQueue) Next() *remotecommand.TerminalSize { … }

// codeExitToStatusError converts a passed CodeExitError to the type necessary
// to send through an error stream using "writeStatus".
func codeExitToStatusError(exitErr exec.CodeExitError) *apierrors.StatusError { … }