Documentation ¶
Index ¶
- Variables
- func RegisterMsgServer(s *grpc.Server, srv MsgServer)
- type ActiveGroup
- func (*ActiveGroup) Descriptor() ([]byte, []int)deprecated
- func (x *ActiveGroup) GetCount() int64
- func (x *ActiveGroup) GetGroup() *sdkws.GroupInfo
- func (*ActiveGroup) ProtoMessage()
- func (x *ActiveGroup) ProtoReflect() protoreflect.Message
- func (x *ActiveGroup) Reset()
- func (x *ActiveGroup) String() string
- type ActiveUser
- type BatchSendMessageReq
- func (*BatchSendMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *BatchSendMessageReq) GetMsgData() *sdkws.MsgData
- func (x *BatchSendMessageReq) GetRecvIDList() []string
- func (*BatchSendMessageReq) ProtoMessage()
- func (x *BatchSendMessageReq) ProtoReflect() protoreflect.Message
- func (x *BatchSendMessageReq) Reset()
- func (x *BatchSendMessageReq) String() string
- type BatchSendMessageResp
- type ChatLog
- func (*ChatLog) Descriptor() ([]byte, []int)deprecated
- func (x *ChatLog) GetClientMsgID() string
- func (x *ChatLog) GetContent() string
- func (x *ChatLog) GetContentType() int32
- func (x *ChatLog) GetCreateTime() int64
- func (x *ChatLog) GetEx() string
- func (x *ChatLog) GetGroupFaceURL() string
- func (x *ChatLog) GetGroupID() string
- func (x *ChatLog) GetGroupMemberCount() uint32
- func (x *ChatLog) GetGroupName() string
- func (x *ChatLog) GetGroupOwner() string
- func (x *ChatLog) GetGroupType() int32
- func (x *ChatLog) GetMsgFrom() int32
- func (x *ChatLog) GetRecvID() string
- func (x *ChatLog) GetRecvNickname() string
- func (x *ChatLog) GetSendID() string
- func (x *ChatLog) GetSendTime() int64
- func (x *ChatLog) GetSenderFaceURL() string
- func (x *ChatLog) GetSenderNickname() string
- func (x *ChatLog) GetSenderPlatformID() int32
- func (x *ChatLog) GetSeq() int64
- func (x *ChatLog) GetServerMsgID() string
- func (x *ChatLog) GetSessionType() int32
- func (x *ChatLog) GetStatus() int32
- func (*ChatLog) ProtoMessage()
- func (x *ChatLog) ProtoReflect() protoreflect.Message
- func (x *ChatLog) Reset()
- func (x *ChatLog) String() string
- type ClearConversationsMsgReq
- func (x *ClearConversationsMsgReq) Check() error
- func (*ClearConversationsMsgReq) Descriptor() ([]byte, []int)deprecated
- func (x *ClearConversationsMsgReq) GetConversationIDs() []string
- func (x *ClearConversationsMsgReq) GetDeleteSyncOpt() *DeleteSyncOpt
- func (x *ClearConversationsMsgReq) GetUserID() string
- func (*ClearConversationsMsgReq) ProtoMessage()
- func (x *ClearConversationsMsgReq) ProtoReflect() protoreflect.Message
- func (x *ClearConversationsMsgReq) Reset()
- func (x *ClearConversationsMsgReq) String() string
- type ClearConversationsMsgResp
- type ClearMsgReq
- type ClearMsgResp
- type DelMsgsReq
- type DelMsgsResp
- type DeleteMsgPhysicalBySeqReq
- func (*DeleteMsgPhysicalBySeqReq) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteMsgPhysicalBySeqReq) GetConversationID() string
- func (x *DeleteMsgPhysicalBySeqReq) GetSeqs() []int64
- func (*DeleteMsgPhysicalBySeqReq) ProtoMessage()
- func (x *DeleteMsgPhysicalBySeqReq) ProtoReflect() protoreflect.Message
- func (x *DeleteMsgPhysicalBySeqReq) Reset()
- func (x *DeleteMsgPhysicalBySeqReq) String() string
- type DeleteMsgPhysicalBySeqResp
- type DeleteMsgPhysicalReq
- func (x *DeleteMsgPhysicalReq) Check() error
- func (*DeleteMsgPhysicalReq) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteMsgPhysicalReq) GetConversationIDs() []string
- func (x *DeleteMsgPhysicalReq) GetTimestamp() int64
- func (*DeleteMsgPhysicalReq) ProtoMessage()
- func (x *DeleteMsgPhysicalReq) ProtoReflect() protoreflect.Message
- func (x *DeleteMsgPhysicalReq) Reset()
- func (x *DeleteMsgPhysicalReq) String() string
- type DeleteMsgPhysicalResp
- type DeleteMsgsReq
- func (x *DeleteMsgsReq) Check() error
- func (*DeleteMsgsReq) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteMsgsReq) GetConversationID() string
- func (x *DeleteMsgsReq) GetDeleteSyncOpt() *DeleteSyncOpt
- func (x *DeleteMsgsReq) GetSeqs() []int64
- func (x *DeleteMsgsReq) GetUserID() string
- func (*DeleteMsgsReq) ProtoMessage()
- func (x *DeleteMsgsReq) ProtoReflect() protoreflect.Message
- func (x *DeleteMsgsReq) Reset()
- func (x *DeleteMsgsReq) String() string
- type DeleteMsgsResp
- type DeleteSyncOpt
- func (*DeleteSyncOpt) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSyncOpt) GetIsSyncOther() bool
- func (x *DeleteSyncOpt) GetIsSyncSelf() bool
- func (*DeleteSyncOpt) ProtoMessage()
- func (x *DeleteSyncOpt) ProtoReflect() protoreflect.Message
- func (x *DeleteSyncOpt) Reset()
- func (x *DeleteSyncOpt) String() string
- type GetActiveGroupReq
- func (*GetActiveGroupReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveGroupReq) GetAse() bool
- func (x *GetActiveGroupReq) GetEnd() int64
- func (x *GetActiveGroupReq) GetPagination() *sdkws.RequestPagination
- func (x *GetActiveGroupReq) GetStart() int64
- func (*GetActiveGroupReq) ProtoMessage()
- func (x *GetActiveGroupReq) ProtoReflect() protoreflect.Message
- func (x *GetActiveGroupReq) Reset()
- func (x *GetActiveGroupReq) String() string
- type GetActiveGroupResp
- func (*GetActiveGroupResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveGroupResp) GetDateCount() map[string]int64
- func (x *GetActiveGroupResp) GetGroupCount() int64
- func (x *GetActiveGroupResp) GetGroups() []*ActiveGroup
- func (x *GetActiveGroupResp) GetMsgCount() int64
- func (*GetActiveGroupResp) ProtoMessage()
- func (x *GetActiveGroupResp) ProtoReflect() protoreflect.Message
- func (x *GetActiveGroupResp) Reset()
- func (x *GetActiveGroupResp) String() string
- type GetActiveUserReq
- func (*GetActiveUserReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveUserReq) GetAse() bool
- func (x *GetActiveUserReq) GetEnd() int64
- func (x *GetActiveUserReq) GetGroup() bool
- func (x *GetActiveUserReq) GetPagination() *sdkws.RequestPagination
- func (x *GetActiveUserReq) GetStart() int64
- func (*GetActiveUserReq) ProtoMessage()
- func (x *GetActiveUserReq) ProtoReflect() protoreflect.Message
- func (x *GetActiveUserReq) Reset()
- func (x *GetActiveUserReq) String() string
- type GetActiveUserResp
- func (*GetActiveUserResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveUserResp) GetDateCount() map[string]int64
- func (x *GetActiveUserResp) GetMsgCount() int64
- func (x *GetActiveUserResp) GetUserCount() int64
- func (x *GetActiveUserResp) GetUsers() []*ActiveUser
- func (*GetActiveUserResp) ProtoMessage()
- func (x *GetActiveUserResp) ProtoReflect() protoreflect.Message
- func (x *GetActiveUserResp) Reset()
- func (x *GetActiveUserResp) String() string
- type GetConversationMaxSeqReq
- func (x *GetConversationMaxSeqReq) Check() error
- func (*GetConversationMaxSeqReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetConversationMaxSeqReq) GetConversationID() string
- func (*GetConversationMaxSeqReq) ProtoMessage()
- func (x *GetConversationMaxSeqReq) ProtoReflect() protoreflect.Message
- func (x *GetConversationMaxSeqReq) Reset()
- func (x *GetConversationMaxSeqReq) String() string
- type GetConversationMaxSeqResp
- func (*GetConversationMaxSeqResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetConversationMaxSeqResp) GetMaxSeq() int64
- func (*GetConversationMaxSeqResp) ProtoMessage()
- func (x *GetConversationMaxSeqResp) ProtoReflect() protoreflect.Message
- func (x *GetConversationMaxSeqResp) Reset()
- func (x *GetConversationMaxSeqResp) String() string
- type GetConversationsHasReadAndMaxSeqReq
- func (x *GetConversationsHasReadAndMaxSeqReq) Check() error
- func (*GetConversationsHasReadAndMaxSeqReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetConversationsHasReadAndMaxSeqReq) GetConversationIDs() []string
- func (x *GetConversationsHasReadAndMaxSeqReq) GetUserID() string
- func (*GetConversationsHasReadAndMaxSeqReq) ProtoMessage()
- func (x *GetConversationsHasReadAndMaxSeqReq) ProtoReflect() protoreflect.Message
- func (x *GetConversationsHasReadAndMaxSeqReq) Reset()
- func (x *GetConversationsHasReadAndMaxSeqReq) String() string
- type GetConversationsHasReadAndMaxSeqResp
- func (*GetConversationsHasReadAndMaxSeqResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetConversationsHasReadAndMaxSeqResp) GetSeqs() map[string]*Seqs
- func (*GetConversationsHasReadAndMaxSeqResp) ProtoMessage()
- func (x *GetConversationsHasReadAndMaxSeqResp) ProtoReflect() protoreflect.Message
- func (x *GetConversationsHasReadAndMaxSeqResp) Reset()
- func (x *GetConversationsHasReadAndMaxSeqResp) String() string
- type GetHasReadSeqsReq
- func (*GetHasReadSeqsReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetHasReadSeqsReq) GetConversationIDs() []string
- func (x *GetHasReadSeqsReq) GetUserID() string
- func (*GetHasReadSeqsReq) ProtoMessage()
- func (x *GetHasReadSeqsReq) ProtoReflect() protoreflect.Message
- func (x *GetHasReadSeqsReq) Reset()
- func (x *GetHasReadSeqsReq) String() string
- type GetMaxAndMinSeqReq
- func (x *GetMaxAndMinSeqReq) Check() error
- func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetMaxAndMinSeqReq) GetUserID() string
- func (*GetMaxAndMinSeqReq) ProtoMessage()
- func (x *GetMaxAndMinSeqReq) ProtoReflect() protoreflect.Message
- func (x *GetMaxAndMinSeqReq) Reset()
- func (x *GetMaxAndMinSeqReq) String() string
- type GetMaxAndMinSeqResp
- func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetMaxAndMinSeqResp) GetMaxSeq() int64
- func (x *GetMaxAndMinSeqResp) GetMinSeq() int64
- func (*GetMaxAndMinSeqResp) ProtoMessage()
- func (x *GetMaxAndMinSeqResp) ProtoReflect() protoreflect.Message
- func (x *GetMaxAndMinSeqResp) Reset()
- func (x *GetMaxAndMinSeqResp) String() string
- type GetMaxSeqsReq
- type GetMsgByConversationIDsReq
- func (*GetMsgByConversationIDsReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetMsgByConversationIDsReq) GetConversationIDs() []string
- func (x *GetMsgByConversationIDsReq) GetMaxSeqs() map[string]int64
- func (*GetMsgByConversationIDsReq) ProtoMessage()
- func (x *GetMsgByConversationIDsReq) ProtoReflect() protoreflect.Message
- func (x *GetMsgByConversationIDsReq) Reset()
- func (x *GetMsgByConversationIDsReq) String() string
- type GetMsgByConversationIDsResp
- func (*GetMsgByConversationIDsResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetMsgByConversationIDsResp) GetMsgDatas() map[string]*sdkws.MsgData
- func (*GetMsgByConversationIDsResp) ProtoMessage()
- func (x *GetMsgByConversationIDsResp) ProtoReflect() protoreflect.Message
- func (x *GetMsgByConversationIDsResp) Reset()
- func (x *GetMsgByConversationIDsResp) String() string
- type GetSendMsgStatusReq
- func (x *GetSendMsgStatusReq) Check() error
- func (*GetSendMsgStatusReq) Descriptor() ([]byte, []int)deprecated
- func (*GetSendMsgStatusReq) ProtoMessage()
- func (x *GetSendMsgStatusReq) ProtoReflect() protoreflect.Message
- func (x *GetSendMsgStatusReq) Reset()
- func (x *GetSendMsgStatusReq) String() string
- type GetSendMsgStatusResp
- func (*GetSendMsgStatusResp) Descriptor() ([]byte, []int)deprecated
- func (x *GetSendMsgStatusResp) GetStatus() int32
- func (*GetSendMsgStatusResp) ProtoMessage()
- func (x *GetSendMsgStatusResp) ProtoReflect() protoreflect.Message
- func (x *GetSendMsgStatusResp) Reset()
- func (x *GetSendMsgStatusResp) String() string
- type GetServerTimeReq
- type GetServerTimeResp
- type MarkConversationAsReadReq
- func (x *MarkConversationAsReadReq) Check() error
- func (*MarkConversationAsReadReq) Descriptor() ([]byte, []int)deprecated
- func (x *MarkConversationAsReadReq) GetConversationID() string
- func (x *MarkConversationAsReadReq) GetHasReadSeq() int64
- func (x *MarkConversationAsReadReq) GetSeqs() []int64
- func (x *MarkConversationAsReadReq) GetUserID() string
- func (*MarkConversationAsReadReq) ProtoMessage()
- func (x *MarkConversationAsReadReq) ProtoReflect() protoreflect.Message
- func (x *MarkConversationAsReadReq) Reset()
- func (x *MarkConversationAsReadReq) String() string
- type MarkConversationAsReadResp
- type MarkMsgsAsReadReq
- func (x *MarkMsgsAsReadReq) Check() error
- func (*MarkMsgsAsReadReq) Descriptor() ([]byte, []int)deprecated
- func (x *MarkMsgsAsReadReq) GetConversationID() string
- func (x *MarkMsgsAsReadReq) GetSeqs() []int64
- func (x *MarkMsgsAsReadReq) GetUserID() string
- func (*MarkMsgsAsReadReq) ProtoMessage()
- func (x *MarkMsgsAsReadReq) ProtoReflect() protoreflect.Message
- func (x *MarkMsgsAsReadReq) Reset()
- func (x *MarkMsgsAsReadReq) String() string
- type MarkMsgsAsReadResp
- type MsgClient
- type MsgDataToDB
- type MsgDataToMQ
- func (*MsgDataToMQ) Descriptor() ([]byte, []int)deprecated
- func (x *MsgDataToMQ) GetMsgData() *sdkws.MsgData
- func (x *MsgDataToMQ) GetToken() string
- func (*MsgDataToMQ) ProtoMessage()
- func (x *MsgDataToMQ) ProtoReflect() protoreflect.Message
- func (x *MsgDataToMQ) Reset()
- func (x *MsgDataToMQ) String() string
- type MsgDataToModifyByMQ
- func (*MsgDataToModifyByMQ) Descriptor() ([]byte, []int)deprecated
- func (x *MsgDataToModifyByMQ) GetConversationID() string
- func (x *MsgDataToModifyByMQ) GetMessages() []*sdkws.MsgData
- func (*MsgDataToModifyByMQ) ProtoMessage()
- func (x *MsgDataToModifyByMQ) ProtoReflect() protoreflect.Message
- func (x *MsgDataToModifyByMQ) Reset()
- func (x *MsgDataToModifyByMQ) String() string
- type MsgDataToMongoByMQ
- func (*MsgDataToMongoByMQ) Descriptor() ([]byte, []int)deprecated
- func (x *MsgDataToMongoByMQ) GetConversationID() string
- func (x *MsgDataToMongoByMQ) GetLastSeq() int64
- func (x *MsgDataToMongoByMQ) GetMsgData() []*sdkws.MsgData
- func (*MsgDataToMongoByMQ) ProtoMessage()
- func (x *MsgDataToMongoByMQ) ProtoReflect() protoreflect.Message
- func (x *MsgDataToMongoByMQ) Reset()
- func (x *MsgDataToMongoByMQ) String() string
- type MsgServer
- type PushMsgDataToMQ
- func (*PushMsgDataToMQ) Descriptor() ([]byte, []int)deprecated
- func (x *PushMsgDataToMQ) GetConversationID() string
- func (x *PushMsgDataToMQ) GetMsgData() *sdkws.MsgData
- func (*PushMsgDataToMQ) ProtoMessage()
- func (x *PushMsgDataToMQ) ProtoReflect() protoreflect.Message
- func (x *PushMsgDataToMQ) Reset()
- func (x *PushMsgDataToMQ) String() string
- type RevokeMsgReq
- func (x *RevokeMsgReq) Check() error
- func (*RevokeMsgReq) Descriptor() ([]byte, []int)deprecated
- func (x *RevokeMsgReq) GetConversationID() string
- func (x *RevokeMsgReq) GetSeq() int64
- func (x *RevokeMsgReq) GetUserID() string
- func (*RevokeMsgReq) ProtoMessage()
- func (x *RevokeMsgReq) ProtoReflect() protoreflect.Message
- func (x *RevokeMsgReq) Reset()
- func (x *RevokeMsgReq) String() string
- type RevokeMsgResp
- type SearchMessageReq
- func (*SearchMessageReq) Descriptor() ([]byte, []int)deprecated
- func (x *SearchMessageReq) GetContentType() int32
- func (x *SearchMessageReq) GetPagination() *sdkws.RequestPagination
- func (x *SearchMessageReq) GetRecvID() string
- func (x *SearchMessageReq) GetSendID() string
- func (x *SearchMessageReq) GetSendTime() string
- func (x *SearchMessageReq) GetSessionType() int32
- func (*SearchMessageReq) ProtoMessage()
- func (x *SearchMessageReq) ProtoReflect() protoreflect.Message
- func (x *SearchMessageReq) Reset()
- func (x *SearchMessageReq) String() string
- type SearchMessageResp
- func (*SearchMessageResp) Descriptor() ([]byte, []int)deprecated
- func (x *SearchMessageResp) GetChatLogs() []*ChatLog
- func (x *SearchMessageResp) GetChatLogsNum() int32
- func (*SearchMessageResp) ProtoMessage()
- func (x *SearchMessageResp) ProtoReflect() protoreflect.Message
- func (x *SearchMessageResp) Reset()
- func (x *SearchMessageResp) String() string
- type SendMsgReq
- type SendMsgResp
- func (*SendMsgResp) Descriptor() ([]byte, []int)deprecated
- func (x *SendMsgResp) GetClientMsgID() string
- func (x *SendMsgResp) GetSendTime() int64
- func (x *SendMsgResp) GetServerMsgID() string
- func (*SendMsgResp) ProtoMessage()
- func (x *SendMsgResp) ProtoReflect() protoreflect.Message
- func (x *SendMsgResp) Reset()
- func (x *SendMsgResp) String() string
- type Seqs
- type SeqsInfoResp
- type SetConversationHasReadSeqReq
- func (x *SetConversationHasReadSeqReq) Check() error
- func (*SetConversationHasReadSeqReq) Descriptor() ([]byte, []int)deprecated
- func (x *SetConversationHasReadSeqReq) GetConversationID() string
- func (x *SetConversationHasReadSeqReq) GetHasReadSeq() int64
- func (x *SetConversationHasReadSeqReq) GetUserID() string
- func (*SetConversationHasReadSeqReq) ProtoMessage()
- func (x *SetConversationHasReadSeqReq) ProtoReflect() protoreflect.Message
- func (x *SetConversationHasReadSeqReq) Reset()
- func (x *SetConversationHasReadSeqReq) String() string
- type SetConversationHasReadSeqResp
- func (*SetConversationHasReadSeqResp) Descriptor() ([]byte, []int)deprecated
- func (*SetConversationHasReadSeqResp) ProtoMessage()
- func (x *SetConversationHasReadSeqResp) ProtoReflect() protoreflect.Message
- func (x *SetConversationHasReadSeqResp) Reset()
- func (x *SetConversationHasReadSeqResp) String() string
- type SetSendMsgStatusReq
- func (x *SetSendMsgStatusReq) Check() error
- func (*SetSendMsgStatusReq) Descriptor() ([]byte, []int)deprecated
- func (x *SetSendMsgStatusReq) GetStatus() int32
- func (*SetSendMsgStatusReq) ProtoMessage()
- func (x *SetSendMsgStatusReq) ProtoReflect() protoreflect.Message
- func (x *SetSendMsgStatusReq) Reset()
- func (x *SetSendMsgStatusReq) String() string
- type SetSendMsgStatusResp
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) ClearConversationsMsg(context.Context, *ClearConversationsMsgReq) (*ClearConversationsMsgResp, error)
- func (*UnimplementedMsgServer) ClearMsg(context.Context, *ClearMsgReq) (*ClearMsgResp, error)
- func (*UnimplementedMsgServer) DeleteMsgPhysical(context.Context, *DeleteMsgPhysicalReq) (*DeleteMsgPhysicalResp, error)
- func (*UnimplementedMsgServer) DeleteMsgPhysicalBySeq(context.Context, *DeleteMsgPhysicalBySeqReq) (*DeleteMsgPhysicalBySeqResp, error)
- func (*UnimplementedMsgServer) DeleteMsgs(context.Context, *DeleteMsgsReq) (*DeleteMsgsResp, error)
- func (*UnimplementedMsgServer) GetActiveGroup(context.Context, *GetActiveGroupReq) (*GetActiveGroupResp, error)
- func (*UnimplementedMsgServer) GetActiveUser(context.Context, *GetActiveUserReq) (*GetActiveUserResp, error)
- func (*UnimplementedMsgServer) GetConversationMaxSeq(context.Context, *GetConversationMaxSeqReq) (*GetConversationMaxSeqResp, error)
- func (*UnimplementedMsgServer) GetConversationsHasReadAndMaxSeq(context.Context, *GetConversationsHasReadAndMaxSeqReq) (*GetConversationsHasReadAndMaxSeqResp, error)
- func (*UnimplementedMsgServer) GetHasReadSeqs(context.Context, *GetHasReadSeqsReq) (*SeqsInfoResp, error)
- func (*UnimplementedMsgServer) GetMaxSeq(context.Context, *sdkws.GetMaxSeqReq) (*sdkws.GetMaxSeqResp, error)
- func (*UnimplementedMsgServer) GetMaxSeqs(context.Context, *GetMaxSeqsReq) (*SeqsInfoResp, error)
- func (*UnimplementedMsgServer) GetMsgByConversationIDs(context.Context, *GetMsgByConversationIDsReq) (*GetMsgByConversationIDsResp, error)
- func (*UnimplementedMsgServer) GetSendMsgStatus(context.Context, *GetSendMsgStatusReq) (*GetSendMsgStatusResp, error)
- func (*UnimplementedMsgServer) GetServerTime(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error)
- func (*UnimplementedMsgServer) MarkConversationAsRead(context.Context, *MarkConversationAsReadReq) (*MarkConversationAsReadResp, error)
- func (*UnimplementedMsgServer) MarkMsgsAsRead(context.Context, *MarkMsgsAsReadReq) (*MarkMsgsAsReadResp, error)
- func (*UnimplementedMsgServer) PullMessageBySeqs(context.Context, *sdkws.PullMessageBySeqsReq) (*sdkws.PullMessageBySeqsResp, error)
- func (*UnimplementedMsgServer) RevokeMsg(context.Context, *RevokeMsgReq) (*RevokeMsgResp, error)
- func (*UnimplementedMsgServer) SearchMessage(context.Context, *SearchMessageReq) (*SearchMessageResp, error)
- func (*UnimplementedMsgServer) SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
- func (*UnimplementedMsgServer) SetConversationHasReadSeq(context.Context, *SetConversationHasReadSeqReq) (*SetConversationHasReadSeqResp, error)
- func (*UnimplementedMsgServer) SetSendMsgStatus(context.Context, *SetSendMsgStatusReq) (*SetSendMsgStatusResp, error)
- func (*UnimplementedMsgServer) UserClearAllMsg(context.Context, *UserClearAllMsgReq) (*UserClearAllMsgResp, error)
- type UserClearAllMsgReq
- func (x *UserClearAllMsgReq) Check() error
- func (*UserClearAllMsgReq) Descriptor() ([]byte, []int)deprecated
- func (x *UserClearAllMsgReq) GetDeleteSyncOpt() *DeleteSyncOpt
- func (x *UserClearAllMsgReq) GetUserID() string
- func (*UserClearAllMsgReq) ProtoMessage()
- func (x *UserClearAllMsgReq) ProtoReflect() protoreflect.Message
- func (x *UserClearAllMsgReq) Reset()
- func (x *UserClearAllMsgReq) String() string
- type UserClearAllMsgResp
Constants ¶
This section is empty.
Variables ¶
var File_msg_msg_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMsgServer ¶
Types ¶
type ActiveGroup ¶
type ActiveGroup struct { Group *sdkws.GroupInfo `protobuf:"bytes,1,opt,name=group,proto3" json:"group"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count"` // contains filtered or unexported fields }
func (*ActiveGroup) Descriptor
deprecated
func (*ActiveGroup) Descriptor() ([]byte, []int)
Deprecated: Use ActiveGroup.ProtoReflect.Descriptor instead.
func (*ActiveGroup) GetCount ¶
func (x *ActiveGroup) GetCount() int64
func (*ActiveGroup) GetGroup ¶
func (x *ActiveGroup) GetGroup() *sdkws.GroupInfo
func (*ActiveGroup) ProtoMessage ¶
func (*ActiveGroup) ProtoMessage()
func (*ActiveGroup) ProtoReflect ¶
func (x *ActiveGroup) ProtoReflect() protoreflect.Message
func (*ActiveGroup) Reset ¶
func (x *ActiveGroup) Reset()
func (*ActiveGroup) String ¶
func (x *ActiveGroup) String() string
type ActiveUser ¶
type ActiveUser struct { User *sdkws.UserInfo `protobuf:"bytes,1,opt,name=user,proto3" json:"user"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count"` // contains filtered or unexported fields }
func (*ActiveUser) Descriptor
deprecated
func (*ActiveUser) Descriptor() ([]byte, []int)
Deprecated: Use ActiveUser.ProtoReflect.Descriptor instead.
func (*ActiveUser) GetCount ¶
func (x *ActiveUser) GetCount() int64
func (*ActiveUser) GetUser ¶
func (x *ActiveUser) GetUser() *sdkws.UserInfo
func (*ActiveUser) ProtoMessage ¶
func (*ActiveUser) ProtoMessage()
func (*ActiveUser) ProtoReflect ¶
func (x *ActiveUser) ProtoReflect() protoreflect.Message
func (*ActiveUser) Reset ¶
func (x *ActiveUser) Reset()
func (*ActiveUser) String ¶
func (x *ActiveUser) String() string
type BatchSendMessageReq ¶
type BatchSendMessageReq struct { RecvIDList []string `protobuf:"bytes,1,rep,name=recvIDList,proto3" json:"recvIDList"` MsgData *sdkws.MsgData `protobuf:"bytes,2,opt,name=msgData,proto3" json:"msgData"` // contains filtered or unexported fields }
func (*BatchSendMessageReq) Descriptor
deprecated
func (*BatchSendMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use BatchSendMessageReq.ProtoReflect.Descriptor instead.
func (*BatchSendMessageReq) GetMsgData ¶
func (x *BatchSendMessageReq) GetMsgData() *sdkws.MsgData
func (*BatchSendMessageReq) GetRecvIDList ¶
func (x *BatchSendMessageReq) GetRecvIDList() []string
func (*BatchSendMessageReq) ProtoMessage ¶
func (*BatchSendMessageReq) ProtoMessage()
func (*BatchSendMessageReq) ProtoReflect ¶
func (x *BatchSendMessageReq) ProtoReflect() protoreflect.Message
func (*BatchSendMessageReq) Reset ¶
func (x *BatchSendMessageReq) Reset()
func (*BatchSendMessageReq) String ¶
func (x *BatchSendMessageReq) String() string
type BatchSendMessageResp ¶
type BatchSendMessageResp struct {
// contains filtered or unexported fields
}
func (*BatchSendMessageResp) Descriptor
deprecated
func (*BatchSendMessageResp) Descriptor() ([]byte, []int)
Deprecated: Use BatchSendMessageResp.ProtoReflect.Descriptor instead.
func (*BatchSendMessageResp) ProtoMessage ¶
func (*BatchSendMessageResp) ProtoMessage()
func (*BatchSendMessageResp) ProtoReflect ¶
func (x *BatchSendMessageResp) ProtoReflect() protoreflect.Message
func (*BatchSendMessageResp) Reset ¶
func (x *BatchSendMessageResp) Reset()
func (*BatchSendMessageResp) String ¶
func (x *BatchSendMessageResp) String() string
type ChatLog ¶
type ChatLog struct { ServerMsgID string `protobuf:"bytes,1,opt,name=serverMsgID,proto3" json:"serverMsgID"` ClientMsgID string `protobuf:"bytes,2,opt,name=clientMsgID,proto3" json:"clientMsgID"` SendID string `protobuf:"bytes,3,opt,name=sendID,proto3" json:"sendID"` RecvID string `protobuf:"bytes,4,opt,name=recvID,proto3" json:"recvID"` GroupID string `protobuf:"bytes,5,opt,name=groupID,proto3" json:"groupID"` RecvNickname string `protobuf:"bytes,6,opt,name=recvNickname,proto3" json:"recvNickname"` SenderPlatformID int32 `protobuf:"varint,7,opt,name=senderPlatformID,proto3" json:"senderPlatformID"` SenderNickname string `protobuf:"bytes,8,opt,name=senderNickname,proto3" json:"senderNickname"` SenderFaceURL string `protobuf:"bytes,9,opt,name=senderFaceURL,proto3" json:"senderFaceURL"` GroupName string `protobuf:"bytes,10,opt,name=groupName,proto3" json:"groupName"` SessionType int32 `protobuf:"varint,11,opt,name=sessionType,proto3" json:"sessionType"` MsgFrom int32 `protobuf:"varint,12,opt,name=msgFrom,proto3" json:"msgFrom"` ContentType int32 `protobuf:"varint,13,opt,name=contentType,proto3" json:"contentType"` Content string `protobuf:"bytes,14,opt,name=content,proto3" json:"content"` Status int32 `protobuf:"varint,15,opt,name=status,proto3" json:"status"` SendTime int64 `protobuf:"varint,16,opt,name=sendTime,proto3" json:"sendTime"` CreateTime int64 `protobuf:"varint,17,opt,name=createTime,proto3" json:"createTime"` Ex string `protobuf:"bytes,18,opt,name=ex,proto3" json:"ex"` GroupFaceURL string `protobuf:"bytes,19,opt,name=groupFaceURL,proto3" json:"groupFaceURL"` GroupMemberCount uint32 `protobuf:"varint,20,opt,name=groupMemberCount,proto3" json:"groupMemberCount"` Seq int64 `protobuf:"varint,21,opt,name=seq,proto3" json:"seq"` GroupOwner string `protobuf:"bytes,22,opt,name=groupOwner,proto3" json:"groupOwner"` GroupType int32 `protobuf:"varint,23,opt,name=groupType,proto3" json:"groupType"` // contains filtered or unexported fields }
func (*ChatLog) Descriptor
deprecated
func (*ChatLog) GetClientMsgID ¶
func (*ChatLog) GetContent ¶
func (*ChatLog) GetContentType ¶
func (*ChatLog) GetCreateTime ¶
func (*ChatLog) GetGroupFaceURL ¶
func (*ChatLog) GetGroupID ¶
func (*ChatLog) GetGroupMemberCount ¶
func (*ChatLog) GetGroupName ¶
func (*ChatLog) GetGroupOwner ¶
func (*ChatLog) GetGroupType ¶
func (*ChatLog) GetMsgFrom ¶
func (*ChatLog) GetRecvNickname ¶
func (*ChatLog) GetSendTime ¶
func (*ChatLog) GetSenderFaceURL ¶
func (*ChatLog) GetSenderNickname ¶
func (*ChatLog) GetSenderPlatformID ¶
func (*ChatLog) GetServerMsgID ¶
func (*ChatLog) GetSessionType ¶
func (*ChatLog) ProtoMessage ¶
func (*ChatLog) ProtoMessage()
func (*ChatLog) ProtoReflect ¶
func (x *ChatLog) ProtoReflect() protoreflect.Message
type ClearConversationsMsgReq ¶
type ClearConversationsMsgReq struct { ConversationIDs []string `protobuf:"bytes,1,rep,name=conversationIDs,proto3" json:"conversationIDs"` UserID string `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID"` DeleteSyncOpt *DeleteSyncOpt `protobuf:"bytes,3,opt,name=deleteSyncOpt,proto3" json:"deleteSyncOpt"` // contains filtered or unexported fields }
func (*ClearConversationsMsgReq) Check ¶
func (x *ClearConversationsMsgReq) Check() error
func (*ClearConversationsMsgReq) Descriptor
deprecated
func (*ClearConversationsMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use ClearConversationsMsgReq.ProtoReflect.Descriptor instead.
func (*ClearConversationsMsgReq) GetConversationIDs ¶
func (x *ClearConversationsMsgReq) GetConversationIDs() []string
func (*ClearConversationsMsgReq) GetDeleteSyncOpt ¶
func (x *ClearConversationsMsgReq) GetDeleteSyncOpt() *DeleteSyncOpt
func (*ClearConversationsMsgReq) GetUserID ¶
func (x *ClearConversationsMsgReq) GetUserID() string
func (*ClearConversationsMsgReq) ProtoMessage ¶
func (*ClearConversationsMsgReq) ProtoMessage()
func (*ClearConversationsMsgReq) ProtoReflect ¶
func (x *ClearConversationsMsgReq) ProtoReflect() protoreflect.Message
func (*ClearConversationsMsgReq) Reset ¶
func (x *ClearConversationsMsgReq) Reset()
func (*ClearConversationsMsgReq) String ¶
func (x *ClearConversationsMsgReq) String() string
type ClearConversationsMsgResp ¶
type ClearConversationsMsgResp struct {
// contains filtered or unexported fields
}
func (*ClearConversationsMsgResp) Descriptor
deprecated
func (*ClearConversationsMsgResp) Descriptor() ([]byte, []int)
Deprecated: Use ClearConversationsMsgResp.ProtoReflect.Descriptor instead.
func (*ClearConversationsMsgResp) ProtoMessage ¶
func (*ClearConversationsMsgResp) ProtoMessage()
func (*ClearConversationsMsgResp) ProtoReflect ¶
func (x *ClearConversationsMsgResp) ProtoReflect() protoreflect.Message
func (*ClearConversationsMsgResp) Reset ¶
func (x *ClearConversationsMsgResp) Reset()
func (*ClearConversationsMsgResp) String ¶
func (x *ClearConversationsMsgResp) String() string
type ClearMsgReq ¶ added in v0.0.65
type ClearMsgReq struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp"` // contains filtered or unexported fields }
func (*ClearMsgReq) Descriptor
deprecated
added in
v0.0.65
func (*ClearMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use ClearMsgReq.ProtoReflect.Descriptor instead.
func (*ClearMsgReq) GetTimestamp ¶ added in v0.0.65
func (x *ClearMsgReq) GetTimestamp() int64
func (*ClearMsgReq) ProtoMessage ¶ added in v0.0.65
func (*ClearMsgReq) ProtoMessage()
func (*ClearMsgReq) ProtoReflect ¶ added in v0.0.65
func (x *ClearMsgReq) ProtoReflect() protoreflect.Message
func (*ClearMsgReq) Reset ¶ added in v0.0.65
func (x *ClearMsgReq) Reset()
func (*ClearMsgReq) String ¶ added in v0.0.65
func (x *ClearMsgReq) String() string
type ClearMsgResp ¶ added in v0.0.65
type ClearMsgResp struct {
// contains filtered or unexported fields
}
func (*ClearMsgResp) Descriptor
deprecated
added in
v0.0.65
func (*ClearMsgResp) Descriptor() ([]byte, []int)
Deprecated: Use ClearMsgResp.ProtoReflect.Descriptor instead.
func (*ClearMsgResp) ProtoMessage ¶ added in v0.0.65
func (*ClearMsgResp) ProtoMessage()
func (*ClearMsgResp) ProtoReflect ¶ added in v0.0.65
func (x *ClearMsgResp) ProtoReflect() protoreflect.Message
func (*ClearMsgResp) Reset ¶ added in v0.0.65
func (x *ClearMsgResp) Reset()
func (*ClearMsgResp) String ¶ added in v0.0.65
func (x *ClearMsgResp) String() string
type DelMsgsReq ¶
type DelMsgsReq struct {
// contains filtered or unexported fields
}
func (*DelMsgsReq) Check ¶
func (x *DelMsgsReq) Check() error
func (*DelMsgsReq) Descriptor
deprecated
func (*DelMsgsReq) Descriptor() ([]byte, []int)
Deprecated: Use DelMsgsReq.ProtoReflect.Descriptor instead.
func (*DelMsgsReq) ProtoMessage ¶
func (*DelMsgsReq) ProtoMessage()
func (*DelMsgsReq) ProtoReflect ¶
func (x *DelMsgsReq) ProtoReflect() protoreflect.Message
func (*DelMsgsReq) Reset ¶
func (x *DelMsgsReq) Reset()
func (*DelMsgsReq) String ¶
func (x *DelMsgsReq) String() string
type DelMsgsResp ¶
type DelMsgsResp struct {
// contains filtered or unexported fields
}
func (*DelMsgsResp) Descriptor
deprecated
func (*DelMsgsResp) Descriptor() ([]byte, []int)
Deprecated: Use DelMsgsResp.ProtoReflect.Descriptor instead.
func (*DelMsgsResp) ProtoMessage ¶
func (*DelMsgsResp) ProtoMessage()
func (*DelMsgsResp) ProtoReflect ¶
func (x *DelMsgsResp) ProtoReflect() protoreflect.Message
func (*DelMsgsResp) Reset ¶
func (x *DelMsgsResp) Reset()
func (*DelMsgsResp) String ¶
func (x *DelMsgsResp) String() string
type DeleteMsgPhysicalBySeqReq ¶
type DeleteMsgPhysicalBySeqReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` Seqs []int64 `protobuf:"varint,2,rep,packed,name=seqs,proto3" json:"seqs"` // contains filtered or unexported fields }
func (*DeleteMsgPhysicalBySeqReq) Descriptor
deprecated
func (*DeleteMsgPhysicalBySeqReq) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMsgPhysicalBySeqReq.ProtoReflect.Descriptor instead.
func (*DeleteMsgPhysicalBySeqReq) GetConversationID ¶
func (x *DeleteMsgPhysicalBySeqReq) GetConversationID() string
func (*DeleteMsgPhysicalBySeqReq) GetSeqs ¶
func (x *DeleteMsgPhysicalBySeqReq) GetSeqs() []int64
func (*DeleteMsgPhysicalBySeqReq) ProtoMessage ¶
func (*DeleteMsgPhysicalBySeqReq) ProtoMessage()
func (*DeleteMsgPhysicalBySeqReq) ProtoReflect ¶
func (x *DeleteMsgPhysicalBySeqReq) ProtoReflect() protoreflect.Message
func (*DeleteMsgPhysicalBySeqReq) Reset ¶
func (x *DeleteMsgPhysicalBySeqReq) Reset()
func (*DeleteMsgPhysicalBySeqReq) String ¶
func (x *DeleteMsgPhysicalBySeqReq) String() string
type DeleteMsgPhysicalBySeqResp ¶
type DeleteMsgPhysicalBySeqResp struct {
// contains filtered or unexported fields
}
func (*DeleteMsgPhysicalBySeqResp) Descriptor
deprecated
func (*DeleteMsgPhysicalBySeqResp) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMsgPhysicalBySeqResp.ProtoReflect.Descriptor instead.
func (*DeleteMsgPhysicalBySeqResp) ProtoMessage ¶
func (*DeleteMsgPhysicalBySeqResp) ProtoMessage()
func (*DeleteMsgPhysicalBySeqResp) ProtoReflect ¶
func (x *DeleteMsgPhysicalBySeqResp) ProtoReflect() protoreflect.Message
func (*DeleteMsgPhysicalBySeqResp) Reset ¶
func (x *DeleteMsgPhysicalBySeqResp) Reset()
func (*DeleteMsgPhysicalBySeqResp) String ¶
func (x *DeleteMsgPhysicalBySeqResp) String() string
type DeleteMsgPhysicalReq ¶
type DeleteMsgPhysicalReq struct { ConversationIDs []string `protobuf:"bytes,1,rep,name=conversationIDs,proto3" json:"conversationIDs"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp"` // contains filtered or unexported fields }
func (*DeleteMsgPhysicalReq) Check ¶
func (x *DeleteMsgPhysicalReq) Check() error
func (*DeleteMsgPhysicalReq) Descriptor
deprecated
func (*DeleteMsgPhysicalReq) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMsgPhysicalReq.ProtoReflect.Descriptor instead.
func (*DeleteMsgPhysicalReq) GetConversationIDs ¶
func (x *DeleteMsgPhysicalReq) GetConversationIDs() []string
func (*DeleteMsgPhysicalReq) GetTimestamp ¶
func (x *DeleteMsgPhysicalReq) GetTimestamp() int64
func (*DeleteMsgPhysicalReq) ProtoMessage ¶
func (*DeleteMsgPhysicalReq) ProtoMessage()
func (*DeleteMsgPhysicalReq) ProtoReflect ¶
func (x *DeleteMsgPhysicalReq) ProtoReflect() protoreflect.Message
func (*DeleteMsgPhysicalReq) Reset ¶
func (x *DeleteMsgPhysicalReq) Reset()
func (*DeleteMsgPhysicalReq) String ¶
func (x *DeleteMsgPhysicalReq) String() string
type DeleteMsgPhysicalResp ¶
type DeleteMsgPhysicalResp struct {
// contains filtered or unexported fields
}
func (*DeleteMsgPhysicalResp) Descriptor
deprecated
func (*DeleteMsgPhysicalResp) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMsgPhysicalResp.ProtoReflect.Descriptor instead.
func (*DeleteMsgPhysicalResp) ProtoMessage ¶
func (*DeleteMsgPhysicalResp) ProtoMessage()
func (*DeleteMsgPhysicalResp) ProtoReflect ¶
func (x *DeleteMsgPhysicalResp) ProtoReflect() protoreflect.Message
func (*DeleteMsgPhysicalResp) Reset ¶
func (x *DeleteMsgPhysicalResp) Reset()
func (*DeleteMsgPhysicalResp) String ¶
func (x *DeleteMsgPhysicalResp) String() string
type DeleteMsgsReq ¶
type DeleteMsgsReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` Seqs []int64 `protobuf:"varint,2,rep,packed,name=seqs,proto3" json:"seqs"` UserID string `protobuf:"bytes,3,opt,name=userID,proto3" json:"userID"` DeleteSyncOpt *DeleteSyncOpt `protobuf:"bytes,4,opt,name=deleteSyncOpt,proto3" json:"deleteSyncOpt"` // contains filtered or unexported fields }
func (*DeleteMsgsReq) Check ¶
func (x *DeleteMsgsReq) Check() error
func (*DeleteMsgsReq) Descriptor
deprecated
func (*DeleteMsgsReq) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMsgsReq.ProtoReflect.Descriptor instead.
func (*DeleteMsgsReq) GetConversationID ¶
func (x *DeleteMsgsReq) GetConversationID() string
func (*DeleteMsgsReq) GetDeleteSyncOpt ¶
func (x *DeleteMsgsReq) GetDeleteSyncOpt() *DeleteSyncOpt
func (*DeleteMsgsReq) GetSeqs ¶
func (x *DeleteMsgsReq) GetSeqs() []int64
func (*DeleteMsgsReq) GetUserID ¶
func (x *DeleteMsgsReq) GetUserID() string
func (*DeleteMsgsReq) ProtoMessage ¶
func (*DeleteMsgsReq) ProtoMessage()
func (*DeleteMsgsReq) ProtoReflect ¶
func (x *DeleteMsgsReq) ProtoReflect() protoreflect.Message
func (*DeleteMsgsReq) Reset ¶
func (x *DeleteMsgsReq) Reset()
func (*DeleteMsgsReq) String ¶
func (x *DeleteMsgsReq) String() string
type DeleteMsgsResp ¶
type DeleteMsgsResp struct {
// contains filtered or unexported fields
}
func (*DeleteMsgsResp) Descriptor
deprecated
func (*DeleteMsgsResp) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMsgsResp.ProtoReflect.Descriptor instead.
func (*DeleteMsgsResp) ProtoMessage ¶
func (*DeleteMsgsResp) ProtoMessage()
func (*DeleteMsgsResp) ProtoReflect ¶
func (x *DeleteMsgsResp) ProtoReflect() protoreflect.Message
func (*DeleteMsgsResp) Reset ¶
func (x *DeleteMsgsResp) Reset()
func (*DeleteMsgsResp) String ¶
func (x *DeleteMsgsResp) String() string
type DeleteSyncOpt ¶
type DeleteSyncOpt struct { IsSyncSelf bool `protobuf:"varint,3,opt,name=IsSyncSelf,proto3" json:"IsSyncSelf"` IsSyncOther bool `protobuf:"varint,4,opt,name=IsSyncOther,proto3" json:"IsSyncOther"` // contains filtered or unexported fields }
func (*DeleteSyncOpt) Descriptor
deprecated
func (*DeleteSyncOpt) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSyncOpt.ProtoReflect.Descriptor instead.
func (*DeleteSyncOpt) GetIsSyncOther ¶
func (x *DeleteSyncOpt) GetIsSyncOther() bool
func (*DeleteSyncOpt) GetIsSyncSelf ¶
func (x *DeleteSyncOpt) GetIsSyncSelf() bool
func (*DeleteSyncOpt) ProtoMessage ¶
func (*DeleteSyncOpt) ProtoMessage()
func (*DeleteSyncOpt) ProtoReflect ¶
func (x *DeleteSyncOpt) ProtoReflect() protoreflect.Message
func (*DeleteSyncOpt) Reset ¶
func (x *DeleteSyncOpt) Reset()
func (*DeleteSyncOpt) String ¶
func (x *DeleteSyncOpt) String() string
type GetActiveGroupReq ¶
type GetActiveGroupReq struct { Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start"` End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end"` Ase bool `protobuf:"varint,3,opt,name=ase,proto3" json:"ase"` Pagination *sdkws.RequestPagination `protobuf:"bytes,4,opt,name=pagination,proto3" json:"pagination"` // contains filtered or unexported fields }
func (*GetActiveGroupReq) Descriptor
deprecated
func (*GetActiveGroupReq) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveGroupReq.ProtoReflect.Descriptor instead.
func (*GetActiveGroupReq) GetAse ¶
func (x *GetActiveGroupReq) GetAse() bool
func (*GetActiveGroupReq) GetEnd ¶
func (x *GetActiveGroupReq) GetEnd() int64
func (*GetActiveGroupReq) GetPagination ¶
func (x *GetActiveGroupReq) GetPagination() *sdkws.RequestPagination
func (*GetActiveGroupReq) GetStart ¶
func (x *GetActiveGroupReq) GetStart() int64
func (*GetActiveGroupReq) ProtoMessage ¶
func (*GetActiveGroupReq) ProtoMessage()
func (*GetActiveGroupReq) ProtoReflect ¶
func (x *GetActiveGroupReq) ProtoReflect() protoreflect.Message
func (*GetActiveGroupReq) Reset ¶
func (x *GetActiveGroupReq) Reset()
func (*GetActiveGroupReq) String ¶
func (x *GetActiveGroupReq) String() string
type GetActiveGroupResp ¶
type GetActiveGroupResp struct { MsgCount int64 `protobuf:"varint,1,opt,name=msgCount,proto3" json:"msgCount"` GroupCount int64 `protobuf:"varint,2,opt,name=groupCount,proto3" json:"groupCount"` DateCount map[string]int64 `` /* 160-byte string literal not displayed */ Groups []*ActiveGroup `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups"` // contains filtered or unexported fields }
func (*GetActiveGroupResp) Descriptor
deprecated
func (*GetActiveGroupResp) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveGroupResp.ProtoReflect.Descriptor instead.
func (*GetActiveGroupResp) GetDateCount ¶
func (x *GetActiveGroupResp) GetDateCount() map[string]int64
func (*GetActiveGroupResp) GetGroupCount ¶
func (x *GetActiveGroupResp) GetGroupCount() int64
func (*GetActiveGroupResp) GetGroups ¶
func (x *GetActiveGroupResp) GetGroups() []*ActiveGroup
func (*GetActiveGroupResp) GetMsgCount ¶
func (x *GetActiveGroupResp) GetMsgCount() int64
func (*GetActiveGroupResp) ProtoMessage ¶
func (*GetActiveGroupResp) ProtoMessage()
func (*GetActiveGroupResp) ProtoReflect ¶
func (x *GetActiveGroupResp) ProtoReflect() protoreflect.Message
func (*GetActiveGroupResp) Reset ¶
func (x *GetActiveGroupResp) Reset()
func (*GetActiveGroupResp) String ¶
func (x *GetActiveGroupResp) String() string
type GetActiveUserReq ¶
type GetActiveUserReq struct { Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start"` End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end"` Ase bool `protobuf:"varint,3,opt,name=ase,proto3" json:"ase"` Group bool `protobuf:"varint,4,opt,name=group,proto3" json:"group"` Pagination *sdkws.RequestPagination `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination"` // contains filtered or unexported fields }
func (*GetActiveUserReq) Descriptor
deprecated
func (*GetActiveUserReq) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveUserReq.ProtoReflect.Descriptor instead.
func (*GetActiveUserReq) GetAse ¶
func (x *GetActiveUserReq) GetAse() bool
func (*GetActiveUserReq) GetEnd ¶
func (x *GetActiveUserReq) GetEnd() int64
func (*GetActiveUserReq) GetGroup ¶
func (x *GetActiveUserReq) GetGroup() bool
func (*GetActiveUserReq) GetPagination ¶
func (x *GetActiveUserReq) GetPagination() *sdkws.RequestPagination
func (*GetActiveUserReq) GetStart ¶
func (x *GetActiveUserReq) GetStart() int64
func (*GetActiveUserReq) ProtoMessage ¶
func (*GetActiveUserReq) ProtoMessage()
func (*GetActiveUserReq) ProtoReflect ¶
func (x *GetActiveUserReq) ProtoReflect() protoreflect.Message
func (*GetActiveUserReq) Reset ¶
func (x *GetActiveUserReq) Reset()
func (*GetActiveUserReq) String ¶
func (x *GetActiveUserReq) String() string
type GetActiveUserResp ¶
type GetActiveUserResp struct { MsgCount int64 `protobuf:"varint,1,opt,name=msgCount,proto3" json:"msgCount"` UserCount int64 `protobuf:"varint,2,opt,name=userCount,proto3" json:"userCount"` DateCount map[string]int64 `` /* 160-byte string literal not displayed */ Users []*ActiveUser `protobuf:"bytes,4,rep,name=users,proto3" json:"users"` // contains filtered or unexported fields }
func (*GetActiveUserResp) Descriptor
deprecated
func (*GetActiveUserResp) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveUserResp.ProtoReflect.Descriptor instead.
func (*GetActiveUserResp) GetDateCount ¶
func (x *GetActiveUserResp) GetDateCount() map[string]int64
func (*GetActiveUserResp) GetMsgCount ¶
func (x *GetActiveUserResp) GetMsgCount() int64
func (*GetActiveUserResp) GetUserCount ¶
func (x *GetActiveUserResp) GetUserCount() int64
func (*GetActiveUserResp) GetUsers ¶
func (x *GetActiveUserResp) GetUsers() []*ActiveUser
func (*GetActiveUserResp) ProtoMessage ¶
func (*GetActiveUserResp) ProtoMessage()
func (*GetActiveUserResp) ProtoReflect ¶
func (x *GetActiveUserResp) ProtoReflect() protoreflect.Message
func (*GetActiveUserResp) Reset ¶
func (x *GetActiveUserResp) Reset()
func (*GetActiveUserResp) String ¶
func (x *GetActiveUserResp) String() string
type GetConversationMaxSeqReq ¶
type GetConversationMaxSeqReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` // contains filtered or unexported fields }
func (*GetConversationMaxSeqReq) Check ¶
func (x *GetConversationMaxSeqReq) Check() error
func (*GetConversationMaxSeqReq) Descriptor
deprecated
func (*GetConversationMaxSeqReq) Descriptor() ([]byte, []int)
Deprecated: Use GetConversationMaxSeqReq.ProtoReflect.Descriptor instead.
func (*GetConversationMaxSeqReq) GetConversationID ¶
func (x *GetConversationMaxSeqReq) GetConversationID() string
func (*GetConversationMaxSeqReq) ProtoMessage ¶
func (*GetConversationMaxSeqReq) ProtoMessage()
func (*GetConversationMaxSeqReq) ProtoReflect ¶
func (x *GetConversationMaxSeqReq) ProtoReflect() protoreflect.Message
func (*GetConversationMaxSeqReq) Reset ¶
func (x *GetConversationMaxSeqReq) Reset()
func (*GetConversationMaxSeqReq) String ¶
func (x *GetConversationMaxSeqReq) String() string
type GetConversationMaxSeqResp ¶
type GetConversationMaxSeqResp struct { MaxSeq int64 `protobuf:"varint,1,opt,name=maxSeq,proto3" json:"maxSeq"` // contains filtered or unexported fields }
func (*GetConversationMaxSeqResp) Descriptor
deprecated
func (*GetConversationMaxSeqResp) Descriptor() ([]byte, []int)
Deprecated: Use GetConversationMaxSeqResp.ProtoReflect.Descriptor instead.
func (*GetConversationMaxSeqResp) GetMaxSeq ¶
func (x *GetConversationMaxSeqResp) GetMaxSeq() int64
func (*GetConversationMaxSeqResp) ProtoMessage ¶
func (*GetConversationMaxSeqResp) ProtoMessage()
func (*GetConversationMaxSeqResp) ProtoReflect ¶
func (x *GetConversationMaxSeqResp) ProtoReflect() protoreflect.Message
func (*GetConversationMaxSeqResp) Reset ¶
func (x *GetConversationMaxSeqResp) Reset()
func (*GetConversationMaxSeqResp) String ¶
func (x *GetConversationMaxSeqResp) String() string
type GetConversationsHasReadAndMaxSeqReq ¶
type GetConversationsHasReadAndMaxSeqReq struct { UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"` ConversationIDs []string `protobuf:"bytes,2,rep,name=conversationIDs,proto3" json:"conversationIDs"` // contains filtered or unexported fields }
func (*GetConversationsHasReadAndMaxSeqReq) Check ¶
func (x *GetConversationsHasReadAndMaxSeqReq) Check() error
func (*GetConversationsHasReadAndMaxSeqReq) Descriptor
deprecated
func (*GetConversationsHasReadAndMaxSeqReq) Descriptor() ([]byte, []int)
Deprecated: Use GetConversationsHasReadAndMaxSeqReq.ProtoReflect.Descriptor instead.
func (*GetConversationsHasReadAndMaxSeqReq) GetConversationIDs ¶
func (x *GetConversationsHasReadAndMaxSeqReq) GetConversationIDs() []string
func (*GetConversationsHasReadAndMaxSeqReq) GetUserID ¶
func (x *GetConversationsHasReadAndMaxSeqReq) GetUserID() string
func (*GetConversationsHasReadAndMaxSeqReq) ProtoMessage ¶
func (*GetConversationsHasReadAndMaxSeqReq) ProtoMessage()
func (*GetConversationsHasReadAndMaxSeqReq) ProtoReflect ¶
func (x *GetConversationsHasReadAndMaxSeqReq) ProtoReflect() protoreflect.Message
func (*GetConversationsHasReadAndMaxSeqReq) Reset ¶
func (x *GetConversationsHasReadAndMaxSeqReq) Reset()
func (*GetConversationsHasReadAndMaxSeqReq) String ¶
func (x *GetConversationsHasReadAndMaxSeqReq) String() string
type GetConversationsHasReadAndMaxSeqResp ¶
type GetConversationsHasReadAndMaxSeqResp struct { Seqs map[string]*Seqs `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetConversationsHasReadAndMaxSeqResp) Descriptor
deprecated
func (*GetConversationsHasReadAndMaxSeqResp) Descriptor() ([]byte, []int)
Deprecated: Use GetConversationsHasReadAndMaxSeqResp.ProtoReflect.Descriptor instead.
func (*GetConversationsHasReadAndMaxSeqResp) GetSeqs ¶
func (x *GetConversationsHasReadAndMaxSeqResp) GetSeqs() map[string]*Seqs
func (*GetConversationsHasReadAndMaxSeqResp) ProtoMessage ¶
func (*GetConversationsHasReadAndMaxSeqResp) ProtoMessage()
func (*GetConversationsHasReadAndMaxSeqResp) ProtoReflect ¶
func (x *GetConversationsHasReadAndMaxSeqResp) ProtoReflect() protoreflect.Message
func (*GetConversationsHasReadAndMaxSeqResp) Reset ¶
func (x *GetConversationsHasReadAndMaxSeqResp) Reset()
func (*GetConversationsHasReadAndMaxSeqResp) String ¶
func (x *GetConversationsHasReadAndMaxSeqResp) String() string
type GetHasReadSeqsReq ¶
type GetHasReadSeqsReq struct { UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"` ConversationIDs []string `protobuf:"bytes,2,rep,name=conversationIDs,proto3" json:"conversationIDs"` // contains filtered or unexported fields }
func (*GetHasReadSeqsReq) Descriptor
deprecated
func (*GetHasReadSeqsReq) Descriptor() ([]byte, []int)
Deprecated: Use GetHasReadSeqsReq.ProtoReflect.Descriptor instead.
func (*GetHasReadSeqsReq) GetConversationIDs ¶
func (x *GetHasReadSeqsReq) GetConversationIDs() []string
func (*GetHasReadSeqsReq) GetUserID ¶
func (x *GetHasReadSeqsReq) GetUserID() string
func (*GetHasReadSeqsReq) ProtoMessage ¶
func (*GetHasReadSeqsReq) ProtoMessage()
func (*GetHasReadSeqsReq) ProtoReflect ¶
func (x *GetHasReadSeqsReq) ProtoReflect() protoreflect.Message
func (*GetHasReadSeqsReq) Reset ¶
func (x *GetHasReadSeqsReq) Reset()
func (*GetHasReadSeqsReq) String ¶
func (x *GetHasReadSeqsReq) String() string
type GetMaxAndMinSeqReq ¶
type GetMaxAndMinSeqReq struct { UserID string `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID"` // contains filtered or unexported fields }
func (*GetMaxAndMinSeqReq) Check ¶
func (x *GetMaxAndMinSeqReq) Check() error
func (*GetMaxAndMinSeqReq) Descriptor
deprecated
func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int)
Deprecated: Use GetMaxAndMinSeqReq.ProtoReflect.Descriptor instead.
func (*GetMaxAndMinSeqReq) GetUserID ¶
func (x *GetMaxAndMinSeqReq) GetUserID() string
func (*GetMaxAndMinSeqReq) ProtoMessage ¶
func (*GetMaxAndMinSeqReq) ProtoMessage()
func (*GetMaxAndMinSeqReq) ProtoReflect ¶
func (x *GetMaxAndMinSeqReq) ProtoReflect() protoreflect.Message
func (*GetMaxAndMinSeqReq) Reset ¶
func (x *GetMaxAndMinSeqReq) Reset()
func (*GetMaxAndMinSeqReq) String ¶
func (x *GetMaxAndMinSeqReq) String() string
type GetMaxAndMinSeqResp ¶
type GetMaxAndMinSeqResp struct { MaxSeq int64 `protobuf:"varint,1,opt,name=MaxSeq,proto3" json:"MaxSeq"` MinSeq int64 `protobuf:"varint,2,opt,name=MinSeq,proto3" json:"MinSeq"` // contains filtered or unexported fields }
func (*GetMaxAndMinSeqResp) Descriptor
deprecated
func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int)
Deprecated: Use GetMaxAndMinSeqResp.ProtoReflect.Descriptor instead.
func (*GetMaxAndMinSeqResp) GetMaxSeq ¶
func (x *GetMaxAndMinSeqResp) GetMaxSeq() int64
func (*GetMaxAndMinSeqResp) GetMinSeq ¶
func (x *GetMaxAndMinSeqResp) GetMinSeq() int64
func (*GetMaxAndMinSeqResp) ProtoMessage ¶
func (*GetMaxAndMinSeqResp) ProtoMessage()
func (*GetMaxAndMinSeqResp) ProtoReflect ¶
func (x *GetMaxAndMinSeqResp) ProtoReflect() protoreflect.Message
func (*GetMaxAndMinSeqResp) Reset ¶
func (x *GetMaxAndMinSeqResp) Reset()
func (*GetMaxAndMinSeqResp) String ¶
func (x *GetMaxAndMinSeqResp) String() string
type GetMaxSeqsReq ¶
type GetMaxSeqsReq struct { ConversationIDs []string `protobuf:"bytes,2,rep,name=conversationIDs,proto3" json:"conversationIDs"` // contains filtered or unexported fields }
func (*GetMaxSeqsReq) Descriptor
deprecated
func (*GetMaxSeqsReq) Descriptor() ([]byte, []int)
Deprecated: Use GetMaxSeqsReq.ProtoReflect.Descriptor instead.
func (*GetMaxSeqsReq) GetConversationIDs ¶
func (x *GetMaxSeqsReq) GetConversationIDs() []string
func (*GetMaxSeqsReq) ProtoMessage ¶
func (*GetMaxSeqsReq) ProtoMessage()
func (*GetMaxSeqsReq) ProtoReflect ¶
func (x *GetMaxSeqsReq) ProtoReflect() protoreflect.Message
func (*GetMaxSeqsReq) Reset ¶
func (x *GetMaxSeqsReq) Reset()
func (*GetMaxSeqsReq) String ¶
func (x *GetMaxSeqsReq) String() string
type GetMsgByConversationIDsReq ¶
type GetMsgByConversationIDsReq struct { ConversationIDs []string `protobuf:"bytes,1,rep,name=conversationIDs,proto3" json:"conversationIDs"` MaxSeqs map[string]int64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetMsgByConversationIDsReq) Descriptor
deprecated
func (*GetMsgByConversationIDsReq) Descriptor() ([]byte, []int)
Deprecated: Use GetMsgByConversationIDsReq.ProtoReflect.Descriptor instead.
func (*GetMsgByConversationIDsReq) GetConversationIDs ¶
func (x *GetMsgByConversationIDsReq) GetConversationIDs() []string
func (*GetMsgByConversationIDsReq) GetMaxSeqs ¶
func (x *GetMsgByConversationIDsReq) GetMaxSeqs() map[string]int64
func (*GetMsgByConversationIDsReq) ProtoMessage ¶
func (*GetMsgByConversationIDsReq) ProtoMessage()
func (*GetMsgByConversationIDsReq) ProtoReflect ¶
func (x *GetMsgByConversationIDsReq) ProtoReflect() protoreflect.Message
func (*GetMsgByConversationIDsReq) Reset ¶
func (x *GetMsgByConversationIDsReq) Reset()
func (*GetMsgByConversationIDsReq) String ¶
func (x *GetMsgByConversationIDsReq) String() string
type GetMsgByConversationIDsResp ¶
type GetMsgByConversationIDsResp struct { MsgDatas map[string]*sdkws.MsgData `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetMsgByConversationIDsResp) Descriptor
deprecated
func (*GetMsgByConversationIDsResp) Descriptor() ([]byte, []int)
Deprecated: Use GetMsgByConversationIDsResp.ProtoReflect.Descriptor instead.
func (*GetMsgByConversationIDsResp) GetMsgDatas ¶
func (x *GetMsgByConversationIDsResp) GetMsgDatas() map[string]*sdkws.MsgData
func (*GetMsgByConversationIDsResp) ProtoMessage ¶
func (*GetMsgByConversationIDsResp) ProtoMessage()
func (*GetMsgByConversationIDsResp) ProtoReflect ¶
func (x *GetMsgByConversationIDsResp) ProtoReflect() protoreflect.Message
func (*GetMsgByConversationIDsResp) Reset ¶
func (x *GetMsgByConversationIDsResp) Reset()
func (*GetMsgByConversationIDsResp) String ¶
func (x *GetMsgByConversationIDsResp) String() string
type GetSendMsgStatusReq ¶
type GetSendMsgStatusReq struct {
// contains filtered or unexported fields
}
func (*GetSendMsgStatusReq) Check ¶
func (x *GetSendMsgStatusReq) Check() error
func (*GetSendMsgStatusReq) Descriptor
deprecated
func (*GetSendMsgStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use GetSendMsgStatusReq.ProtoReflect.Descriptor instead.
func (*GetSendMsgStatusReq) ProtoMessage ¶
func (*GetSendMsgStatusReq) ProtoMessage()
func (*GetSendMsgStatusReq) ProtoReflect ¶
func (x *GetSendMsgStatusReq) ProtoReflect() protoreflect.Message
func (*GetSendMsgStatusReq) Reset ¶
func (x *GetSendMsgStatusReq) Reset()
func (*GetSendMsgStatusReq) String ¶
func (x *GetSendMsgStatusReq) String() string
type GetSendMsgStatusResp ¶
type GetSendMsgStatusResp struct { Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status"` // contains filtered or unexported fields }
func (*GetSendMsgStatusResp) Descriptor
deprecated
func (*GetSendMsgStatusResp) Descriptor() ([]byte, []int)
Deprecated: Use GetSendMsgStatusResp.ProtoReflect.Descriptor instead.
func (*GetSendMsgStatusResp) GetStatus ¶
func (x *GetSendMsgStatusResp) GetStatus() int32
func (*GetSendMsgStatusResp) ProtoMessage ¶
func (*GetSendMsgStatusResp) ProtoMessage()
func (*GetSendMsgStatusResp) ProtoReflect ¶
func (x *GetSendMsgStatusResp) ProtoReflect() protoreflect.Message
func (*GetSendMsgStatusResp) Reset ¶
func (x *GetSendMsgStatusResp) Reset()
func (*GetSendMsgStatusResp) String ¶
func (x *GetSendMsgStatusResp) String() string
type GetServerTimeReq ¶
type GetServerTimeReq struct {
// contains filtered or unexported fields
}
func (*GetServerTimeReq) Descriptor
deprecated
func (*GetServerTimeReq) Descriptor() ([]byte, []int)
Deprecated: Use GetServerTimeReq.ProtoReflect.Descriptor instead.
func (*GetServerTimeReq) ProtoMessage ¶
func (*GetServerTimeReq) ProtoMessage()
func (*GetServerTimeReq) ProtoReflect ¶
func (x *GetServerTimeReq) ProtoReflect() protoreflect.Message
func (*GetServerTimeReq) Reset ¶
func (x *GetServerTimeReq) Reset()
func (*GetServerTimeReq) String ¶
func (x *GetServerTimeReq) String() string
type GetServerTimeResp ¶
type GetServerTimeResp struct { ServerTime int64 `protobuf:"varint,1,opt,name=serverTime,proto3" json:"serverTime"` // contains filtered or unexported fields }
func (*GetServerTimeResp) Descriptor
deprecated
func (*GetServerTimeResp) Descriptor() ([]byte, []int)
Deprecated: Use GetServerTimeResp.ProtoReflect.Descriptor instead.
func (*GetServerTimeResp) GetServerTime ¶
func (x *GetServerTimeResp) GetServerTime() int64
func (*GetServerTimeResp) ProtoMessage ¶
func (*GetServerTimeResp) ProtoMessage()
func (*GetServerTimeResp) ProtoReflect ¶
func (x *GetServerTimeResp) ProtoReflect() protoreflect.Message
func (*GetServerTimeResp) Reset ¶
func (x *GetServerTimeResp) Reset()
func (*GetServerTimeResp) String ¶
func (x *GetServerTimeResp) String() string
type MarkConversationAsReadReq ¶
type MarkConversationAsReadReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` UserID string `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID"` HasReadSeq int64 `protobuf:"varint,3,opt,name=hasReadSeq,proto3" json:"hasReadSeq"` Seqs []int64 `protobuf:"varint,4,rep,packed,name=seqs,proto3" json:"seqs"` // contains filtered or unexported fields }
func (*MarkConversationAsReadReq) Check ¶
func (x *MarkConversationAsReadReq) Check() error
func (*MarkConversationAsReadReq) Descriptor
deprecated
func (*MarkConversationAsReadReq) Descriptor() ([]byte, []int)
Deprecated: Use MarkConversationAsReadReq.ProtoReflect.Descriptor instead.
func (*MarkConversationAsReadReq) GetConversationID ¶
func (x *MarkConversationAsReadReq) GetConversationID() string
func (*MarkConversationAsReadReq) GetHasReadSeq ¶
func (x *MarkConversationAsReadReq) GetHasReadSeq() int64
func (*MarkConversationAsReadReq) GetSeqs ¶
func (x *MarkConversationAsReadReq) GetSeqs() []int64
func (*MarkConversationAsReadReq) GetUserID ¶
func (x *MarkConversationAsReadReq) GetUserID() string
func (*MarkConversationAsReadReq) ProtoMessage ¶
func (*MarkConversationAsReadReq) ProtoMessage()
func (*MarkConversationAsReadReq) ProtoReflect ¶
func (x *MarkConversationAsReadReq) ProtoReflect() protoreflect.Message
func (*MarkConversationAsReadReq) Reset ¶
func (x *MarkConversationAsReadReq) Reset()
func (*MarkConversationAsReadReq) String ¶
func (x *MarkConversationAsReadReq) String() string
type MarkConversationAsReadResp ¶
type MarkConversationAsReadResp struct {
// contains filtered or unexported fields
}
func (*MarkConversationAsReadResp) Descriptor
deprecated
func (*MarkConversationAsReadResp) Descriptor() ([]byte, []int)
Deprecated: Use MarkConversationAsReadResp.ProtoReflect.Descriptor instead.
func (*MarkConversationAsReadResp) ProtoMessage ¶
func (*MarkConversationAsReadResp) ProtoMessage()
func (*MarkConversationAsReadResp) ProtoReflect ¶
func (x *MarkConversationAsReadResp) ProtoReflect() protoreflect.Message
func (*MarkConversationAsReadResp) Reset ¶
func (x *MarkConversationAsReadResp) Reset()
func (*MarkConversationAsReadResp) String ¶
func (x *MarkConversationAsReadResp) String() string
type MarkMsgsAsReadReq ¶
type MarkMsgsAsReadReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` Seqs []int64 `protobuf:"varint,2,rep,packed,name=seqs,proto3" json:"seqs"` UserID string `protobuf:"bytes,3,opt,name=userID,proto3" json:"userID"` // contains filtered or unexported fields }
func (*MarkMsgsAsReadReq) Check ¶
func (x *MarkMsgsAsReadReq) Check() error
func (*MarkMsgsAsReadReq) Descriptor
deprecated
func (*MarkMsgsAsReadReq) Descriptor() ([]byte, []int)
Deprecated: Use MarkMsgsAsReadReq.ProtoReflect.Descriptor instead.
func (*MarkMsgsAsReadReq) GetConversationID ¶
func (x *MarkMsgsAsReadReq) GetConversationID() string
func (*MarkMsgsAsReadReq) GetSeqs ¶
func (x *MarkMsgsAsReadReq) GetSeqs() []int64
func (*MarkMsgsAsReadReq) GetUserID ¶
func (x *MarkMsgsAsReadReq) GetUserID() string
func (*MarkMsgsAsReadReq) ProtoMessage ¶
func (*MarkMsgsAsReadReq) ProtoMessage()
func (*MarkMsgsAsReadReq) ProtoReflect ¶
func (x *MarkMsgsAsReadReq) ProtoReflect() protoreflect.Message
func (*MarkMsgsAsReadReq) Reset ¶
func (x *MarkMsgsAsReadReq) Reset()
func (*MarkMsgsAsReadReq) String ¶
func (x *MarkMsgsAsReadReq) String() string
type MarkMsgsAsReadResp ¶
type MarkMsgsAsReadResp struct {
// contains filtered or unexported fields
}
func (*MarkMsgsAsReadResp) Descriptor
deprecated
func (*MarkMsgsAsReadResp) Descriptor() ([]byte, []int)
Deprecated: Use MarkMsgsAsReadResp.ProtoReflect.Descriptor instead.
func (*MarkMsgsAsReadResp) ProtoMessage ¶
func (*MarkMsgsAsReadResp) ProtoMessage()
func (*MarkMsgsAsReadResp) ProtoReflect ¶
func (x *MarkMsgsAsReadResp) ProtoReflect() protoreflect.Message
func (*MarkMsgsAsReadResp) Reset ¶
func (x *MarkMsgsAsReadResp) Reset()
func (*MarkMsgsAsReadResp) String ¶
func (x *MarkMsgsAsReadResp) String() string
type MsgClient ¶
type MsgClient interface { // 获取最小最大seq(包括用户的,以及指定群组的) GetMaxSeq(ctx context.Context, in *sdkws.GetMaxSeqReq, opts ...grpc.CallOption) (*sdkws.GetMaxSeqResp, error) // 获取会话列表的最大seq GetMaxSeqs(ctx context.Context, in *GetMaxSeqsReq, opts ...grpc.CallOption) (*SeqsInfoResp, error) // 获取会话列表已读的最大seq GetHasReadSeqs(ctx context.Context, in *GetHasReadSeqsReq, opts ...grpc.CallOption) (*SeqsInfoResp, error) // 获取最新消息 GetMsgByConversationIDs(ctx context.Context, in *GetMsgByConversationIDsReq, opts ...grpc.CallOption) (*GetMsgByConversationIDsResp, error) GetConversationMaxSeq(ctx context.Context, in *GetConversationMaxSeqReq, opts ...grpc.CallOption) (*GetConversationMaxSeqResp, error) // 拉取历史消息(包括用户的,以及指定群组的) PullMessageBySeqs(ctx context.Context, in *sdkws.PullMessageBySeqsReq, opts ...grpc.CallOption) (*sdkws.PullMessageBySeqsResp, error) SearchMessage(ctx context.Context, in *SearchMessageReq, opts ...grpc.CallOption) (*SearchMessageResp, error) // 发送消息 SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error) // 全量清空指定会话消息 重置min seq 比最大seq大1 ClearConversationsMsg(ctx context.Context, in *ClearConversationsMsgReq, opts ...grpc.CallOption) (*ClearConversationsMsgResp, error) // 删除用户全部消息 重置min seq 比最大seq大1 UserClearAllMsg(ctx context.Context, in *UserClearAllMsgReq, opts ...grpc.CallOption) (*UserClearAllMsgResp, error) // 用户标记删除部分消息by Seq DeleteMsgs(ctx context.Context, in *DeleteMsgsReq, opts ...grpc.CallOption) (*DeleteMsgsResp, error) // seq物理删除消息 DeleteMsgPhysicalBySeq(ctx context.Context, in *DeleteMsgPhysicalBySeqReq, opts ...grpc.CallOption) (*DeleteMsgPhysicalBySeqResp, error) // 物理删除消息by 时间 DeleteMsgPhysical(ctx context.Context, in *DeleteMsgPhysicalReq, opts ...grpc.CallOption) (*DeleteMsgPhysicalResp, error) // 设置消息是否发送成功-针对api发送的消息 SetSendMsgStatus(ctx context.Context, in *SetSendMsgStatusReq, opts ...grpc.CallOption) (*SetSendMsgStatusResp, error) // 获取消息发送状态 GetSendMsgStatus(ctx context.Context, in *GetSendMsgStatusReq, opts ...grpc.CallOption) (*GetSendMsgStatusResp, error) RevokeMsg(ctx context.Context, in *RevokeMsgReq, opts ...grpc.CallOption) (*RevokeMsgResp, error) // mark as read MarkMsgsAsRead(ctx context.Context, in *MarkMsgsAsReadReq, opts ...grpc.CallOption) (*MarkMsgsAsReadResp, error) MarkConversationAsRead(ctx context.Context, in *MarkConversationAsReadReq, opts ...grpc.CallOption) (*MarkConversationAsReadResp, error) SetConversationHasReadSeq(ctx context.Context, in *SetConversationHasReadSeqReq, opts ...grpc.CallOption) (*SetConversationHasReadSeqResp, error) GetConversationsHasReadAndMaxSeq(ctx context.Context, in *GetConversationsHasReadAndMaxSeqReq, opts ...grpc.CallOption) (*GetConversationsHasReadAndMaxSeqResp, error) GetActiveUser(ctx context.Context, in *GetActiveUserReq, opts ...grpc.CallOption) (*GetActiveUserResp, error) GetActiveGroup(ctx context.Context, in *GetActiveGroupReq, opts ...grpc.CallOption) (*GetActiveGroupResp, error) GetServerTime(ctx context.Context, in *GetServerTimeReq, opts ...grpc.CallOption) (*GetServerTimeResp, error) ClearMsg(ctx context.Context, in *ClearMsgReq, opts ...grpc.CallOption) (*ClearMsgResp, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc.ClientConnInterface) MsgClient
type MsgDataToDB ¶
type MsgDataToDB struct { MsgData *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData,proto3" json:"msgData"` // contains filtered or unexported fields }
func (*MsgDataToDB) Descriptor
deprecated
func (*MsgDataToDB) Descriptor() ([]byte, []int)
Deprecated: Use MsgDataToDB.ProtoReflect.Descriptor instead.
func (*MsgDataToDB) GetMsgData ¶
func (x *MsgDataToDB) GetMsgData() *sdkws.MsgData
func (*MsgDataToDB) ProtoMessage ¶
func (*MsgDataToDB) ProtoMessage()
func (*MsgDataToDB) ProtoReflect ¶
func (x *MsgDataToDB) ProtoReflect() protoreflect.Message
func (*MsgDataToDB) Reset ¶
func (x *MsgDataToDB) Reset()
func (*MsgDataToDB) String ¶
func (x *MsgDataToDB) String() string
type MsgDataToMQ ¶
type MsgDataToMQ struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token"` MsgData *sdkws.MsgData `protobuf:"bytes,2,opt,name=msgData,proto3" json:"msgData"` // contains filtered or unexported fields }
func (*MsgDataToMQ) Descriptor
deprecated
func (*MsgDataToMQ) Descriptor() ([]byte, []int)
Deprecated: Use MsgDataToMQ.ProtoReflect.Descriptor instead.
func (*MsgDataToMQ) GetMsgData ¶
func (x *MsgDataToMQ) GetMsgData() *sdkws.MsgData
func (*MsgDataToMQ) GetToken ¶
func (x *MsgDataToMQ) GetToken() string
func (*MsgDataToMQ) ProtoMessage ¶
func (*MsgDataToMQ) ProtoMessage()
func (*MsgDataToMQ) ProtoReflect ¶
func (x *MsgDataToMQ) ProtoReflect() protoreflect.Message
func (*MsgDataToMQ) Reset ¶
func (x *MsgDataToMQ) Reset()
func (*MsgDataToMQ) String ¶
func (x *MsgDataToMQ) String() string
type MsgDataToModifyByMQ ¶
type MsgDataToModifyByMQ struct { Messages []*sdkws.MsgData `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages"` ConversationID string `protobuf:"bytes,2,opt,name=conversationID,proto3" json:"conversationID"` // contains filtered or unexported fields }
func (*MsgDataToModifyByMQ) Descriptor
deprecated
func (*MsgDataToModifyByMQ) Descriptor() ([]byte, []int)
Deprecated: Use MsgDataToModifyByMQ.ProtoReflect.Descriptor instead.
func (*MsgDataToModifyByMQ) GetConversationID ¶
func (x *MsgDataToModifyByMQ) GetConversationID() string
func (*MsgDataToModifyByMQ) GetMessages ¶
func (x *MsgDataToModifyByMQ) GetMessages() []*sdkws.MsgData
func (*MsgDataToModifyByMQ) ProtoMessage ¶
func (*MsgDataToModifyByMQ) ProtoMessage()
func (*MsgDataToModifyByMQ) ProtoReflect ¶
func (x *MsgDataToModifyByMQ) ProtoReflect() protoreflect.Message
func (*MsgDataToModifyByMQ) Reset ¶
func (x *MsgDataToModifyByMQ) Reset()
func (*MsgDataToModifyByMQ) String ¶
func (x *MsgDataToModifyByMQ) String() string
type MsgDataToMongoByMQ ¶
type MsgDataToMongoByMQ struct { LastSeq int64 `protobuf:"varint,1,opt,name=lastSeq,proto3" json:"lastSeq"` ConversationID string `protobuf:"bytes,2,opt,name=conversationID,proto3" json:"conversationID"` MsgData []*sdkws.MsgData `protobuf:"bytes,3,rep,name=msgData,proto3" json:"msgData"` // contains filtered or unexported fields }
func (*MsgDataToMongoByMQ) Descriptor
deprecated
func (*MsgDataToMongoByMQ) Descriptor() ([]byte, []int)
Deprecated: Use MsgDataToMongoByMQ.ProtoReflect.Descriptor instead.
func (*MsgDataToMongoByMQ) GetConversationID ¶
func (x *MsgDataToMongoByMQ) GetConversationID() string
func (*MsgDataToMongoByMQ) GetLastSeq ¶
func (x *MsgDataToMongoByMQ) GetLastSeq() int64
func (*MsgDataToMongoByMQ) GetMsgData ¶
func (x *MsgDataToMongoByMQ) GetMsgData() []*sdkws.MsgData
func (*MsgDataToMongoByMQ) ProtoMessage ¶
func (*MsgDataToMongoByMQ) ProtoMessage()
func (*MsgDataToMongoByMQ) ProtoReflect ¶
func (x *MsgDataToMongoByMQ) ProtoReflect() protoreflect.Message
func (*MsgDataToMongoByMQ) Reset ¶
func (x *MsgDataToMongoByMQ) Reset()
func (*MsgDataToMongoByMQ) String ¶
func (x *MsgDataToMongoByMQ) String() string
type MsgServer ¶
type MsgServer interface { // 获取最小最大seq(包括用户的,以及指定群组的) GetMaxSeq(context.Context, *sdkws.GetMaxSeqReq) (*sdkws.GetMaxSeqResp, error) // 获取会话列表的最大seq GetMaxSeqs(context.Context, *GetMaxSeqsReq) (*SeqsInfoResp, error) // 获取会话列表已读的最大seq GetHasReadSeqs(context.Context, *GetHasReadSeqsReq) (*SeqsInfoResp, error) // 获取最新消息 GetMsgByConversationIDs(context.Context, *GetMsgByConversationIDsReq) (*GetMsgByConversationIDsResp, error) GetConversationMaxSeq(context.Context, *GetConversationMaxSeqReq) (*GetConversationMaxSeqResp, error) // 拉取历史消息(包括用户的,以及指定群组的) PullMessageBySeqs(context.Context, *sdkws.PullMessageBySeqsReq) (*sdkws.PullMessageBySeqsResp, error) SearchMessage(context.Context, *SearchMessageReq) (*SearchMessageResp, error) // 发送消息 SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error) // 全量清空指定会话消息 重置min seq 比最大seq大1 ClearConversationsMsg(context.Context, *ClearConversationsMsgReq) (*ClearConversationsMsgResp, error) // 删除用户全部消息 重置min seq 比最大seq大1 UserClearAllMsg(context.Context, *UserClearAllMsgReq) (*UserClearAllMsgResp, error) // 用户标记删除部分消息by Seq DeleteMsgs(context.Context, *DeleteMsgsReq) (*DeleteMsgsResp, error) // seq物理删除消息 DeleteMsgPhysicalBySeq(context.Context, *DeleteMsgPhysicalBySeqReq) (*DeleteMsgPhysicalBySeqResp, error) // 物理删除消息by 时间 DeleteMsgPhysical(context.Context, *DeleteMsgPhysicalReq) (*DeleteMsgPhysicalResp, error) // 设置消息是否发送成功-针对api发送的消息 SetSendMsgStatus(context.Context, *SetSendMsgStatusReq) (*SetSendMsgStatusResp, error) // 获取消息发送状态 GetSendMsgStatus(context.Context, *GetSendMsgStatusReq) (*GetSendMsgStatusResp, error) RevokeMsg(context.Context, *RevokeMsgReq) (*RevokeMsgResp, error) // mark as read MarkMsgsAsRead(context.Context, *MarkMsgsAsReadReq) (*MarkMsgsAsReadResp, error) MarkConversationAsRead(context.Context, *MarkConversationAsReadReq) (*MarkConversationAsReadResp, error) SetConversationHasReadSeq(context.Context, *SetConversationHasReadSeqReq) (*SetConversationHasReadSeqResp, error) GetConversationsHasReadAndMaxSeq(context.Context, *GetConversationsHasReadAndMaxSeqReq) (*GetConversationsHasReadAndMaxSeqResp, error) GetActiveUser(context.Context, *GetActiveUserReq) (*GetActiveUserResp, error) GetActiveGroup(context.Context, *GetActiveGroupReq) (*GetActiveGroupResp, error) GetServerTime(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error) ClearMsg(context.Context, *ClearMsgReq) (*ClearMsgResp, error) }
MsgServer is the server API for Msg service.
type PushMsgDataToMQ ¶
type PushMsgDataToMQ struct { MsgData *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData,proto3" json:"msgData"` ConversationID string `protobuf:"bytes,2,opt,name=conversationID,proto3" json:"conversationID"` // contains filtered or unexported fields }
func (*PushMsgDataToMQ) Descriptor
deprecated
func (*PushMsgDataToMQ) Descriptor() ([]byte, []int)
Deprecated: Use PushMsgDataToMQ.ProtoReflect.Descriptor instead.
func (*PushMsgDataToMQ) GetConversationID ¶
func (x *PushMsgDataToMQ) GetConversationID() string
func (*PushMsgDataToMQ) GetMsgData ¶
func (x *PushMsgDataToMQ) GetMsgData() *sdkws.MsgData
func (*PushMsgDataToMQ) ProtoMessage ¶
func (*PushMsgDataToMQ) ProtoMessage()
func (*PushMsgDataToMQ) ProtoReflect ¶
func (x *PushMsgDataToMQ) ProtoReflect() protoreflect.Message
func (*PushMsgDataToMQ) Reset ¶
func (x *PushMsgDataToMQ) Reset()
func (*PushMsgDataToMQ) String ¶
func (x *PushMsgDataToMQ) String() string
type RevokeMsgReq ¶
type RevokeMsgReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` Seq int64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq"` UserID string `protobuf:"bytes,3,opt,name=userID,proto3" json:"userID"` // contains filtered or unexported fields }
func (*RevokeMsgReq) Check ¶
func (x *RevokeMsgReq) Check() error
func (*RevokeMsgReq) Descriptor
deprecated
func (*RevokeMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use RevokeMsgReq.ProtoReflect.Descriptor instead.
func (*RevokeMsgReq) GetConversationID ¶
func (x *RevokeMsgReq) GetConversationID() string
func (*RevokeMsgReq) GetSeq ¶
func (x *RevokeMsgReq) GetSeq() int64
func (*RevokeMsgReq) GetUserID ¶
func (x *RevokeMsgReq) GetUserID() string
func (*RevokeMsgReq) ProtoMessage ¶
func (*RevokeMsgReq) ProtoMessage()
func (*RevokeMsgReq) ProtoReflect ¶
func (x *RevokeMsgReq) ProtoReflect() protoreflect.Message
func (*RevokeMsgReq) Reset ¶
func (x *RevokeMsgReq) Reset()
func (*RevokeMsgReq) String ¶
func (x *RevokeMsgReq) String() string
type RevokeMsgResp ¶
type RevokeMsgResp struct {
// contains filtered or unexported fields
}
func (*RevokeMsgResp) Descriptor
deprecated
func (*RevokeMsgResp) Descriptor() ([]byte, []int)
Deprecated: Use RevokeMsgResp.ProtoReflect.Descriptor instead.
func (*RevokeMsgResp) ProtoMessage ¶
func (*RevokeMsgResp) ProtoMessage()
func (*RevokeMsgResp) ProtoReflect ¶
func (x *RevokeMsgResp) ProtoReflect() protoreflect.Message
func (*RevokeMsgResp) Reset ¶
func (x *RevokeMsgResp) Reset()
func (*RevokeMsgResp) String ¶
func (x *RevokeMsgResp) String() string
type SearchMessageReq ¶
type SearchMessageReq struct { SendID string `protobuf:"bytes,1,opt,name=sendID,proto3" json:"sendID"` //发送者ID RecvID string `protobuf:"bytes,2,opt,name=recvID,proto3" json:"recvID"` //接收者ID ContentType int32 `protobuf:"varint,3,opt,name=contentType,proto3" json:"contentType"` SendTime string `protobuf:"bytes,4,opt,name=sendTime,proto3" json:"sendTime"` SessionType int32 `protobuf:"varint,5,opt,name=sessionType,proto3" json:"sessionType"` Pagination *sdkws.RequestPagination `protobuf:"bytes,6,opt,name=pagination,proto3" json:"pagination"` // contains filtered or unexported fields }
func (*SearchMessageReq) Descriptor
deprecated
func (*SearchMessageReq) Descriptor() ([]byte, []int)
Deprecated: Use SearchMessageReq.ProtoReflect.Descriptor instead.
func (*SearchMessageReq) GetContentType ¶
func (x *SearchMessageReq) GetContentType() int32
func (*SearchMessageReq) GetPagination ¶
func (x *SearchMessageReq) GetPagination() *sdkws.RequestPagination
func (*SearchMessageReq) GetRecvID ¶
func (x *SearchMessageReq) GetRecvID() string
func (*SearchMessageReq) GetSendID ¶
func (x *SearchMessageReq) GetSendID() string
func (*SearchMessageReq) GetSendTime ¶
func (x *SearchMessageReq) GetSendTime() string
func (*SearchMessageReq) GetSessionType ¶
func (x *SearchMessageReq) GetSessionType() int32
func (*SearchMessageReq) ProtoMessage ¶
func (*SearchMessageReq) ProtoMessage()
func (*SearchMessageReq) ProtoReflect ¶
func (x *SearchMessageReq) ProtoReflect() protoreflect.Message
func (*SearchMessageReq) Reset ¶
func (x *SearchMessageReq) Reset()
func (*SearchMessageReq) String ¶
func (x *SearchMessageReq) String() string
type SearchMessageResp ¶
type SearchMessageResp struct { ChatLogs []*ChatLog `protobuf:"bytes,1,rep,name=chatLogs,proto3" json:"chatLogs"` ChatLogsNum int32 `protobuf:"varint,2,opt,name=chatLogsNum,proto3" json:"chatLogsNum"` // contains filtered or unexported fields }
func (*SearchMessageResp) Descriptor
deprecated
func (*SearchMessageResp) Descriptor() ([]byte, []int)
Deprecated: Use SearchMessageResp.ProtoReflect.Descriptor instead.
func (*SearchMessageResp) GetChatLogs ¶
func (x *SearchMessageResp) GetChatLogs() []*ChatLog
func (*SearchMessageResp) GetChatLogsNum ¶
func (x *SearchMessageResp) GetChatLogsNum() int32
func (*SearchMessageResp) ProtoMessage ¶
func (*SearchMessageResp) ProtoMessage()
func (*SearchMessageResp) ProtoReflect ¶
func (x *SearchMessageResp) ProtoReflect() protoreflect.Message
func (*SearchMessageResp) Reset ¶
func (x *SearchMessageResp) Reset()
func (*SearchMessageResp) String ¶
func (x *SearchMessageResp) String() string
type SendMsgReq ¶
type SendMsgReq struct { MsgData *sdkws.MsgData `protobuf:"bytes,3,opt,name=msgData,proto3" json:"msgData"` // contains filtered or unexported fields }
func (*SendMsgReq) Check ¶
func (x *SendMsgReq) Check() error
func (*SendMsgReq) Descriptor
deprecated
func (*SendMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use SendMsgReq.ProtoReflect.Descriptor instead.
func (*SendMsgReq) GetMsgData ¶
func (x *SendMsgReq) GetMsgData() *sdkws.MsgData
func (*SendMsgReq) ProtoMessage ¶
func (*SendMsgReq) ProtoMessage()
func (*SendMsgReq) ProtoReflect ¶
func (x *SendMsgReq) ProtoReflect() protoreflect.Message
func (*SendMsgReq) Reset ¶
func (x *SendMsgReq) Reset()
func (*SendMsgReq) String ¶
func (x *SendMsgReq) String() string
type SendMsgResp ¶
type SendMsgResp struct { ServerMsgID string `protobuf:"bytes,1,opt,name=serverMsgID,proto3" json:"serverMsgID"` ClientMsgID string `protobuf:"bytes,2,opt,name=clientMsgID,proto3" json:"clientMsgID"` SendTime int64 `protobuf:"varint,3,opt,name=sendTime,proto3" json:"sendTime"` // contains filtered or unexported fields }
func (*SendMsgResp) Descriptor
deprecated
func (*SendMsgResp) Descriptor() ([]byte, []int)
Deprecated: Use SendMsgResp.ProtoReflect.Descriptor instead.
func (*SendMsgResp) GetClientMsgID ¶
func (x *SendMsgResp) GetClientMsgID() string
func (*SendMsgResp) GetSendTime ¶
func (x *SendMsgResp) GetSendTime() int64
func (*SendMsgResp) GetServerMsgID ¶
func (x *SendMsgResp) GetServerMsgID() string
func (*SendMsgResp) ProtoMessage ¶
func (*SendMsgResp) ProtoMessage()
func (*SendMsgResp) ProtoReflect ¶
func (x *SendMsgResp) ProtoReflect() protoreflect.Message
func (*SendMsgResp) Reset ¶
func (x *SendMsgResp) Reset()
func (*SendMsgResp) String ¶
func (x *SendMsgResp) String() string
type Seqs ¶
type Seqs struct { MaxSeq int64 `protobuf:"varint,1,opt,name=maxSeq,proto3" json:"maxSeq"` HasReadSeq int64 `protobuf:"varint,2,opt,name=hasReadSeq,proto3" json:"hasReadSeq"` // contains filtered or unexported fields }
func (*Seqs) Descriptor
deprecated
func (*Seqs) GetHasReadSeq ¶
func (*Seqs) ProtoMessage ¶
func (*Seqs) ProtoMessage()
func (*Seqs) ProtoReflect ¶
func (x *Seqs) ProtoReflect() protoreflect.Message
type SeqsInfoResp ¶
type SeqsInfoResp struct { MaxSeqs map[string]int64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SeqsInfoResp) Descriptor
deprecated
func (*SeqsInfoResp) Descriptor() ([]byte, []int)
Deprecated: Use SeqsInfoResp.ProtoReflect.Descriptor instead.
func (*SeqsInfoResp) GetMaxSeqs ¶
func (x *SeqsInfoResp) GetMaxSeqs() map[string]int64
func (*SeqsInfoResp) ProtoMessage ¶
func (*SeqsInfoResp) ProtoMessage()
func (*SeqsInfoResp) ProtoReflect ¶
func (x *SeqsInfoResp) ProtoReflect() protoreflect.Message
func (*SeqsInfoResp) Reset ¶
func (x *SeqsInfoResp) Reset()
func (*SeqsInfoResp) String ¶
func (x *SeqsInfoResp) String() string
type SetConversationHasReadSeqReq ¶
type SetConversationHasReadSeqReq struct { ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"` UserID string `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID"` HasReadSeq int64 `protobuf:"varint,3,opt,name=hasReadSeq,proto3" json:"hasReadSeq"` // contains filtered or unexported fields }
func (*SetConversationHasReadSeqReq) Check ¶
func (x *SetConversationHasReadSeqReq) Check() error
func (*SetConversationHasReadSeqReq) Descriptor
deprecated
func (*SetConversationHasReadSeqReq) Descriptor() ([]byte, []int)
Deprecated: Use SetConversationHasReadSeqReq.ProtoReflect.Descriptor instead.
func (*SetConversationHasReadSeqReq) GetConversationID ¶
func (x *SetConversationHasReadSeqReq) GetConversationID() string
func (*SetConversationHasReadSeqReq) GetHasReadSeq ¶
func (x *SetConversationHasReadSeqReq) GetHasReadSeq() int64
func (*SetConversationHasReadSeqReq) GetUserID ¶
func (x *SetConversationHasReadSeqReq) GetUserID() string
func (*SetConversationHasReadSeqReq) ProtoMessage ¶
func (*SetConversationHasReadSeqReq) ProtoMessage()
func (*SetConversationHasReadSeqReq) ProtoReflect ¶
func (x *SetConversationHasReadSeqReq) ProtoReflect() protoreflect.Message
func (*SetConversationHasReadSeqReq) Reset ¶
func (x *SetConversationHasReadSeqReq) Reset()
func (*SetConversationHasReadSeqReq) String ¶
func (x *SetConversationHasReadSeqReq) String() string
type SetConversationHasReadSeqResp ¶
type SetConversationHasReadSeqResp struct {
// contains filtered or unexported fields
}
func (*SetConversationHasReadSeqResp) Descriptor
deprecated
func (*SetConversationHasReadSeqResp) Descriptor() ([]byte, []int)
Deprecated: Use SetConversationHasReadSeqResp.ProtoReflect.Descriptor instead.
func (*SetConversationHasReadSeqResp) ProtoMessage ¶
func (*SetConversationHasReadSeqResp) ProtoMessage()
func (*SetConversationHasReadSeqResp) ProtoReflect ¶
func (x *SetConversationHasReadSeqResp) ProtoReflect() protoreflect.Message
func (*SetConversationHasReadSeqResp) Reset ¶
func (x *SetConversationHasReadSeqResp) Reset()
func (*SetConversationHasReadSeqResp) String ¶
func (x *SetConversationHasReadSeqResp) String() string
type SetSendMsgStatusReq ¶
type SetSendMsgStatusReq struct { Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status"` // contains filtered or unexported fields }
func (*SetSendMsgStatusReq) Check ¶
func (x *SetSendMsgStatusReq) Check() error
func (*SetSendMsgStatusReq) Descriptor
deprecated
func (*SetSendMsgStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use SetSendMsgStatusReq.ProtoReflect.Descriptor instead.
func (*SetSendMsgStatusReq) GetStatus ¶
func (x *SetSendMsgStatusReq) GetStatus() int32
func (*SetSendMsgStatusReq) ProtoMessage ¶
func (*SetSendMsgStatusReq) ProtoMessage()
func (*SetSendMsgStatusReq) ProtoReflect ¶
func (x *SetSendMsgStatusReq) ProtoReflect() protoreflect.Message
func (*SetSendMsgStatusReq) Reset ¶
func (x *SetSendMsgStatusReq) Reset()
func (*SetSendMsgStatusReq) String ¶
func (x *SetSendMsgStatusReq) String() string
type SetSendMsgStatusResp ¶
type SetSendMsgStatusResp struct {
// contains filtered or unexported fields
}
func (*SetSendMsgStatusResp) Descriptor
deprecated
func (*SetSendMsgStatusResp) Descriptor() ([]byte, []int)
Deprecated: Use SetSendMsgStatusResp.ProtoReflect.Descriptor instead.
func (*SetSendMsgStatusResp) ProtoMessage ¶
func (*SetSendMsgStatusResp) ProtoMessage()
func (*SetSendMsgStatusResp) ProtoReflect ¶
func (x *SetSendMsgStatusResp) ProtoReflect() protoreflect.Message
func (*SetSendMsgStatusResp) Reset ¶
func (x *SetSendMsgStatusResp) Reset()
func (*SetSendMsgStatusResp) String ¶
func (x *SetSendMsgStatusResp) String() string
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) ClearConversationsMsg ¶
func (*UnimplementedMsgServer) ClearConversationsMsg(context.Context, *ClearConversationsMsgReq) (*ClearConversationsMsgResp, error)
func (*UnimplementedMsgServer) ClearMsg ¶ added in v0.0.65
func (*UnimplementedMsgServer) ClearMsg(context.Context, *ClearMsgReq) (*ClearMsgResp, error)
func (*UnimplementedMsgServer) DeleteMsgPhysical ¶
func (*UnimplementedMsgServer) DeleteMsgPhysical(context.Context, *DeleteMsgPhysicalReq) (*DeleteMsgPhysicalResp, error)
func (*UnimplementedMsgServer) DeleteMsgPhysicalBySeq ¶
func (*UnimplementedMsgServer) DeleteMsgPhysicalBySeq(context.Context, *DeleteMsgPhysicalBySeqReq) (*DeleteMsgPhysicalBySeqResp, error)
func (*UnimplementedMsgServer) DeleteMsgs ¶
func (*UnimplementedMsgServer) DeleteMsgs(context.Context, *DeleteMsgsReq) (*DeleteMsgsResp, error)
func (*UnimplementedMsgServer) GetActiveGroup ¶
func (*UnimplementedMsgServer) GetActiveGroup(context.Context, *GetActiveGroupReq) (*GetActiveGroupResp, error)
func (*UnimplementedMsgServer) GetActiveUser ¶
func (*UnimplementedMsgServer) GetActiveUser(context.Context, *GetActiveUserReq) (*GetActiveUserResp, error)
func (*UnimplementedMsgServer) GetConversationMaxSeq ¶
func (*UnimplementedMsgServer) GetConversationMaxSeq(context.Context, *GetConversationMaxSeqReq) (*GetConversationMaxSeqResp, error)
func (*UnimplementedMsgServer) GetConversationsHasReadAndMaxSeq ¶
func (*UnimplementedMsgServer) GetConversationsHasReadAndMaxSeq(context.Context, *GetConversationsHasReadAndMaxSeqReq) (*GetConversationsHasReadAndMaxSeqResp, error)
func (*UnimplementedMsgServer) GetHasReadSeqs ¶
func (*UnimplementedMsgServer) GetHasReadSeqs(context.Context, *GetHasReadSeqsReq) (*SeqsInfoResp, error)
func (*UnimplementedMsgServer) GetMaxSeq ¶
func (*UnimplementedMsgServer) GetMaxSeq(context.Context, *sdkws.GetMaxSeqReq) (*sdkws.GetMaxSeqResp, error)
func (*UnimplementedMsgServer) GetMaxSeqs ¶
func (*UnimplementedMsgServer) GetMaxSeqs(context.Context, *GetMaxSeqsReq) (*SeqsInfoResp, error)
func (*UnimplementedMsgServer) GetMsgByConversationIDs ¶
func (*UnimplementedMsgServer) GetMsgByConversationIDs(context.Context, *GetMsgByConversationIDsReq) (*GetMsgByConversationIDsResp, error)
func (*UnimplementedMsgServer) GetSendMsgStatus ¶
func (*UnimplementedMsgServer) GetSendMsgStatus(context.Context, *GetSendMsgStatusReq) (*GetSendMsgStatusResp, error)
func (*UnimplementedMsgServer) GetServerTime ¶
func (*UnimplementedMsgServer) GetServerTime(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error)
func (*UnimplementedMsgServer) MarkConversationAsRead ¶
func (*UnimplementedMsgServer) MarkConversationAsRead(context.Context, *MarkConversationAsReadReq) (*MarkConversationAsReadResp, error)
func (*UnimplementedMsgServer) MarkMsgsAsRead ¶
func (*UnimplementedMsgServer) MarkMsgsAsRead(context.Context, *MarkMsgsAsReadReq) (*MarkMsgsAsReadResp, error)
func (*UnimplementedMsgServer) PullMessageBySeqs ¶
func (*UnimplementedMsgServer) PullMessageBySeqs(context.Context, *sdkws.PullMessageBySeqsReq) (*sdkws.PullMessageBySeqsResp, error)
func (*UnimplementedMsgServer) RevokeMsg ¶
func (*UnimplementedMsgServer) RevokeMsg(context.Context, *RevokeMsgReq) (*RevokeMsgResp, error)
func (*UnimplementedMsgServer) SearchMessage ¶
func (*UnimplementedMsgServer) SearchMessage(context.Context, *SearchMessageReq) (*SearchMessageResp, error)
func (*UnimplementedMsgServer) SendMsg ¶
func (*UnimplementedMsgServer) SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
func (*UnimplementedMsgServer) SetConversationHasReadSeq ¶
func (*UnimplementedMsgServer) SetConversationHasReadSeq(context.Context, *SetConversationHasReadSeqReq) (*SetConversationHasReadSeqResp, error)
func (*UnimplementedMsgServer) SetSendMsgStatus ¶
func (*UnimplementedMsgServer) SetSendMsgStatus(context.Context, *SetSendMsgStatusReq) (*SetSendMsgStatusResp, error)
func (*UnimplementedMsgServer) UserClearAllMsg ¶
func (*UnimplementedMsgServer) UserClearAllMsg(context.Context, *UserClearAllMsgReq) (*UserClearAllMsgResp, error)
type UserClearAllMsgReq ¶
type UserClearAllMsgReq struct { UserID string `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"` DeleteSyncOpt *DeleteSyncOpt `protobuf:"bytes,3,opt,name=deleteSyncOpt,proto3" json:"deleteSyncOpt"` // contains filtered or unexported fields }
func (*UserClearAllMsgReq) Check ¶
func (x *UserClearAllMsgReq) Check() error
func (*UserClearAllMsgReq) Descriptor
deprecated
func (*UserClearAllMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use UserClearAllMsgReq.ProtoReflect.Descriptor instead.
func (*UserClearAllMsgReq) GetDeleteSyncOpt ¶
func (x *UserClearAllMsgReq) GetDeleteSyncOpt() *DeleteSyncOpt
func (*UserClearAllMsgReq) GetUserID ¶
func (x *UserClearAllMsgReq) GetUserID() string
func (*UserClearAllMsgReq) ProtoMessage ¶
func (*UserClearAllMsgReq) ProtoMessage()
func (*UserClearAllMsgReq) ProtoReflect ¶
func (x *UserClearAllMsgReq) ProtoReflect() protoreflect.Message
func (*UserClearAllMsgReq) Reset ¶
func (x *UserClearAllMsgReq) Reset()
func (*UserClearAllMsgReq) String ¶
func (x *UserClearAllMsgReq) String() string
type UserClearAllMsgResp ¶
type UserClearAllMsgResp struct {
// contains filtered or unexported fields
}
func (*UserClearAllMsgResp) Descriptor
deprecated
func (*UserClearAllMsgResp) Descriptor() ([]byte, []int)
Deprecated: Use UserClearAllMsgResp.ProtoReflect.Descriptor instead.
func (*UserClearAllMsgResp) ProtoMessage ¶
func (*UserClearAllMsgResp) ProtoMessage()
func (*UserClearAllMsgResp) ProtoReflect ¶
func (x *UserClearAllMsgResp) ProtoReflect() protoreflect.Message
func (*UserClearAllMsgResp) Reset ¶
func (x *UserClearAllMsgResp) Reset()
func (*UserClearAllMsgResp) String ¶
func (x *UserClearAllMsgResp) String() string