websocket

Documentation

Index

• func Dial(protocol, host string, port int, path string) (*websocket.Conn, error)
• type WebSocket
  • func NewWebSocket(fd int, conn *websocket.Conn) *WebSocket
  • func (t *WebSocket) Close() error
  • func (t *WebSocket) Closed() bool
  • func (t *WebSocket) FD() int
  • func (t *WebSocket) RQueue() chan connection.IPacket
  • func (t *WebSocket) Read(hLen, bLen, bLenOffset int) ([]byte, error)
  • func (t *WebSocket) RemoteIp() string
  • func (t *WebSocket) Send(pack connection.IPacket) error
  • func (t *WebSocket) SendBytes(buf []byte) error
  • func (t *WebSocket) WQueue() chan []byte
  • func (t *WebSocket) Write(pack []byte) (int, error)

Functions

func Dial

func Dial(protocol, host string, port int, path string) (*websocket.Conn, error)

Types

type WebSocket

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

func NewWebSocket

func NewWebSocket(fd int, conn *websocket.Conn) *WebSocket

func (*WebSocket) Close

func (t *WebSocket) Close() error

func (*WebSocket) Closed

func (t *WebSocket) Closed() bool

func (*WebSocket) FD

func (t *WebSocket) FD() int

func (*WebSocket) RQueue

func (t *WebSocket) RQueue() chan connection.IPacket

func (*WebSocket) Read

func (t *WebSocket) Read(hLen, bLen, bLenOffset int) ([]byte, error)

func (*WebSocket) RemoteIp

func (t *WebSocket) RemoteIp() string

func (*WebSocket) Send

func (t *WebSocket) Send(pack connection.IPacket) error

func (*WebSocket) SendBytes

func (t *WebSocket) SendBytes(buf []byte) error

func (*WebSocket) WQueue

func (t *WebSocket) WQueue() chan []byte

func (*WebSocket) Write

func (t *WebSocket) Write(pack []byte) (int, error)