streaming

Jun 10, 2022

Changes in this version

+ var DefaultConfig = Config

+ func NewErrorStreamingDisabled(method string) error

+ func NewErrorTooManyInFlight() error

+ func WriteError(err error, w http.ResponseWriter) error

+ type Config struct

+ Addr string

+ BaseURL *url.URL

+ StreamCreationTimeout time.Duration

+ StreamIdleTimeout time.Duration

+ SupportedPortForwardProtocols []string

+ SupportedRemoteCommandProtocols []string

+ TLSConfig *tls.Config

+ type Runtime interface

+ Attach func(containerID string, in io.Reader, out, err io.WriteCloser, tty bool, ...) error

+ Exec func(containerID string, cmd []string, in io.Reader, out, err io.WriteCloser, ...) error

+ PortForward func(podSandboxID string, port int32, stream io.ReadWriteCloser) error

+ type Server interface

+ GetAttach func(req *runtimeapi.AttachRequest) (*runtimeapi.AttachResponse, error)

+ GetExec func(*runtimeapi.ExecRequest) (*runtimeapi.ExecResponse, error)

+ GetPortForward func(*runtimeapi.PortForwardRequest) (*runtimeapi.PortForwardResponse, error)

+ Start func(stayUp bool) error

+ Stop func() error

+ func NewServer(config Config, runtime Runtime) (Server, error)