Versions in this module Expand all Collapse all v1 v1.0.3 Mar 7, 2025 v1.0.2 Mar 7, 2025 v1.0.1 Mar 7, 2025 Changes in this version + var File_msg_msg_proto protoreflect.FileDescriptor + func RegisterMsgServer(s *grpc.Server, srv MsgServer) + type ActiveConversation struct + ConversationID string + LastTime int64 + MaxSeq int64 + func (*ActiveConversation) Descriptor() ([]byte, []int) + func (*ActiveConversation) ProtoMessage() + func (x *ActiveConversation) GetConversationID() string + func (x *ActiveConversation) GetLastTime() int64 + func (x *ActiveConversation) GetMaxSeq() int64 + func (x *ActiveConversation) ProtoReflect() protoreflect.Message + func (x *ActiveConversation) Reset() + func (x *ActiveConversation) String() string + type ActiveGroup struct + Count int64 + Group *sdkws.GroupInfo + func (*ActiveGroup) Descriptor() ([]byte, []int) + func (*ActiveGroup) ProtoMessage() + func (x *ActiveGroup) GetCount() int64 + func (x *ActiveGroup) GetGroup() *sdkws.GroupInfo + func (x *ActiveGroup) ProtoReflect() protoreflect.Message + func (x *ActiveGroup) Reset() + func (x *ActiveGroup) String() string + type ActiveUser struct + Count int64 + User *sdkws.UserInfo + func (*ActiveUser) Descriptor() ([]byte, []int) + func (*ActiveUser) ProtoMessage() + func (x *ActiveUser) GetCount() int64 + func (x *ActiveUser) GetUser() *sdkws.UserInfo + func (x *ActiveUser) ProtoReflect() protoreflect.Message + func (x *ActiveUser) Reset() + func (x *ActiveUser) String() string + type AppendStreamMsgReq struct + ClientMsgID string + End bool + Packets []string + StartIndex int64 + func (*AppendStreamMsgReq) Descriptor() ([]byte, []int) + func (*AppendStreamMsgReq) ProtoMessage() + func (x *AppendStreamMsgReq) GetClientMsgID() string + func (x *AppendStreamMsgReq) GetEnd() bool + func (x *AppendStreamMsgReq) GetPackets() []string + func (x *AppendStreamMsgReq) GetStartIndex() int64 + func (x *AppendStreamMsgReq) ProtoReflect() protoreflect.Message + func (x *AppendStreamMsgReq) Reset() + func (x *AppendStreamMsgReq) String() string + type AppendStreamMsgResp struct + func (*AppendStreamMsgResp) Descriptor() ([]byte, []int) + func (*AppendStreamMsgResp) ProtoMessage() + func (x *AppendStreamMsgResp) ProtoReflect() protoreflect.Message + func (x *AppendStreamMsgResp) Reset() + func (x *AppendStreamMsgResp) String() string + type BatchSendMessageReq struct + MsgData *sdkws.MsgData + RecvIDList []string + func (*BatchSendMessageReq) Descriptor() ([]byte, []int) + func (*BatchSendMessageReq) ProtoMessage() + func (x *BatchSendMessageReq) GetMsgData() *sdkws.MsgData + func (x *BatchSendMessageReq) GetRecvIDList() []string + func (x *BatchSendMessageReq) ProtoReflect() protoreflect.Message + func (x *BatchSendMessageReq) Reset() + func (x *BatchSendMessageReq) String() string + type BatchSendMessageResp struct + func (*BatchSendMessageResp) Descriptor() ([]byte, []int) + func (*BatchSendMessageResp) ProtoMessage() + func (x *BatchSendMessageResp) ProtoReflect() protoreflect.Message + func (x *BatchSendMessageResp) Reset() + func (x *BatchSendMessageResp) String() string + type ChatLog struct + ClientMsgID string + Content string + ContentType int32 + CreateTime int64 + Ex string + GroupFaceURL string + GroupID string + GroupMemberCount uint32 + GroupName string + GroupOwner string + GroupType int32 + MsgFrom int32 + RecvID string + RecvNickname string + SendID string + SendTime int64 + SenderFaceURL string + SenderNickname string + SenderPlatformID int32 + Seq int64 + ServerMsgID string + SessionType int32 + Status int32 + func (*ChatLog) Descriptor() ([]byte, []int) + func (*ChatLog) ProtoMessage() + 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 (x *ChatLog) ProtoReflect() protoreflect.Message + func (x *ChatLog) Reset() + func (x *ChatLog) String() string + type ClearConversationsMsgReq struct + ConversationIDs []string + DeleteSyncOpt *DeleteSyncOpt + UserID string + func (*ClearConversationsMsgReq) Descriptor() ([]byte, []int) + func (*ClearConversationsMsgReq) ProtoMessage() + func (x *ClearConversationsMsgReq) Check() error + func (x *ClearConversationsMsgReq) GetConversationIDs() []string + func (x *ClearConversationsMsgReq) GetDeleteSyncOpt() *DeleteSyncOpt + func (x *ClearConversationsMsgReq) GetUserID() string + func (x *ClearConversationsMsgReq) ProtoReflect() protoreflect.Message + func (x *ClearConversationsMsgReq) Reset() + func (x *ClearConversationsMsgReq) String() string + type ClearConversationsMsgResp struct + func (*ClearConversationsMsgResp) Descriptor() ([]byte, []int) + func (*ClearConversationsMsgResp) ProtoMessage() + func (x *ClearConversationsMsgResp) ProtoReflect() protoreflect.Message + func (x *ClearConversationsMsgResp) Reset() + func (x *ClearConversationsMsgResp) String() string + type ClearMsgReq struct + Timestamp int64 + func (*ClearMsgReq) Descriptor() ([]byte, []int) + func (*ClearMsgReq) ProtoMessage() + func (x *ClearMsgReq) GetTimestamp() int64 + func (x *ClearMsgReq) ProtoReflect() protoreflect.Message + func (x *ClearMsgReq) Reset() + func (x *ClearMsgReq) String() string + type ClearMsgResp struct + func (*ClearMsgResp) Descriptor() ([]byte, []int) + func (*ClearMsgResp) ProtoMessage() + func (x *ClearMsgResp) ProtoReflect() protoreflect.Message + func (x *ClearMsgResp) Reset() + func (x *ClearMsgResp) String() string + type ConversationSeqs struct + ConversationID string + Seqs []int64 + func (*ConversationSeqs) Descriptor() ([]byte, []int) + func (*ConversationSeqs) ProtoMessage() + func (x *ConversationSeqs) GetConversationID() string + func (x *ConversationSeqs) GetSeqs() []int64 + func (x *ConversationSeqs) ProtoReflect() protoreflect.Message + func (x *ConversationSeqs) Reset() + func (x *ConversationSeqs) String() string + type DelMsgsReq struct + func (*DelMsgsReq) Descriptor() ([]byte, []int) + func (*DelMsgsReq) ProtoMessage() + func (x *DelMsgsReq) Check() error + func (x *DelMsgsReq) ProtoReflect() protoreflect.Message + func (x *DelMsgsReq) Reset() + func (x *DelMsgsReq) String() string + type DelMsgsResp struct + func (*DelMsgsResp) Descriptor() ([]byte, []int) + func (*DelMsgsResp) ProtoMessage() + func (x *DelMsgsResp) ProtoReflect() protoreflect.Message + func (x *DelMsgsResp) Reset() + func (x *DelMsgsResp) String() string + type DeleteMsgPhysicalBySeqReq struct + ConversationID string + Seqs []int64 + func (*DeleteMsgPhysicalBySeqReq) Descriptor() ([]byte, []int) + func (*DeleteMsgPhysicalBySeqReq) ProtoMessage() + func (x *DeleteMsgPhysicalBySeqReq) GetConversationID() string + func (x *DeleteMsgPhysicalBySeqReq) GetSeqs() []int64 + func (x *DeleteMsgPhysicalBySeqReq) ProtoReflect() protoreflect.Message + func (x *DeleteMsgPhysicalBySeqReq) Reset() + func (x *DeleteMsgPhysicalBySeqReq) String() string + type DeleteMsgPhysicalBySeqResp struct + func (*DeleteMsgPhysicalBySeqResp) Descriptor() ([]byte, []int) + func (*DeleteMsgPhysicalBySeqResp) ProtoMessage() + func (x *DeleteMsgPhysicalBySeqResp) ProtoReflect() protoreflect.Message + func (x *DeleteMsgPhysicalBySeqResp) Reset() + func (x *DeleteMsgPhysicalBySeqResp) String() string + type DeleteMsgPhysicalReq struct + ConversationIDs []string + Timestamp int64 + func (*DeleteMsgPhysicalReq) Descriptor() ([]byte, []int) + func (*DeleteMsgPhysicalReq) ProtoMessage() + func (x *DeleteMsgPhysicalReq) Check() error + func (x *DeleteMsgPhysicalReq) GetConversationIDs() []string + func (x *DeleteMsgPhysicalReq) GetTimestamp() int64 + func (x *DeleteMsgPhysicalReq) ProtoReflect() protoreflect.Message + func (x *DeleteMsgPhysicalReq) Reset() + func (x *DeleteMsgPhysicalReq) String() string + type DeleteMsgPhysicalResp struct + func (*DeleteMsgPhysicalResp) Descriptor() ([]byte, []int) + func (*DeleteMsgPhysicalResp) ProtoMessage() + func (x *DeleteMsgPhysicalResp) ProtoReflect() protoreflect.Message + func (x *DeleteMsgPhysicalResp) Reset() + func (x *DeleteMsgPhysicalResp) String() string + type DeleteMsgsReq struct + ConversationID string + DeleteSyncOpt *DeleteSyncOpt + Seqs []int64 + UserID string + func (*DeleteMsgsReq) Descriptor() ([]byte, []int) + func (*DeleteMsgsReq) ProtoMessage() + func (x *DeleteMsgsReq) Check() error + func (x *DeleteMsgsReq) GetConversationID() string + func (x *DeleteMsgsReq) GetDeleteSyncOpt() *DeleteSyncOpt + func (x *DeleteMsgsReq) GetSeqs() []int64 + func (x *DeleteMsgsReq) GetUserID() string + func (x *DeleteMsgsReq) ProtoReflect() protoreflect.Message + func (x *DeleteMsgsReq) Reset() + func (x *DeleteMsgsReq) String() string + type DeleteMsgsResp struct + func (*DeleteMsgsResp) Descriptor() ([]byte, []int) + func (*DeleteMsgsResp) ProtoMessage() + func (x *DeleteMsgsResp) ProtoReflect() protoreflect.Message + func (x *DeleteMsgsResp) Reset() + func (x *DeleteMsgsResp) String() string + type DeleteSyncOpt struct + IsSyncOther bool + IsSyncSelf bool + func (*DeleteSyncOpt) Descriptor() ([]byte, []int) + func (*DeleteSyncOpt) ProtoMessage() + func (x *DeleteSyncOpt) GetIsSyncOther() bool + func (x *DeleteSyncOpt) GetIsSyncSelf() bool + func (x *DeleteSyncOpt) ProtoReflect() protoreflect.Message + func (x *DeleteSyncOpt) Reset() + func (x *DeleteSyncOpt) String() string + type DestructMsgsReq struct + Conversations []*conversation.Conversation + func (*DestructMsgsReq) Descriptor() ([]byte, []int) + func (*DestructMsgsReq) ProtoMessage() + func (x *DestructMsgsReq) GetConversations() []*conversation.Conversation + func (x *DestructMsgsReq) ProtoReflect() protoreflect.Message + func (x *DestructMsgsReq) Reset() + func (x *DestructMsgsReq) String() string + type DestructMsgsResp struct + func (*DestructMsgsResp) Descriptor() ([]byte, []int) + func (*DestructMsgsResp) ProtoMessage() + func (x *DestructMsgsResp) ProtoReflect() protoreflect.Message + func (x *DestructMsgsResp) Reset() + func (x *DestructMsgsResp) String() string + type GetActiveConversationReq struct + ConversationIDs []string + Limit int64 + func (*GetActiveConversationReq) Descriptor() ([]byte, []int) + func (*GetActiveConversationReq) ProtoMessage() + func (x *GetActiveConversationReq) GetConversationIDs() []string + func (x *GetActiveConversationReq) GetLimit() int64 + func (x *GetActiveConversationReq) ProtoReflect() protoreflect.Message + func (x *GetActiveConversationReq) Reset() + func (x *GetActiveConversationReq) String() string + type GetActiveConversationResp struct + Conversations []*ActiveConversation + func (*GetActiveConversationResp) Descriptor() ([]byte, []int) + func (*GetActiveConversationResp) ProtoMessage() + func (x *GetActiveConversationResp) GetConversations() []*ActiveConversation + func (x *GetActiveConversationResp) ProtoReflect() protoreflect.Message + func (x *GetActiveConversationResp) Reset() + func (x *GetActiveConversationResp) String() string + type GetActiveGroupReq struct + Ase bool + End int64 + Pagination *sdkws.RequestPagination + Start int64 + func (*GetActiveGroupReq) Descriptor() ([]byte, []int) + func (*GetActiveGroupReq) ProtoMessage() + func (x *GetActiveGroupReq) GetAse() bool + func (x *GetActiveGroupReq) GetEnd() int64 + func (x *GetActiveGroupReq) GetPagination() *sdkws.RequestPagination + func (x *GetActiveGroupReq) GetStart() int64 + func (x *GetActiveGroupReq) ProtoReflect() protoreflect.Message + func (x *GetActiveGroupReq) Reset() + func (x *GetActiveGroupReq) String() string + type GetActiveGroupResp struct + DateCount map[string]int64 + GroupCount int64 + Groups []*ActiveGroup + MsgCount int64 + func (*GetActiveGroupResp) Descriptor() ([]byte, []int) + func (*GetActiveGroupResp) ProtoMessage() + func (x *GetActiveGroupResp) GetDateCount() map[string]int64 + func (x *GetActiveGroupResp) GetGroupCount() int64 + func (x *GetActiveGroupResp) GetGroups() []*ActiveGroup + func (x *GetActiveGroupResp) GetMsgCount() int64 + func (x *GetActiveGroupResp) ProtoReflect() protoreflect.Message + func (x *GetActiveGroupResp) Reset() + func (x *GetActiveGroupResp) String() string + type GetActiveUserReq struct + Ase bool + End int64 + Group bool + Pagination *sdkws.RequestPagination + Start int64 + func (*GetActiveUserReq) Descriptor() ([]byte, []int) + func (*GetActiveUserReq) ProtoMessage() + 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 (x *GetActiveUserReq) ProtoReflect() protoreflect.Message + func (x *GetActiveUserReq) Reset() + func (x *GetActiveUserReq) String() string + type GetActiveUserResp struct + DateCount map[string]int64 + MsgCount int64 + UserCount int64 + Users []*ActiveUser + func (*GetActiveUserResp) Descriptor() ([]byte, []int) + func (*GetActiveUserResp) ProtoMessage() + func (x *GetActiveUserResp) GetDateCount() map[string]int64 + func (x *GetActiveUserResp) GetMsgCount() int64 + func (x *GetActiveUserResp) GetUserCount() int64 + func (x *GetActiveUserResp) GetUsers() []*ActiveUser + func (x *GetActiveUserResp) ProtoReflect() protoreflect.Message + func (x *GetActiveUserResp) Reset() + func (x *GetActiveUserResp) String() string + type GetConversationMaxSeqReq struct + ConversationID string + func (*GetConversationMaxSeqReq) Descriptor() ([]byte, []int) + func (*GetConversationMaxSeqReq) ProtoMessage() + func (x *GetConversationMaxSeqReq) Check() error + func (x *GetConversationMaxSeqReq) GetConversationID() string + func (x *GetConversationMaxSeqReq) ProtoReflect() protoreflect.Message + func (x *GetConversationMaxSeqReq) Reset() + func (x *GetConversationMaxSeqReq) String() string + type GetConversationMaxSeqResp struct + MaxSeq int64 + func (*GetConversationMaxSeqResp) Descriptor() ([]byte, []int) + func (*GetConversationMaxSeqResp) ProtoMessage() + func (x *GetConversationMaxSeqResp) Format() any + func (x *GetConversationMaxSeqResp) GetMaxSeq() int64 + func (x *GetConversationMaxSeqResp) ProtoReflect() protoreflect.Message + func (x *GetConversationMaxSeqResp) Reset() + func (x *GetConversationMaxSeqResp) String() string + type GetConversationsHasReadAndMaxSeqReq struct + ConversationIDs []string + UserID string + func (*GetConversationsHasReadAndMaxSeqReq) Descriptor() ([]byte, []int) + func (*GetConversationsHasReadAndMaxSeqReq) ProtoMessage() + func (x *GetConversationsHasReadAndMaxSeqReq) Check() error + func (x *GetConversationsHasReadAndMaxSeqReq) GetConversationIDs() []string + func (x *GetConversationsHasReadAndMaxSeqReq) GetUserID() string + func (x *GetConversationsHasReadAndMaxSeqReq) ProtoReflect() protoreflect.Message + func (x *GetConversationsHasReadAndMaxSeqReq) Reset() + func (x *GetConversationsHasReadAndMaxSeqReq) String() string + type GetConversationsHasReadAndMaxSeqResp struct + Seqs map[string]*Seqs + func (*GetConversationsHasReadAndMaxSeqResp) Descriptor() ([]byte, []int) + func (*GetConversationsHasReadAndMaxSeqResp) ProtoMessage() + func (x *GetConversationsHasReadAndMaxSeqResp) Format() any + func (x *GetConversationsHasReadAndMaxSeqResp) GetSeqs() map[string]*Seqs + func (x *GetConversationsHasReadAndMaxSeqResp) ProtoReflect() protoreflect.Message + func (x *GetConversationsHasReadAndMaxSeqResp) Reset() + func (x *GetConversationsHasReadAndMaxSeqResp) String() string + type GetHasReadSeqsReq struct + ConversationIDs []string + UserID string + func (*GetHasReadSeqsReq) Descriptor() ([]byte, []int) + func (*GetHasReadSeqsReq) ProtoMessage() + func (x *GetHasReadSeqsReq) GetConversationIDs() []string + func (x *GetHasReadSeqsReq) GetUserID() string + func (x *GetHasReadSeqsReq) ProtoReflect() protoreflect.Message + func (x *GetHasReadSeqsReq) Reset() + func (x *GetHasReadSeqsReq) String() string + type GetMaxAndMinSeqReq struct + UserID string + func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int) + func (*GetMaxAndMinSeqReq) ProtoMessage() + func (x *GetMaxAndMinSeqReq) Check() error + func (x *GetMaxAndMinSeqReq) GetUserID() string + func (x *GetMaxAndMinSeqReq) ProtoReflect() protoreflect.Message + func (x *GetMaxAndMinSeqReq) Reset() + func (x *GetMaxAndMinSeqReq) String() string + type GetMaxAndMinSeqResp struct + MaxSeq int64 + MinSeq int64 + func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int) + func (*GetMaxAndMinSeqResp) ProtoMessage() + func (x *GetMaxAndMinSeqResp) GetMaxSeq() int64 + func (x *GetMaxAndMinSeqResp) GetMinSeq() int64 + func (x *GetMaxAndMinSeqResp) ProtoReflect() protoreflect.Message + func (x *GetMaxAndMinSeqResp) Reset() + func (x *GetMaxAndMinSeqResp) String() string + type GetMaxSeqsReq struct + ConversationIDs []string + func (*GetMaxSeqsReq) Descriptor() ([]byte, []int) + func (*GetMaxSeqsReq) ProtoMessage() + func (x *GetMaxSeqsReq) GetConversationIDs() []string + func (x *GetMaxSeqsReq) ProtoReflect() protoreflect.Message + func (x *GetMaxSeqsReq) Reset() + func (x *GetMaxSeqsReq) String() string + type GetMsgByConversationIDsReq struct + ConversationIDs []string + MaxSeqs map[string]int64 + func (*GetMsgByConversationIDsReq) Descriptor() ([]byte, []int) + func (*GetMsgByConversationIDsReq) ProtoMessage() + func (x *GetMsgByConversationIDsReq) GetConversationIDs() []string + func (x *GetMsgByConversationIDsReq) GetMaxSeqs() map[string]int64 + func (x *GetMsgByConversationIDsReq) ProtoReflect() protoreflect.Message + func (x *GetMsgByConversationIDsReq) Reset() + func (x *GetMsgByConversationIDsReq) String() string + type GetMsgByConversationIDsResp struct + MsgDatas map[string]*sdkws.MsgData + func (*GetMsgByConversationIDsResp) Descriptor() ([]byte, []int) + func (*GetMsgByConversationIDsResp) ProtoMessage() + func (x *GetMsgByConversationIDsResp) GetMsgDatas() map[string]*sdkws.MsgData + func (x *GetMsgByConversationIDsResp) ProtoReflect() protoreflect.Message + func (x *GetMsgByConversationIDsResp) Reset() + func (x *GetMsgByConversationIDsResp) String() string + type GetSendMsgStatusReq struct + func (*GetSendMsgStatusReq) Descriptor() ([]byte, []int) + func (*GetSendMsgStatusReq) ProtoMessage() + func (x *GetSendMsgStatusReq) Check() error + func (x *GetSendMsgStatusReq) ProtoReflect() protoreflect.Message + func (x *GetSendMsgStatusReq) Reset() + func (x *GetSendMsgStatusReq) String() string + type GetSendMsgStatusResp struct + Status int32 + func (*GetSendMsgStatusResp) Descriptor() ([]byte, []int) + func (*GetSendMsgStatusResp) ProtoMessage() + func (x *GetSendMsgStatusResp) GetStatus() int32 + func (x *GetSendMsgStatusResp) ProtoReflect() protoreflect.Message + func (x *GetSendMsgStatusResp) Reset() + func (x *GetSendMsgStatusResp) String() string + type GetSeqMessageReq struct + Conversations []*ConversationSeqs + UserID string + func (*GetSeqMessageReq) Descriptor() ([]byte, []int) + func (*GetSeqMessageReq) ProtoMessage() + func (x *GetSeqMessageReq) GetConversations() []*ConversationSeqs + func (x *GetSeqMessageReq) GetUserID() string + func (x *GetSeqMessageReq) ProtoReflect() protoreflect.Message + func (x *GetSeqMessageReq) Reset() + func (x *GetSeqMessageReq) String() string + type GetSeqMessageResp struct + Msgs map[string]*sdkws.PullMsgs + NotificationMsgs map[string]*sdkws.PullMsgs + func (*GetSeqMessageResp) Descriptor() ([]byte, []int) + func (*GetSeqMessageResp) ProtoMessage() + func (x *GetSeqMessageResp) GetMsgs() map[string]*sdkws.PullMsgs + func (x *GetSeqMessageResp) GetNotificationMsgs() map[string]*sdkws.PullMsgs + func (x *GetSeqMessageResp) ProtoReflect() protoreflect.Message + func (x *GetSeqMessageResp) Reset() + func (x *GetSeqMessageResp) String() string + type GetServerTimeReq struct + func (*GetServerTimeReq) Descriptor() ([]byte, []int) + func (*GetServerTimeReq) ProtoMessage() + func (x *GetServerTimeReq) ProtoReflect() protoreflect.Message + func (x *GetServerTimeReq) Reset() + func (x *GetServerTimeReq) String() string + type GetServerTimeResp struct + ServerTime int64 + func (*GetServerTimeResp) Descriptor() ([]byte, []int) + func (*GetServerTimeResp) ProtoMessage() + func (x *GetServerTimeResp) GetServerTime() int64 + func (x *GetServerTimeResp) ProtoReflect() protoreflect.Message + func (x *GetServerTimeResp) Reset() + func (x *GetServerTimeResp) String() string + type GetStreamMsgReq struct + ClientMsgID string + func (*GetStreamMsgReq) Descriptor() ([]byte, []int) + func (*GetStreamMsgReq) ProtoMessage() + func (x *GetStreamMsgReq) GetClientMsgID() string + func (x *GetStreamMsgReq) ProtoReflect() protoreflect.Message + func (x *GetStreamMsgReq) Reset() + func (x *GetStreamMsgReq) String() string + type GetStreamMsgResp struct + ClientMsgID string + ConversationID string + CreateTime int64 + DeadlineTime int64 + End bool + Packets []string + UserID string + func (*GetStreamMsgResp) Descriptor() ([]byte, []int) + func (*GetStreamMsgResp) ProtoMessage() + func (x *GetStreamMsgResp) GetClientMsgID() string + func (x *GetStreamMsgResp) GetConversationID() string + func (x *GetStreamMsgResp) GetCreateTime() int64 + func (x *GetStreamMsgResp) GetDeadlineTime() int64 + func (x *GetStreamMsgResp) GetEnd() bool + func (x *GetStreamMsgResp) GetPackets() []string + func (x *GetStreamMsgResp) GetUserID() string + func (x *GetStreamMsgResp) ProtoReflect() protoreflect.Message + func (x *GetStreamMsgResp) Reset() + func (x *GetStreamMsgResp) String() string + type MarkConversationAsReadReq struct + ConversationID string + HasReadSeq int64 + Seqs []int64 + UserID string + func (*MarkConversationAsReadReq) Descriptor() ([]byte, []int) + func (*MarkConversationAsReadReq) ProtoMessage() + func (x *MarkConversationAsReadReq) Check() error + func (x *MarkConversationAsReadReq) GetConversationID() string + func (x *MarkConversationAsReadReq) GetHasReadSeq() int64 + func (x *MarkConversationAsReadReq) GetSeqs() []int64 + func (x *MarkConversationAsReadReq) GetUserID() string + func (x *MarkConversationAsReadReq) ProtoReflect() protoreflect.Message + func (x *MarkConversationAsReadReq) Reset() + func (x *MarkConversationAsReadReq) String() string + type MarkConversationAsReadResp struct + func (*MarkConversationAsReadResp) Descriptor() ([]byte, []int) + func (*MarkConversationAsReadResp) ProtoMessage() + func (x *MarkConversationAsReadResp) ProtoReflect() protoreflect.Message + func (x *MarkConversationAsReadResp) Reset() + func (x *MarkConversationAsReadResp) String() string + type MarkMsgsAsReadReq struct + ConversationID string + Seqs []int64 + UserID string + func (*MarkMsgsAsReadReq) Descriptor() ([]byte, []int) + func (*MarkMsgsAsReadReq) ProtoMessage() + func (x *MarkMsgsAsReadReq) Check() error + func (x *MarkMsgsAsReadReq) GetConversationID() string + func (x *MarkMsgsAsReadReq) GetSeqs() []int64 + func (x *MarkMsgsAsReadReq) GetUserID() string + func (x *MarkMsgsAsReadReq) ProtoReflect() protoreflect.Message + func (x *MarkMsgsAsReadReq) Reset() + func (x *MarkMsgsAsReadReq) String() string + type MarkMsgsAsReadResp struct + func (*MarkMsgsAsReadResp) Descriptor() ([]byte, []int) + func (*MarkMsgsAsReadResp) ProtoMessage() + func (x *MarkMsgsAsReadResp) ProtoReflect() protoreflect.Message + func (x *MarkMsgsAsReadResp) Reset() + func (x *MarkMsgsAsReadResp) String() string + type MsgClient interface + AppendStreamMsg func(ctx context.Context, in *AppendStreamMsgReq, opts ...grpc.CallOption) (*AppendStreamMsgResp, error) + ClearConversationsMsg func(ctx context.Context, in *ClearConversationsMsgReq, opts ...grpc.CallOption) (*ClearConversationsMsgResp, error) + ClearMsg func(ctx context.Context, in *ClearMsgReq, opts ...grpc.CallOption) (*ClearMsgResp, error) + DeleteMsgPhysical func(ctx context.Context, in *DeleteMsgPhysicalReq, opts ...grpc.CallOption) (*DeleteMsgPhysicalResp, error) + DeleteMsgPhysicalBySeq func(ctx context.Context, in *DeleteMsgPhysicalBySeqReq, opts ...grpc.CallOption) (*DeleteMsgPhysicalBySeqResp, error) + DeleteMsgs func(ctx context.Context, in *DeleteMsgsReq, opts ...grpc.CallOption) (*DeleteMsgsResp, error) + DestructMsgs func(ctx context.Context, in *DestructMsgsReq, opts ...grpc.CallOption) (*DestructMsgsResp, error) + GetActiveConversation func(ctx context.Context, in *GetActiveConversationReq, opts ...grpc.CallOption) (*GetActiveConversationResp, error) + GetActiveGroup func(ctx context.Context, in *GetActiveGroupReq, opts ...grpc.CallOption) (*GetActiveGroupResp, error) + GetActiveUser func(ctx context.Context, in *GetActiveUserReq, opts ...grpc.CallOption) (*GetActiveUserResp, error) + GetConversationMaxSeq func(ctx context.Context, in *GetConversationMaxSeqReq, opts ...grpc.CallOption) (*GetConversationMaxSeqResp, error) + GetConversationsHasReadAndMaxSeq func(ctx context.Context, in *GetConversationsHasReadAndMaxSeqReq, ...) (*GetConversationsHasReadAndMaxSeqResp, error) + GetHasReadSeqs func(ctx context.Context, in *GetHasReadSeqsReq, opts ...grpc.CallOption) (*SeqsInfoResp, error) + GetMaxSeq func(ctx context.Context, in *sdkws.GetMaxSeqReq, opts ...grpc.CallOption) (*sdkws.GetMaxSeqResp, error) + GetMaxSeqs func(ctx context.Context, in *GetMaxSeqsReq, opts ...grpc.CallOption) (*SeqsInfoResp, error) + GetMsgByConversationIDs func(ctx context.Context, in *GetMsgByConversationIDsReq, opts ...grpc.CallOption) (*GetMsgByConversationIDsResp, error) + GetSendMsgStatus func(ctx context.Context, in *GetSendMsgStatusReq, opts ...grpc.CallOption) (*GetSendMsgStatusResp, error) + GetSeqMessage func(ctx context.Context, in *GetSeqMessageReq, opts ...grpc.CallOption) (*GetSeqMessageResp, error) + GetServerTime func(ctx context.Context, in *GetServerTimeReq, opts ...grpc.CallOption) (*GetServerTimeResp, error) + GetStreamMsg func(ctx context.Context, in *GetStreamMsgReq, opts ...grpc.CallOption) (*GetStreamMsgResp, error) + MarkConversationAsRead func(ctx context.Context, in *MarkConversationAsReadReq, opts ...grpc.CallOption) (*MarkConversationAsReadResp, error) + MarkMsgsAsRead func(ctx context.Context, in *MarkMsgsAsReadReq, opts ...grpc.CallOption) (*MarkMsgsAsReadResp, error) + PullMessageBySeqs func(ctx context.Context, in *sdkws.PullMessageBySeqsReq, opts ...grpc.CallOption) (*sdkws.PullMessageBySeqsResp, error) + RevokeMsg func(ctx context.Context, in *RevokeMsgReq, opts ...grpc.CallOption) (*RevokeMsgResp, error) + SearchMessage func(ctx context.Context, in *SearchMessageReq, opts ...grpc.CallOption) (*SearchMessageResp, error) + SendMsg func(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error) + SetConversationHasReadSeq func(ctx context.Context, in *SetConversationHasReadSeqReq, opts ...grpc.CallOption) (*SetConversationHasReadSeqResp, error) + SetSendMsgStatus func(ctx context.Context, in *SetSendMsgStatusReq, opts ...grpc.CallOption) (*SetSendMsgStatusResp, error) + SetUserConversationsMinSeq func(ctx context.Context, in *SetUserConversationsMinSeqReq, ...) (*SetUserConversationsMinSeqResp, error) + UserClearAllMsg func(ctx context.Context, in *UserClearAllMsgReq, opts ...grpc.CallOption) (*UserClearAllMsgResp, error) + func NewMsgClient(cc grpc.ClientConnInterface) MsgClient + type MsgDataToDB struct + MsgData *sdkws.MsgData + func (*MsgDataToDB) Descriptor() ([]byte, []int) + func (*MsgDataToDB) ProtoMessage() + func (x *MsgDataToDB) GetMsgData() *sdkws.MsgData + func (x *MsgDataToDB) ProtoReflect() protoreflect.Message + func (x *MsgDataToDB) Reset() + func (x *MsgDataToDB) String() string + type MsgDataToMQ struct + MsgData *sdkws.MsgData + Token string + func (*MsgDataToMQ) Descriptor() ([]byte, []int) + func (*MsgDataToMQ) ProtoMessage() + func (x *MsgDataToMQ) GetMsgData() *sdkws.MsgData + func (x *MsgDataToMQ) GetToken() string + func (x *MsgDataToMQ) ProtoReflect() protoreflect.Message + func (x *MsgDataToMQ) Reset() + func (x *MsgDataToMQ) String() string + type MsgDataToModifyByMQ struct + ConversationID string + Messages []*sdkws.MsgData + func (*MsgDataToModifyByMQ) Descriptor() ([]byte, []int) + func (*MsgDataToModifyByMQ) ProtoMessage() + func (x *MsgDataToModifyByMQ) GetConversationID() string + func (x *MsgDataToModifyByMQ) GetMessages() []*sdkws.MsgData + func (x *MsgDataToModifyByMQ) ProtoReflect() protoreflect.Message + func (x *MsgDataToModifyByMQ) Reset() + func (x *MsgDataToModifyByMQ) String() string + type MsgDataToMongoByMQ struct + ConversationID string + LastSeq int64 + MsgData []*sdkws.MsgData + func (*MsgDataToMongoByMQ) Descriptor() ([]byte, []int) + func (*MsgDataToMongoByMQ) ProtoMessage() + func (x *MsgDataToMongoByMQ) GetConversationID() string + func (x *MsgDataToMongoByMQ) GetLastSeq() int64 + func (x *MsgDataToMongoByMQ) GetMsgData() []*sdkws.MsgData + func (x *MsgDataToMongoByMQ) ProtoReflect() protoreflect.Message + func (x *MsgDataToMongoByMQ) Reset() + func (x *MsgDataToMongoByMQ) String() string + type MsgServer interface + AppendStreamMsg func(context.Context, *AppendStreamMsgReq) (*AppendStreamMsgResp, error) + ClearConversationsMsg func(context.Context, *ClearConversationsMsgReq) (*ClearConversationsMsgResp, error) + ClearMsg func(context.Context, *ClearMsgReq) (*ClearMsgResp, error) + DeleteMsgPhysical func(context.Context, *DeleteMsgPhysicalReq) (*DeleteMsgPhysicalResp, error) + DeleteMsgPhysicalBySeq func(context.Context, *DeleteMsgPhysicalBySeqReq) (*DeleteMsgPhysicalBySeqResp, error) + DeleteMsgs func(context.Context, *DeleteMsgsReq) (*DeleteMsgsResp, error) + DestructMsgs func(context.Context, *DestructMsgsReq) (*DestructMsgsResp, error) + GetActiveConversation func(context.Context, *GetActiveConversationReq) (*GetActiveConversationResp, error) + GetActiveGroup func(context.Context, *GetActiveGroupReq) (*GetActiveGroupResp, error) + GetActiveUser func(context.Context, *GetActiveUserReq) (*GetActiveUserResp, error) + GetConversationMaxSeq func(context.Context, *GetConversationMaxSeqReq) (*GetConversationMaxSeqResp, error) + GetConversationsHasReadAndMaxSeq func(context.Context, *GetConversationsHasReadAndMaxSeqReq) (*GetConversationsHasReadAndMaxSeqResp, error) + GetHasReadSeqs func(context.Context, *GetHasReadSeqsReq) (*SeqsInfoResp, error) + GetMaxSeq func(context.Context, *sdkws.GetMaxSeqReq) (*sdkws.GetMaxSeqResp, error) + GetMaxSeqs func(context.Context, *GetMaxSeqsReq) (*SeqsInfoResp, error) + GetMsgByConversationIDs func(context.Context, *GetMsgByConversationIDsReq) (*GetMsgByConversationIDsResp, error) + GetSendMsgStatus func(context.Context, *GetSendMsgStatusReq) (*GetSendMsgStatusResp, error) + GetSeqMessage func(context.Context, *GetSeqMessageReq) (*GetSeqMessageResp, error) + GetServerTime func(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error) + GetStreamMsg func(context.Context, *GetStreamMsgReq) (*GetStreamMsgResp, error) + MarkConversationAsRead func(context.Context, *MarkConversationAsReadReq) (*MarkConversationAsReadResp, error) + MarkMsgsAsRead func(context.Context, *MarkMsgsAsReadReq) (*MarkMsgsAsReadResp, error) + PullMessageBySeqs func(context.Context, *sdkws.PullMessageBySeqsReq) (*sdkws.PullMessageBySeqsResp, error) + RevokeMsg func(context.Context, *RevokeMsgReq) (*RevokeMsgResp, error) + SearchMessage func(context.Context, *SearchMessageReq) (*SearchMessageResp, error) + SendMsg func(context.Context, *SendMsgReq) (*SendMsgResp, error) + SetConversationHasReadSeq func(context.Context, *SetConversationHasReadSeqReq) (*SetConversationHasReadSeqResp, error) + SetSendMsgStatus func(context.Context, *SetSendMsgStatusReq) (*SetSendMsgStatusResp, error) + SetUserConversationsMinSeq func(context.Context, *SetUserConversationsMinSeqReq) (*SetUserConversationsMinSeqResp, error) + UserClearAllMsg func(context.Context, *UserClearAllMsgReq) (*UserClearAllMsgResp, error) + type PushMsgDataToMQ struct + ConversationID string + MsgData *sdkws.MsgData + func (*PushMsgDataToMQ) Descriptor() ([]byte, []int) + func (*PushMsgDataToMQ) ProtoMessage() + func (x *PushMsgDataToMQ) GetConversationID() string + func (x *PushMsgDataToMQ) GetMsgData() *sdkws.MsgData + func (x *PushMsgDataToMQ) ProtoReflect() protoreflect.Message + func (x *PushMsgDataToMQ) Reset() + func (x *PushMsgDataToMQ) String() string + type RevokeMsgReq struct + ConversationID string + Seq int64 + UserID string + func (*RevokeMsgReq) Descriptor() ([]byte, []int) + func (*RevokeMsgReq) ProtoMessage() + func (x *RevokeMsgReq) Check() error + func (x *RevokeMsgReq) GetConversationID() string + func (x *RevokeMsgReq) GetSeq() int64 + func (x *RevokeMsgReq) GetUserID() string + func (x *RevokeMsgReq) ProtoReflect() protoreflect.Message + func (x *RevokeMsgReq) Reset() + func (x *RevokeMsgReq) String() string + type RevokeMsgResp struct + func (*RevokeMsgResp) Descriptor() ([]byte, []int) + func (*RevokeMsgResp) ProtoMessage() + func (x *RevokeMsgResp) ProtoReflect() protoreflect.Message + func (x *RevokeMsgResp) Reset() + func (x *RevokeMsgResp) String() string + type SearchChatLog struct + ChatLog *ChatLog + IsRevoked bool + func (*SearchChatLog) Descriptor() ([]byte, []int) + func (*SearchChatLog) ProtoMessage() + func (x *SearchChatLog) GetChatLog() *ChatLog + func (x *SearchChatLog) GetIsRevoked() bool + func (x *SearchChatLog) ProtoReflect() protoreflect.Message + func (x *SearchChatLog) Reset() + func (x *SearchChatLog) String() string + type SearchMessageReq struct + ContentType int32 + Pagination *sdkws.RequestPagination + RecvID string + SendID string + SendTime string + SessionType int32 + func (*SearchMessageReq) Descriptor() ([]byte, []int) + func (*SearchMessageReq) ProtoMessage() + 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 (x *SearchMessageReq) ProtoReflect() protoreflect.Message + func (x *SearchMessageReq) Reset() + func (x *SearchMessageReq) String() string + type SearchMessageResp struct + ChatLogs []*SearchChatLog + ChatLogsNum int32 + func (*SearchMessageResp) Descriptor() ([]byte, []int) + func (*SearchMessageResp) ProtoMessage() + func (x *SearchMessageResp) GetChatLogs() []*SearchChatLog + func (x *SearchMessageResp) GetChatLogsNum() int32 + func (x *SearchMessageResp) ProtoReflect() protoreflect.Message + func (x *SearchMessageResp) Reset() + func (x *SearchMessageResp) String() string + type SearchedMsgData struct + IsRevoked bool + MsgData *sdkws.MsgData + func (*SearchedMsgData) Descriptor() ([]byte, []int) + func (*SearchedMsgData) ProtoMessage() + func (x *SearchedMsgData) GetIsRevoked() bool + func (x *SearchedMsgData) GetMsgData() *sdkws.MsgData + func (x *SearchedMsgData) ProtoReflect() protoreflect.Message + func (x *SearchedMsgData) Reset() + func (x *SearchedMsgData) String() string + type SendMsgReq struct + MsgData *sdkws.MsgData + func (*SendMsgReq) Descriptor() ([]byte, []int) + func (*SendMsgReq) ProtoMessage() + func (x *SendMsgReq) Check() error + func (x *SendMsgReq) GetMsgData() *sdkws.MsgData + func (x *SendMsgReq) ProtoReflect() protoreflect.Message + func (x *SendMsgReq) Reset() + func (x *SendMsgReq) String() string + type SendMsgResp struct + ClientMsgID string + SendTime int64 + ServerMsgID string + func (*SendMsgResp) Descriptor() ([]byte, []int) + func (*SendMsgResp) ProtoMessage() + func (x *SendMsgResp) GetClientMsgID() string + func (x *SendMsgResp) GetSendTime() int64 + func (x *SendMsgResp) GetServerMsgID() string + func (x *SendMsgResp) ProtoReflect() protoreflect.Message + func (x *SendMsgResp) Reset() + func (x *SendMsgResp) String() string + type Seqs struct + HasReadSeq int64 + MaxSeq int64 + MaxSeqTime int64 + func (*Seqs) Descriptor() ([]byte, []int) + func (*Seqs) ProtoMessage() + func (x *Seqs) GetHasReadSeq() int64 + func (x *Seqs) GetMaxSeq() int64 + func (x *Seqs) GetMaxSeqTime() int64 + func (x *Seqs) ProtoReflect() protoreflect.Message + func (x *Seqs) Reset() + func (x *Seqs) String() string + type SeqsInfoResp struct + MaxSeqs map[string]int64 + func (*SeqsInfoResp) Descriptor() ([]byte, []int) + func (*SeqsInfoResp) ProtoMessage() + func (x *SeqsInfoResp) Format() any + func (x *SeqsInfoResp) GetMaxSeqs() map[string]int64 + func (x *SeqsInfoResp) ProtoReflect() protoreflect.Message + func (x *SeqsInfoResp) Reset() + func (x *SeqsInfoResp) String() string + type SetConversationHasReadSeqReq struct + ConversationID string + HasReadSeq int64 + NoNotification bool + UserID string + func (*SetConversationHasReadSeqReq) Descriptor() ([]byte, []int) + func (*SetConversationHasReadSeqReq) ProtoMessage() + func (x *SetConversationHasReadSeqReq) Check() error + func (x *SetConversationHasReadSeqReq) GetConversationID() string + func (x *SetConversationHasReadSeqReq) GetHasReadSeq() int64 + func (x *SetConversationHasReadSeqReq) GetNoNotification() bool + func (x *SetConversationHasReadSeqReq) GetUserID() string + func (x *SetConversationHasReadSeqReq) ProtoReflect() protoreflect.Message + func (x *SetConversationHasReadSeqReq) Reset() + func (x *SetConversationHasReadSeqReq) String() string + type SetConversationHasReadSeqResp struct + func (*SetConversationHasReadSeqResp) Descriptor() ([]byte, []int) + func (*SetConversationHasReadSeqResp) ProtoMessage() + func (x *SetConversationHasReadSeqResp) ProtoReflect() protoreflect.Message + func (x *SetConversationHasReadSeqResp) Reset() + func (x *SetConversationHasReadSeqResp) String() string + type SetSendMsgStatusReq struct + Status int32 + func (*SetSendMsgStatusReq) Descriptor() ([]byte, []int) + func (*SetSendMsgStatusReq) ProtoMessage() + func (x *SetSendMsgStatusReq) Check() error + func (x *SetSendMsgStatusReq) GetStatus() int32 + func (x *SetSendMsgStatusReq) ProtoReflect() protoreflect.Message + func (x *SetSendMsgStatusReq) Reset() + func (x *SetSendMsgStatusReq) String() string + type SetSendMsgStatusResp struct + func (*SetSendMsgStatusResp) Descriptor() ([]byte, []int) + func (*SetSendMsgStatusResp) ProtoMessage() + func (x *SetSendMsgStatusResp) ProtoReflect() protoreflect.Message + func (x *SetSendMsgStatusResp) Reset() + func (x *SetSendMsgStatusResp) String() string + type SetUserConversationsMinSeqReq struct + ConversationID string + Seq int64 + UserIDs []string + func (*SetUserConversationsMinSeqReq) Descriptor() ([]byte, []int) + func (*SetUserConversationsMinSeqReq) ProtoMessage() + func (x *SetUserConversationsMinSeqReq) GetConversationID() string + func (x *SetUserConversationsMinSeqReq) GetSeq() int64 + func (x *SetUserConversationsMinSeqReq) GetUserIDs() []string + func (x *SetUserConversationsMinSeqReq) ProtoReflect() protoreflect.Message + func (x *SetUserConversationsMinSeqReq) Reset() + func (x *SetUserConversationsMinSeqReq) String() string + type SetUserConversationsMinSeqResp struct + func (*SetUserConversationsMinSeqResp) Descriptor() ([]byte, []int) + func (*SetUserConversationsMinSeqResp) ProtoMessage() + func (x *SetUserConversationsMinSeqResp) ProtoReflect() protoreflect.Message + func (x *SetUserConversationsMinSeqResp) Reset() + func (x *SetUserConversationsMinSeqResp) String() string + type UnimplementedMsgServer struct + func (*UnimplementedMsgServer) AppendStreamMsg(context.Context, *AppendStreamMsgReq) (*AppendStreamMsgResp, error) + 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) DestructMsgs(context.Context, *DestructMsgsReq) (*DestructMsgsResp, error) + func (*UnimplementedMsgServer) GetActiveConversation(context.Context, *GetActiveConversationReq) (*GetActiveConversationResp, 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) GetSeqMessage(context.Context, *GetSeqMessageReq) (*GetSeqMessageResp, error) + func (*UnimplementedMsgServer) GetServerTime(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error) + func (*UnimplementedMsgServer) GetStreamMsg(context.Context, *GetStreamMsgReq) (*GetStreamMsgResp, 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) SetUserConversationsMinSeq(context.Context, *SetUserConversationsMinSeqReq) (*SetUserConversationsMinSeqResp, error) + func (*UnimplementedMsgServer) UserClearAllMsg(context.Context, *UserClearAllMsgReq) (*UserClearAllMsgResp, error) + type UserClearAllMsgReq struct + DeleteSyncOpt *DeleteSyncOpt + UserID string + func (*UserClearAllMsgReq) Descriptor() ([]byte, []int) + func (*UserClearAllMsgReq) ProtoMessage() + func (x *UserClearAllMsgReq) Check() error + func (x *UserClearAllMsgReq) GetDeleteSyncOpt() *DeleteSyncOpt + func (x *UserClearAllMsgReq) GetUserID() string + func (x *UserClearAllMsgReq) ProtoReflect() protoreflect.Message + func (x *UserClearAllMsgReq) Reset() + func (x *UserClearAllMsgReq) String() string + type UserClearAllMsgResp struct + func (*UserClearAllMsgResp) Descriptor() ([]byte, []int) + func (*UserClearAllMsgResp) ProtoMessage() + func (x *UserClearAllMsgResp) ProtoReflect() protoreflect.Message + func (x *UserClearAllMsgResp) Reset() + func (x *UserClearAllMsgResp) String() string
Go to main page