websocket

Documentation

Index

• func Dial(protocol, host string, port int, path string) (*websocket.Conn, error)
• type WebSocket
  • func NewWebSocket(fd uint64, conn *websocket.Conn) *WebSocket
  • func (t *WebSocket) Close() error
  • func (t *WebSocket) Closed() bool
  • func (t *WebSocket) Expired() bool
  • func (t *WebSocket) FD() uint64
  • func (t *WebSocket) Get(key int64) (any, bool)
  • func (t *WebSocket) Read(hLen, bLen, bLenOffset int) ([]byte, error)
  • func (t *WebSocket) RemoteIp() string
  • func (t *WebSocket) SQueue() <-chan bool
  • func (t *WebSocket) Send(pack connection.IPacket) error
  • func (t *WebSocket) SendBytes(buf []byte) error
  • func (t *WebSocket) Set(key int64, val any)
  • 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 uint64, conn *websocket.Conn) *WebSocket

func (*WebSocket) Close

func (t *WebSocket) Close() error

func (*WebSocket) Closed

func (t *WebSocket) Closed() bool

func (*WebSocket) Expired

func (t *WebSocket) Expired() bool

func (*WebSocket) FD

func (t *WebSocket) FD() uint64

func (*WebSocket) Get

func (t *WebSocket) Get(key int64) (any, bool)

func (*WebSocket) Read

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

func (*WebSocket) RemoteIp

func (t *WebSocket) RemoteIp() string

func (*WebSocket) SQueue

func (t *WebSocket) SQueue() <-chan bool

func (*WebSocket) Send

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

func (*WebSocket) SendBytes

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

func (*WebSocket) Set

func (t *WebSocket) Set(key int64, val any)

func (*WebSocket) WQueue

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

func (*WebSocket) Write

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