type Server …
type Runtime …
type Config …
var DefaultConfig …
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 { … }