server

Documentation

Index

• Constants
• type Cmd2Value
• type MsgTransferHistoryServer
  • func NewMsgTransferHistoryServer(svcCtx *svc.ServiceContext) *MsgTransferHistoryServer
  • func (s *MsgTransferHistoryServer) ChatMs2Mongo(msg []byte, msgKey string) error
  • func (s *MsgTransferHistoryServer) Cleanup(session sarama.ConsumerGroupSession) error
  • func (s *MsgTransferHistoryServer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (s *MsgTransferHistoryServer) SetOnlineTopicStatus(busy int)
  • func (s *MsgTransferHistoryServer) Setup(session sarama.ConsumerGroupSession) error
  • func (s *MsgTransferHistoryServer) Start()
  • func (s *MsgTransferHistoryServer) TriggerCmd(ctx context.Context, status int)

Constants

const OnlineTopicBusy = 1

const OnlineTopicVacancy = 0

Types

type Cmd2Value

type Cmd2Value struct {
	Cmd   int
	Value interface{}
}

type MsgTransferHistoryServer

type MsgTransferHistoryServer struct {
	OnlineTopicStatus int
	// contains filtered or unexported fields
}

func NewMsgTransferHistoryServer

func NewMsgTransferHistoryServer(svcCtx *svc.ServiceContext) *MsgTransferHistoryServer

func (*MsgTransferHistoryServer) ChatMs2Mongo

func (s *MsgTransferHistoryServer) ChatMs2Mongo(msg []byte, msgKey string) error

func (*MsgTransferHistoryServer) Cleanup

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

func (*MsgTransferHistoryServer) ConsumeClaim

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

func (*MsgTransferHistoryServer) SetOnlineTopicStatus

func (s *MsgTransferHistoryServer) SetOnlineTopicStatus(busy int)

func (*MsgTransferHistoryServer) Setup

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

func (*MsgTransferHistoryServer) Start

func (s *MsgTransferHistoryServer) Start()

func (*MsgTransferHistoryServer) TriggerCmd

func (s *MsgTransferHistoryServer) TriggerCmd(ctx context.Context, status int)