ws

May 14, 2022

Changes in this version

+ const BinaryMessage

+ const CloseMessage

+ const DefaultHeartbeatInterval

+ const DefaultInChanSize

+ const DefaultOutChanSize

+ const PingMessage

+ const PongMessage

+ const TextMessage

type Connection

+ func (c *Connection) GetRemoteAddr() net.Addr

+ func (c *Connection) KeepHeartbeat()

+ type Options struct

+ HeartbeatInterval int

+ InChanSize int

+ OutChanSize int

May 8, 2022

Changes in this version

+ type Heartbeat interface

+ GetAliveTime func() int

+ GetPongMsg func() []byte

+ IsPingMsg func(msg []byte) bool

May 7, 2022

Changes in this version

+ const Ping

+ const Pong

+ var ErrConnClose = errors.New("connection already closed")

+ type Callback interface

+ ConnClose func(id string)

+ type Connection struct

+ func NewConnection(callback Callback, heartBeater HeartBeater) *Connection

+ func (wc *Connection) Close() error

+ func (wc *Connection) GetConnID() string

+ func (wc *Connection) Open(w http.ResponseWriter, r *http.Request) error

+ func (wc *Connection) Receive() (msg *Message, err error)

+ func (wc *Connection) Write(msg *Message) (err error)

type HeartBeater

+ GetAliveTime func() int

+ type Message struct

+ Data []byte

+ MessageType int

May 6, 2022

Changes in this version

+ type HeartBeater interface

+ GetHeartbeatTime func() int

+ GetPongMsg func() []byte

+ IsPingMsg func(msg []byte) bool

type WsConnection

+ func (conn *WsConnection) GetWsConnId() string

Feb 25, 2021

Changes in this version

+ var ErrIdEmpty = errors.New("id is null")

+ var ErrWsConnClose = errors.New("websocket connection closed")

+ type Collection interface

+ Del func(id string) error

+ Get func(id string) (wsConn *websocket.Conn, err error)

+ GetAll func() (wsConnList []*websocket.Conn, err error)

+ GetGroup func(groupName string) (wsConnList []*websocket.Conn, err error)

+ Set func(id string, wsConn *websocket.Conn) error

+ type Conn interface

+ Close func() error

+ Open func(w http.ResponseWriter, r *http.Request) error

+ Receive func() (msg *WsMessage, err error)

+ Write func(msg *WsMessage) (err error)

+ type MsgTo struct

+ To string

+ ToType ToType

+ type ToType string

+ const ToAll

+ const ToConn

+ const ToGroup

+ type WsConnection struct

+ func NewWsConnection(id string, collect Collection) *WsConnection

+ func (conn *WsConnection) Close() error

+ func (conn *WsConnection) Open(w http.ResponseWriter, r *http.Request) error

+ func (conn *WsConnection) Receive() (msg *WsMessage, err error)

+ func (conn *WsConnection) Write(msg *WsMessage) (err error)

+ type WsMessage struct

+ Data []byte

+ MessageType int

+ To MsgTo