Versions in this module Expand all Collapse all v3 v3.0.1 Dec 12, 2020 v3.0.0 Dec 7, 2020 Changes in this version + type Channel struct + func NewChannel(name string) *Channel + func (c *Channel) Add(s *rpc.Session) error + func (c *Channel) GetMembers() []int64 + func (c *Channel) GetSessions() map[int64]*rpc.Session + func (c *Channel) Leave(uid int64) + func (c *Channel) PushMessage(route string, msg interface{}, excludeUid []int64) + type ChannelService struct + func GetChannelService() *ChannelService + func (c *ChannelService) AsyncPushMessageBySid(nodeId string, route string, msg interface{}, sids []int64) + func (c *ChannelService) Broadcast(nodeId string, route string, msg interface{}) + func (c *ChannelService) CreateChannel(name string) *Channel + func (c *ChannelService) DestroyChannel(name string) + func (c *ChannelService) GetChannel(name string) *Channel + func (c *ChannelService) PushMessageBySid(nodeId string, route string, msg interface{}, sids []int64)
Go to main page