rpcserver

Documentation

Index

• type OnlineMessageRelayServiceServer
  • func NewOnlineMessageRelayServiceServer(svcCtx *rpcsvc.ServiceContext) *OnlineMessageRelayServiceServer
  • func (s *OnlineMessageRelayServiceServer) GetUsersOnlineStatus(ctx context.Context, in *pb.GetUsersOnlineStatusReq) (*pb.GetUsersOnlineStatusResp, error)
  • func (s *OnlineMessageRelayServiceServer) HandleMsg(value []byte, key []byte, topic string, partition int32, offset int64, ...) error
  • func (s *OnlineMessageRelayServiceServer) KickUserConns(ctx context.Context, in *pb.KickUserConnsReq) (*pb.KickUserConnsResp, error)
  • func (s *OnlineMessageRelayServiceServer) OnlinePushMsg(ctx context.Context, in *pb.OnlinePushMsgReq) (*pb.OnlinePushMsgResp, error)
  • func (s *OnlineMessageRelayServiceServer) PushMsg(ctx context.Context, msgFromMQ *chatpb.PushMsgDataToMQ) error
  • func (s *OnlineMessageRelayServiceServer) Subscribe()

Types

type OnlineMessageRelayServiceServer

type OnlineMessageRelayServiceServer struct {
	pb.UnimplementedOnlineMessageRelayServiceServer
	SingleConsumerGroup *xkafka.MConsumerGroup
	GroupConsumerGroup  *xkafka.MConsumerGroup
	// contains filtered or unexported fields
}

func NewOnlineMessageRelayServiceServer

func NewOnlineMessageRelayServiceServer(svcCtx *rpcsvc.ServiceContext) *OnlineMessageRelayServiceServer

func (*OnlineMessageRelayServiceServer) GetUsersOnlineStatus

func (s *OnlineMessageRelayServiceServer) GetUsersOnlineStatus(ctx context.Context, in *pb.GetUsersOnlineStatusReq) (*pb.GetUsersOnlineStatusResp, error)

func (*OnlineMessageRelayServiceServer) HandleMsg

func (s *OnlineMessageRelayServiceServer) HandleMsg(value []byte, key []byte, topic string, partition int32, offset int64, msg *sarama.ConsumerMessage) error

func (*OnlineMessageRelayServiceServer) KickUserConns

func (s *OnlineMessageRelayServiceServer) KickUserConns(ctx context.Context, in *pb.KickUserConnsReq) (*pb.KickUserConnsResp, error)

func (*OnlineMessageRelayServiceServer) OnlinePushMsg

func (s *OnlineMessageRelayServiceServer) OnlinePushMsg(ctx context.Context, in *pb.OnlinePushMsgReq) (*pb.OnlinePushMsgResp, error)

func (*OnlineMessageRelayServiceServer) PushMsg

func (s *OnlineMessageRelayServiceServer) PushMsg(ctx context.Context, msgFromMQ *chatpb.PushMsgDataToMQ) error

func (*OnlineMessageRelayServiceServer) Subscribe

func (s *OnlineMessageRelayServiceServer) Subscribe()