Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GetMaxAndMinSeqLogic ¶
func NewGetMaxAndMinSeqLogic ¶
func NewGetMaxAndMinSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMaxAndMinSeqLogic
func (*GetMaxAndMinSeqLogic) GetMaxAndMinSeq ¶
func (l *GetMaxAndMinSeqLogic) GetMaxAndMinSeq(in *pb.GetMaxAndMinSeqReq) (*pb.GetMaxAndMinSeqResp, error)
type GetSuperGroupMaxAndMinSeqLogic ¶
type GetSuperGroupMaxAndMinSeqLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}
    func NewGetSuperGroupMaxAndMinSeqLogic ¶
func NewGetSuperGroupMaxAndMinSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetSuperGroupMaxAndMinSeqLogic
func (*GetSuperGroupMaxAndMinSeqLogic) GetSuperGroupMaxAndMinSeq ¶
func (l *GetSuperGroupMaxAndMinSeqLogic) GetSuperGroupMaxAndMinSeq(in *pb.GetMaxAndMinSuperGroupSeqReq) (*pb.GetMaxAndMinSuperGroupSeqResp, error)
type MsgCallBackReq ¶
type MsgCallBackReq struct {
	SendID       string `json:"sendID"`
	RecvID       string `json:"recvID"`
	Content      string `json:"content"`
	SendTime     int64  `json:"sendTime"`
	MsgFrom      int32  `json:"msgFrom"`
	ContentType  int32  `json:"contentType"`
	SessionType  int32  `json:"sessionType"`
	PlatformID   int32  `json:"senderPlatformID"`
	MsgID        string `json:"msgID"`
	IsOnlineOnly bool   `json:"isOnlineOnly"`
}
    type MsgCallBackResp ¶
type PullMessageBySeqListLogic ¶
func NewPullMessageBySeqListLogic ¶
func NewPullMessageBySeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageBySeqListLogic
func (*PullMessageBySeqListLogic) PullMessageBySeqList ¶
func (l *PullMessageBySeqListLogic) PullMessageBySeqList(in *pb.WrapPullMessageBySeqListReq) (*pb.WrapPullMessageBySeqListResp, error)
type PullMessageBySuperGroupSeqListLogic ¶
type PullMessageBySuperGroupSeqListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}
    func NewPullMessageBySuperGroupSeqListLogic ¶
func NewPullMessageBySuperGroupSeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageBySuperGroupSeqListLogic
func (*PullMessageBySuperGroupSeqListLogic) PullMessageBySuperGroupSeqList ¶
func (l *PullMessageBySuperGroupSeqListLogic) PullMessageBySuperGroupSeqList(in *pb.PullMessageBySuperGroupSeqListReq) (*pb.WrapPullMessageBySeqListResp, error)
type SendMsgLogic ¶
func NewSendMsgLogic ¶
func NewSendMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendMsgLogic
func (*SendMsgLogic) SendMsg ¶
func (l *SendMsgLogic) SendMsg(pb *pb.SendMsgReq) (*pb.SendMsgResp, error)
      
      Source Files
      ¶
    
- getMaxAndMinSeqLogic.go
 - getSuperGroupMaxAndMinSeqLogic.go
 - pullMessageBySeqListLogic.go
 - pullMessageBySuperGroupSeqListLogic.go
 - sendMsgCallbackAtAllInSuperGroup.go
 - sendMsgCallbackSendGroupMsg.go
 - sendMsgCallbackSendSingleMsg.go
 - sendMsgCallbackSendSuperGroupMsg.go
 - sendMsgCallbackWordFilter.go
 - sendMsgEncapsulateMsgData.go
 - sendMsgLogic.go
 - sendMsgStruct.go
 - sendMsgToKafka.go
 
 Click to show internal directories. 
   Click to hide internal directories.