Documentation ¶
Index ¶
- func TestSendAll()
- func TestSendGroup()
- type BroadCastMessageData
- type Client
- type GroupMessageData
- type ICodec
- type IHandler
- type Manager
- func (manager *Manager) Info() map[string]interface{}
- func (manager *Manager) LenClient() uint
- func (manager *Manager) LenGroup() uint
- func (manager *Manager) RegisterClient(client *Client)
- func (manager *Manager) Send(id string, group string, message []byte)
- func (manager *Manager) SendAll(message []byte)
- func (manager *Manager) SendAllService()
- func (manager *Manager) SendGroup(group string, message []byte)
- func (manager *Manager) SendGroupService()
- func (manager *Manager) SendService()
- func (manager *Manager) Start()
- func (manager *Manager) UnRegisterClient(client *Client)
- func (manager *Manager) WsClient(ctx *gin.Context)
- type MessageData
- type WSClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
Id, Group string
Socket *websocket.Conn
Message chan []byte
Codec ICodec
Router IHandler
}
Client 单个 websocket 信息
type GroupMessageData ¶
groupMessageData 组广播数据信息
type Manager ¶
type Manager struct { Group map[string]map[string]*Client Lock sync.Mutex Register, UnRegister chan *Client Message chan *MessageData GroupMessage chan *GroupMessageData BroadCastMessage chan *BroadCastMessageData // contains filtered or unexported fields }
Manager 所有 websocket 信息
var WebsocketManager *Manager
Click to show internal directories.
Click to hide internal directories.