server

Documentation

Index

• type Cmd2Value
• type MsgPushServiceServer
  • func NewMsgPushServiceServer(svcCtx *svc.ServiceContext) *MsgPushServiceServer
  • func (s *MsgPushServiceServer) Cleanup(session sarama.ConsumerGroupSession) error
  • func (s *MsgPushServiceServer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (s *MsgPushServiceServer) ConsumeSingle(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)
  • func (s *MsgPushServiceServer) ConsumeSuperGroup(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)
  • func (s *MsgPushServiceServer) PushMsg(ctx context.Context, in *pushpb.PushMsgReq) (*pushpb.PushMsgResp, error)
  • func (s *MsgPushServiceServer) PushSuperGroupMsg(ctx context.Context, in *chatpb.PushMsgToSuperGroupDataToMQ) (*pushpb.PushMsgResp, error)
  • func (s *MsgPushServiceServer) Setup(session sarama.ConsumerGroupSession) error
  • func (s *MsgPushServiceServer) Subscribe()

Types

type Cmd2Value

type Cmd2Value struct {
	Cmd   int
	Value interface{}
}

type MsgPushServiceServer

type MsgPushServiceServer struct {
	pushpb.UnimplementedMsgPushServiceServer
	SingleConsumerGroup     *xkafka.MConsumerGroup
	SuperGroupConsumerGroup *xkafka.MConsumerGroup
	// contains filtered or unexported fields
}

func NewMsgPushServiceServer

func NewMsgPushServiceServer(svcCtx *svc.ServiceContext) *MsgPushServiceServer

func (*MsgPushServiceServer) Cleanup

func (s *MsgPushServiceServer) Cleanup(session sarama.ConsumerGroupSession) error

func (*MsgPushServiceServer) ConsumeClaim

func (s *MsgPushServiceServer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*MsgPushServiceServer) ConsumeSingle

func (s *MsgPushServiceServer) ConsumeSingle(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)

func (*MsgPushServiceServer) ConsumeSuperGroup

func (s *MsgPushServiceServer) ConsumeSuperGroup(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)

func (*MsgPushServiceServer) PushMsg

func (s *MsgPushServiceServer) PushMsg(ctx context.Context, in *pushpb.PushMsgReq) (*pushpb.PushMsgResp, error)

func (*MsgPushServiceServer) PushSuperGroupMsg

func (s *MsgPushServiceServer) PushSuperGroupMsg(ctx context.Context, in *chatpb.PushMsgToSuperGroupDataToMQ) (*pushpb.PushMsgResp, error)

func (*MsgPushServiceServer) Setup

func (s *MsgPushServiceServer) Setup(session sarama.ConsumerGroupSession) error

func (*MsgPushServiceServer) Subscribe

func (s *MsgPushServiceServer) Subscribe()