Documentation ¶
Index ¶
- Constants
- type Cmd2Value
- type MsgTransferPersistentServer
- func (s *MsgTransferPersistentServer) ChatMs2mysql(msg []byte, msgKey string) error
- func (s *MsgTransferPersistentServer) Cleanup(session sarama.ConsumerGroupSession) error
- func (s *MsgTransferPersistentServer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
- func (s *MsgTransferPersistentServer) SetOnlineTopicStatus(busy int)
- func (s *MsgTransferPersistentServer) Setup(session sarama.ConsumerGroupSession) error
- func (s *MsgTransferPersistentServer) Start()
- func (s *MsgTransferPersistentServer) TriggerCmd(ctx context.Context, status int)
Constants ¶
View Source
const OnlineTopicBusy = 1
View Source
const OnlineTopicVacancy = 0
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MsgTransferPersistentServer ¶
type MsgTransferPersistentServer struct { OnlineTopicStatus int // contains filtered or unexported fields }
func NewMsgTransferPersistentServer ¶
func NewMsgTransferPersistentServer(svcCtx *svc.ServiceContext) *MsgTransferPersistentServer
func (*MsgTransferPersistentServer) ChatMs2mysql ¶
func (s *MsgTransferPersistentServer) ChatMs2mysql(msg []byte, msgKey string) error
func (*MsgTransferPersistentServer) Cleanup ¶
func (s *MsgTransferPersistentServer) Cleanup(session sarama.ConsumerGroupSession) error
func (*MsgTransferPersistentServer) ConsumeClaim ¶
func (s *MsgTransferPersistentServer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*MsgTransferPersistentServer) SetOnlineTopicStatus ¶
func (s *MsgTransferPersistentServer) SetOnlineTopicStatus(busy int)
func (*MsgTransferPersistentServer) Setup ¶
func (s *MsgTransferPersistentServer) Setup(session sarama.ConsumerGroupSession) error
func (*MsgTransferPersistentServer) Start ¶
func (s *MsgTransferPersistentServer) Start()
func (*MsgTransferPersistentServer) TriggerCmd ¶
func (s *MsgTransferPersistentServer) TriggerCmd(ctx context.Context, status int)
Click to show internal directories.
Click to hide internal directories.