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
Source Files
Click to show internal directories.
Click to hide internal directories.