Versions in this module Expand all Collapse all v1 v1.0.0 Aug 2, 2019 Changes in this version + func AllSendMessages(appId uint32, userId string, data string) + func ClearTimeoutConnections() + func GetAppIds() []uint32 + func GetManagerInfo(isDebug string) (managerInfo map[string]interface{}) + func GetUserKey(appId uint32, userId string) (key string) + func GetUserList() (userList []string) + func HeartbeatController(client *Client, seq string, message []byte) (code int, msg string, data interface{}) + func InAppIds(appId uint32) (inAppId bool) + func LoginController(client *Client, seq string, message []byte) (code int, msg string, data interface{}) + func ProcessData(client *Client, message []byte) + func Register(key string, value DisposeFunc) + func StartWebSocket() + type Client struct + Addr string + AppId uint32 + FirstTime uint64 + HeartbeatTime uint64 + LoginTime uint64 + Send chan []byte + Socket *websocket.Conn + UserId string + func GetUserClient(appId uint32, userId string) (client *Client) + func NewClient(addr string, socket *websocket.Conn, firstTime uint64) (client *Client) + func (c *Client) GetKey() (key string) + func (c *Client) Heartbeat(currentTime uint64) + func (c *Client) IsHeartbeatTimeout(currentTime uint64) (timeout bool) + func (c *Client) IsLogin() (isLogin bool) + func (c *Client) Login(appId uint32, userId string, loginTime uint64) + func (c *Client) SendMsg(msg []byte) + type ClientManager struct + Broadcast chan []byte + Clients map[*Client]bool + ClientsLock sync.RWMutex + Login chan *Login + Register chan *Client + Unregister chan *Client + UserLock sync.RWMutex + Users map[string]*Client + func NewClientManager() (clientManager *ClientManager) + func (manager *ClientManager) AddClients(client *Client) + func (manager *ClientManager) AddUsers(key string, client *Client) + func (manager *ClientManager) DelClients(client *Client) + func (manager *ClientManager) DelUsers(key string) + func (manager *ClientManager) EventLogin(Login *Login) + func (manager *ClientManager) EventRegister(client *Client) + func (manager *ClientManager) EventUnregister(client *Client) + func (manager *ClientManager) GetUserClient(appId uint32, userId string) (client *Client) + type DisposeFunc func(client *Client, seq string, message []byte) (code int, msg string, data interface{}) + type Login struct + AppId uint32 + Client *Client + UserId string + func (l *Login) GetKey() (key string) Incompatible versions in this module v2.0.1+incompatible Aug 10, 2019 v2.0.0+incompatible Aug 4, 2019
Go to main page