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

type Server …

type Runtime …

type Config …

var DefaultConfig …

// NewServer creates a new Server for stream requests.
// TODO(tallclair): Add auth(n/z) interface & handling.
func NewServer(config Config, runtime Runtime) (Server, error) { … }

type server …

func validateExecRequest(req *runtimeapi.ExecRequest) error { … }

func (s *server) GetExec(req *runtimeapi.ExecRequest) (*runtimeapi.ExecResponse, error) { … }

func validateAttachRequest(req *runtimeapi.AttachRequest) error { … }

func (s *server) GetAttach(req *runtimeapi.AttachRequest) (*runtimeapi.AttachResponse, error) { … }

func (s *server) GetPortForward(req *runtimeapi.PortForwardRequest) (*runtimeapi.PortForwardResponse, error) { … }

func (s *server) Start(stayUp bool) error { … }

func (s *server) Stop() error { … }

func (s *server) ServeHTTP(w http.ResponseWriter, r *http.Request) { … }

func (s *server) buildURL(method, token string) string { … }

func (s *server) serveExec(req *restful.Request, resp *restful.Response) { … }

func (s *server) serveAttach(req *restful.Request, resp *restful.Response) { … }

func (s *server) servePortForward(req *restful.Request, resp *restful.Response) { … }

type criAdapter …

var _ …

var _ …

var _ …

func (a *criAdapter) ExecInContainer(ctx context.Context, podName string, podUID types.UID, container string, cmd []string, in io.Reader, out, err io.WriteCloser, tty bool, resize <-chan remotecommand.TerminalSize, timeout time.Duration) error { … }

func (a *criAdapter) AttachContainer(ctx context.Context, podName string, podUID types.UID, container string, in io.Reader, out, err io.WriteCloser, tty bool, resize <-chan remotecommand.TerminalSize) error { … }

func (a *criAdapter) PortForward(ctx context.Context, podName string, podUID types.UID, port int32, stream io.ReadWriteCloser) error { … }