logic

Documentation

Index

• type GetMaxAndMinSeqLogic
  • func NewGetMaxAndMinSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMaxAndMinSeqLogic
  • func (l *GetMaxAndMinSeqLogic) GetMaxAndMinSeq(in *pb.GetMaxAndMinSeqReq) (*pb.GetMaxAndMinSeqResp, error)
• type GetSuperGroupMaxAndMinSeqLogic
  • func NewGetSuperGroupMaxAndMinSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetSuperGroupMaxAndMinSeqLogic
  • func (l *GetSuperGroupMaxAndMinSeqLogic) GetSuperGroupMaxAndMinSeq(in *pb.GetMaxAndMinSuperGroupSeqReq) (*pb.GetMaxAndMinSuperGroupSeqResp, error)
• type MsgCallBackReq
• type MsgCallBackResp
• type PullMessageBySeqListLogic
  • func NewPullMessageBySeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageBySeqListLogic
  • func (l *PullMessageBySeqListLogic) PullMessageBySeqList(in *pb.WrapPullMessageBySeqListReq) (*pb.WrapPullMessageBySeqListResp, error)
• type PullMessageBySuperGroupSeqListLogic
  • func NewPullMessageBySuperGroupSeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageBySuperGroupSeqListLogic
  • func (l *PullMessageBySuperGroupSeqListLogic) PullMessageBySuperGroupSeqList(in *pb.PullMessageBySuperGroupSeqListReq) (*pb.WrapPullMessageBySeqListResp, error)
• type SendMsgLogic
  • func NewSendMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendMsgLogic
  • func (l *SendMsgLogic) SendMsg(pb *pb.SendMsgReq) (*pb.SendMsgResp, error)

Types

type GetMaxAndMinSeqLogic

type GetMaxAndMinSeqLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

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 MsgCallBackResp struct {
	ErrCode         int32  `json:"errCode"`
	ErrMsg          string `json:"errMsg"`
	ResponseErrCode int32  `json:"responseErrCode"`
	ResponseResult  struct {
		ModifiedMsg string `json:"modifiedMsg"`
		Ext         string `json:"ext"`
	}
}

type PullMessageBySeqListLogic

type PullMessageBySeqListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

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

type SendMsgLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSendMsgLogic

func NewSendMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SendMsgLogic

func (*SendMsgLogic) SendMsg

func (l *SendMsgLogic) SendMsg(pb *pb.SendMsgReq) (*pb.SendMsgResp, error)