Documentation ¶
Index ¶
- func GetPs1(p []byte) string
- func ParseCmdInput(p []byte) string
- func ParseCmdOutput(p []byte) string
- type CmdStruct
- type ReplyRecorder
- type StreamHandler
- func (handler *StreamHandler) Close() error
- func (handler *StreamHandler) CommandRecordChan()
- func (handler *StreamHandler) Next() (size *remotecommand.TerminalSize)
- func (handler *StreamHandler) Read(p []byte) (size int, err error)
- func (handler *StreamHandler) Write(p []byte) (size int, err error)
- type WebTerminal
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseCmdInput ¶
func ParseCmdOutput ¶
Types ¶
type ReplyRecorder ¶
type ReplyRecorder struct { AbsGzFilePath string // contains filtered or unexported fields }
func NewReplyRecord ¶
func NewReplyRecord(sid, shell string) (recorder ReplyRecorder)
func (*ReplyRecorder) End ¶
func (r *ReplyRecorder) End()
func (*ReplyRecorder) Record ¶
func (r *ReplyRecorder) Record(b []byte)
type StreamHandler ¶
type StreamHandler struct { SessionID string WsConn *utils.WsConnection ResizeEvent chan remotecommand.TerminalSize Shell string // contains filtered or unexported fields }
StreamHandler ssh流式处理器
func (*StreamHandler) Close ¶
func (handler *StreamHandler) Close() error
func (*StreamHandler) CommandRecordChan ¶
func (handler *StreamHandler) CommandRecordChan()
func (*StreamHandler) Next ¶
func (handler *StreamHandler) Next() (size *remotecommand.TerminalSize)
Next executor回调获取web是否resize
type WebTerminal ¶
type WebTerminal struct { K8sClient *kubernetes.Clientset PodName string Namespace string Container string Shell string }
func (*WebTerminal) NewSshSPDYExecutor ¶
func (wt *WebTerminal) NewSshSPDYExecutor() *rest.Request
Click to show internal directories.
Click to hide internal directories.