core

Documentation

Index

• func HandleError(c *gin.Context, err error) bool
• func JsonError(c *gin.Context, msg interface{})
• func NewSshClient(server Server) (*ssh.Client, error)
• func WshandleError(ws *websocket.Conn, err error) bool
• type Server
• type SshConn
  • func NewSshConn(cols, rows int, sshClient *ssh.Client) (*SshConn, error)
  • func (s *SshConn) Close()
  • func (s *SshConn) ReceiveWsMsg(wsConn *websocket.Conn, exitCh chan bool)
  • func (s *SshConn) SendComboOutput(wsConn *websocket.Conn, exitCh chan bool)
  • func (s *SshConn) SessionWait(quitChan chan bool)

Functions

func HandleError

func HandleError(c *gin.Context, err error) bool

func JsonError

func JsonError(c *gin.Context, msg interface{})

func NewSshClient

func NewSshClient(server Server) (*ssh.Client, error)

func WshandleError

func WshandleError(ws *websocket.Conn, err error) bool

Types

type Server

type Server struct {
	Ip     string
	Port   int
	User   string
	Passwd string
}

type SshConn

type SshConn struct {
	// calling Write() to write data into ssh server
	StdinPipe io.WriteCloser
	// Write() be called to receive data from ssh server
	ComboOutput *wsBufferWriter
	Session     *ssh.Session
	SftpClient  *sftp.Client
}

SshConn connect to ssh server using ssh session.

func NewSshConn

func NewSshConn(cols, rows int, sshClient *ssh.Client) (*SshConn, error)

NewSshConn setup ssh shell session. set Session and StdinPipe here, and the Session.Stdout and Session.Sdterr are also set.

func (*SshConn) Close

func (s *SshConn) Close()

func (*SshConn) ReceiveWsMsg

func (s *SshConn) ReceiveWsMsg(wsConn *websocket.Conn, exitCh chan bool)

ReceiveWsMsg receive websocket msg do some handling then write into ssh.session.stdin

func (*SshConn) SendComboOutput

func (s *SshConn) SendComboOutput(wsConn *websocket.Conn, exitCh chan bool)

func (*SshConn) SessionWait

func (s *SshConn) SessionWait(quitChan chan bool)