Versions in this module Expand all Collapse all v0 v0.0.2 Feb 6, 2024 Changes in this version + var MemberOfflineErr = errors.New("member offline") + type Broker struct + func (b *Broker) Broadcast(req *pb.BroadcastReq) (err error) + func (b *Broker) BroadcastRoom(req *pb.BroadcastRoomReq) (err error) + func (b *Broker) Push(msg *protocol.TransMessage) + type ConsumerGroupHandler struct + func (h *ConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error + func (h *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (h *ConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error + type MessageSender struct + func NewMessageSender(c *conf.Config, etcdClient *clientv3.Client) *MessageSender + func (s *MessageSender) Init() + type Server struct + func New(c *conf.Config, sender *MessageSender, repo data.DispatcherRepo) *Server + func (s *Server) HandlePush(ctx context.Context, receiverId uint64, dm *protocol.DispatcherMessage) (err error) + func (s *Server) Run()
Go to main page