logic

Documentation

Index

• type GetMaxAndMinSeqLogic
  • func NewGetMaxAndMinSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMaxAndMinSeqLogic
  • func (l *GetMaxAndMinSeqLogic) GetMaxAndMinSeq(in *pb.GetMinAndMaxSeqReq) (*pb.GetMinAndMaxSeqResp, error)
• type GetMinAndMaxGroupSeqLogic
  • func NewGetMinAndMaxGroupSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMinAndMaxGroupSeqLogic
  • func (l *GetMinAndMaxGroupSeqLogic) GetMinAndMaxGroupSeq(in *pb.GetMinAndMaxGroupSeqReq) (*pb.GetMinAndMaxGroupSeqResp, error)
• type MsgCallBackReq
• type MsgCallBackResp
• type PullMessageByGroupSeqListLogic
  • func NewPullMessageByGroupSeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageByGroupSeqListLogic
  • func (l *PullMessageByGroupSeqListLogic) PullMessageByGroupSeqList(in *pb.PullMsgByGroupSeqListReq) (*pb.PullMsgListResp, error)
• type PullMessageBySeqListLogic
  • func NewPullMessageBySeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageBySeqListLogic
  • func (l *PullMessageBySeqListLogic) PullMessageBySeqList(in *pb.PullMsgBySeqListReq) (*pb.PullMsgListResp, 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.GetMinAndMaxSeqReq) (*pb.GetMinAndMaxSeqResp, error)

type GetMinAndMaxGroupSeqLogic

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

func NewGetMinAndMaxGroupSeqLogic

func NewGetMinAndMaxGroupSeqLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMinAndMaxGroupSeqLogic

func (*GetMinAndMaxGroupSeqLogic) GetMinAndMaxGroupSeq

func (l *GetMinAndMaxGroupSeqLogic) GetMinAndMaxGroupSeq(in *pb.GetMinAndMaxGroupSeqReq) (*pb.GetMinAndMaxGroupSeqResp, error)

type MsgCallBackReq

type MsgCallBackReq struct {
	SendID       string `json:"sendID"`
	RecvID       string `json:"recvID"`
	Content      string `json:"content"`
	SendTime     int64  `json:"sendTime"`
	ContentType  int32  `json:"contentType"`
	SessionType  int32  `json:"sessionType"`
	ClientMsgID  string `json:"clientMsgID"`
	ServerMsgID  string `json:"serverMsgID"`
	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 PullMessageByGroupSeqListLogic

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

func NewPullMessageByGroupSeqListLogic

func NewPullMessageByGroupSeqListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PullMessageByGroupSeqListLogic

func (*PullMessageByGroupSeqListLogic) PullMessageByGroupSeqList

func (l *PullMessageByGroupSeqListLogic) PullMessageByGroupSeqList(in *pb.PullMsgByGroupSeqListReq) (*pb.PullMsgListResp, error)

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.PullMsgBySeqListReq) (*pb.PullMsgListResp, 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)