terminal

Documentation

Index

• func ValidatePod(ctx context.Context, client kubernetes.Interface, ...) error
• type ExecOptions
• type ExecutorType
• type TerminalMessage
• type TerminalSession
  • func NewTerminalSession(c kubernetes.Interface, w http.ResponseWriter, r *http.Request, ...) (*TerminalSession, error)
  • func (t *TerminalSession) Close() error
  • func (t *TerminalSession) Done()
  • func (t *TerminalSession) Exec(config *rest.Config, namespace, podName, containerName string, cmd []string, ...) error
  • func (t *TerminalSession) Next() *remotecommand.TerminalSize
  • func (t *TerminalSession) Read(p []byte) (n int, err error)
  • func (t *TerminalSession) Write(p []byte) (n int, err error)

Functions

func ValidatePod

func ValidatePod(ctx context.Context, client kubernetes.Interface, namespace, podName, containerName string) error

Types

type ExecOptions

type ExecOptions struct {
	Stdin    bool
	Stdout   bool
	Stderr   bool
	TTY      bool
	Executor ExecutorType
}

type ExecutorType

type ExecutorType string

const (
	// EndOfTransmission end
	EndOfTransmission = "\u0004"

	WebsocketExecutorType ExecutorType = "websocket"
	SPDYExecutorType      ExecutorType = "spdy"
)

type TerminalMessage

type TerminalMessage struct {
	Op   string `json:"op"`
	Data string `json:"data"`
	Rows uint16 `json:"rows"`
	Cols uint16 `json:"cols"`
}

TerminalMessage is the messaging protocol between ShellController and TerminalSession.

OP DIRECTION FIELD(S) USED DESCRIPTION --------------------------------------------------------------------- bind fe->be SessionID Id sent back from TerminalResponse stdin fe->be Data Keystrokes/paste buffer resize fe->be Rows, Cols New terminal size stdout be->fe Data Output from the process

type TerminalSession

type TerminalSession struct {
	// contains filtered or unexported fields
}

func NewTerminalSession

func NewTerminalSession(c kubernetes.Interface, w http.ResponseWriter, r *http.Request, responseHeader http.Header) (*TerminalSession, error)

func (*TerminalSession) Close

func (t *TerminalSession) Close() error

func (*TerminalSession) Done

func (t *TerminalSession) Done()

func (*TerminalSession) Exec

func (t *TerminalSession) Exec(config *rest.Config, namespace, podName, containerName string, cmd []string, opts *ExecOptions) error

func (*TerminalSession) Next

func (t *TerminalSession) Next() *remotecommand.TerminalSize

func (*TerminalSession) Read

func (t *TerminalSession) Read(p []byte) (n int, err error)

func (*TerminalSession) Write

func (t *TerminalSession) Write(p []byte) (n int, err error)