ws

Documentation

Index

• type Connection
  • func Constructor(resp http.ResponseWriter, req *http.Request) (wsConn *Connection, err error)
  • func (wsConn *Connection) WsClose()
  • func (wsConn *Connection) WsRead() (msg *Message, err error)
  • func (wsConn *Connection) WsWrite(messageType int, data []byte) (err error)
• type Message
• type StreamHandler
  • 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)

Types

type Connection

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

Connection ...

func Constructor

func Constructor(resp http.ResponseWriter, req *http.Request) (wsConn *Connection, err error)

Constructor ...

func (*Connection) WsClose

func (wsConn *Connection) WsClose()

WsClose ...

func (*Connection) WsRead

func (wsConn *Connection) WsRead() (msg *Message, err error)

WsRead ...

func (*Connection) WsWrite

func (wsConn *Connection) WsWrite(messageType int, data []byte) (err error)

WsWrite ...

type Message

type Message struct {
	MessageType int
	Data        []byte
}

Message ...

type StreamHandler

type StreamHandler struct {
	WsConn      *Connection
	ResizeEvent chan remotecommand.TerminalSize
}

StreamHandler ...

func (*StreamHandler) Next

func (handler *StreamHandler) Next() (size *remotecommand.TerminalSize)

Next ...

func (*StreamHandler) Read

func (handler *StreamHandler) Read(p []byte) (size int, err error)

func (*StreamHandler) Write

func (handler *StreamHandler) Write(p []byte) (size int, err error)