server

Documentation

Index

• Variables
• type Broker
  • 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
  • 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
  • func NewMessageSender(c *conf.Config, etcdClient *clientv3.Client) *MessageSender
  • func (s *MessageSender) Init()
• type Server
  • 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()

Variables

var (
	MemberOfflineErr = errors.New("member offline")
)

Types

type Broker

type Broker struct {
	// contains filtered or unexported fields
}

func (*Broker) Broadcast

func (b *Broker) Broadcast(req *pb.BroadcastReq) (err error)

func (*Broker) BroadcastRoom

func (b *Broker) BroadcastRoom(req *pb.BroadcastRoomReq) (err error)

func (*Broker) Push

func (b *Broker) Push(msg *protocol.TransMessage)

type ConsumerGroupHandler

type ConsumerGroupHandler struct {
	// contains filtered or unexported fields
}

func (*ConsumerGroupHandler) Cleanup

func (h *ConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

func (*ConsumerGroupHandler) ConsumeClaim

func (h *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*ConsumerGroupHandler) Setup

func (h *ConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error

type MessageSender

type MessageSender struct {
	// contains filtered or unexported fields
}

func NewMessageSender

func NewMessageSender(c *conf.Config, etcdClient *clientv3.Client) *MessageSender

func (*MessageSender) Init

func (s *MessageSender) Init()

type Server

type Server struct {
	// contains filtered or unexported fields
}

func New

func New(c *conf.Config, sender *MessageSender, repo data.DispatcherRepo) *Server

func (*Server) HandlePush

func (s *Server) HandlePush(ctx context.Context, receiverId uint64, dm *protocol.DispatcherMessage) (err error)

func (*Server) Run

func (s *Server) Run()