msg

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Msg_GetMaxSeq_FullMethodName                        = "/openim.msg.msg/GetMaxSeq"
	Msg_GetMaxSeqs_FullMethodName                       = "/openim.msg.msg/GetMaxSeqs"
	Msg_GetHasReadSeqs_FullMethodName                   = "/openim.msg.msg/GetHasReadSeqs"
	Msg_GetMsgByConversationIDs_FullMethodName          = "/openim.msg.msg/GetMsgByConversationIDs"
	Msg_GetConversationMaxSeq_FullMethodName            = "/openim.msg.msg/GetConversationMaxSeq"
	Msg_PullMessageBySeqs_FullMethodName                = "/openim.msg.msg/PullMessageBySeqs"
	Msg_GetSeqMessage_FullMethodName                    = "/openim.msg.msg/GetSeqMessage"
	Msg_SearchMessage_FullMethodName                    = "/openim.msg.msg/SearchMessage"
	Msg_SendMsg_FullMethodName                          = "/openim.msg.msg/SendMsg"
	Msg_SetUserConversationsMinSeq_FullMethodName       = "/openim.msg.msg/SetUserConversationsMinSeq"
	Msg_ClearConversationsMsg_FullMethodName            = "/openim.msg.msg/ClearConversationsMsg"
	Msg_UserClearAllMsg_FullMethodName                  = "/openim.msg.msg/UserClearAllMsg"
	Msg_DeleteMsgs_FullMethodName                       = "/openim.msg.msg/DeleteMsgs"
	Msg_DeleteMsgPhysicalBySeq_FullMethodName           = "/openim.msg.msg/DeleteMsgPhysicalBySeq"
	Msg_DeleteMsgPhysical_FullMethodName                = "/openim.msg.msg/DeleteMsgPhysical"
	Msg_SetSendMsgStatus_FullMethodName                 = "/openim.msg.msg/SetSendMsgStatus"
	Msg_GetSendMsgStatus_FullMethodName                 = "/openim.msg.msg/GetSendMsgStatus"
	Msg_RevokeMsg_FullMethodName                        = "/openim.msg.msg/RevokeMsg"
	Msg_MarkMsgsAsRead_FullMethodName                   = "/openim.msg.msg/MarkMsgsAsRead"
	Msg_MarkConversationAsRead_FullMethodName           = "/openim.msg.msg/MarkConversationAsRead"
	Msg_SetConversationHasReadSeq_FullMethodName        = "/openim.msg.msg/SetConversationHasReadSeq"
	Msg_GetConversationsHasReadAndMaxSeq_FullMethodName = "/openim.msg.msg/GetConversationsHasReadAndMaxSeq"
	Msg_GetActiveUser_FullMethodName                    = "/openim.msg.msg/GetActiveUser"
	Msg_GetActiveGroup_FullMethodName                   = "/openim.msg.msg/GetActiveGroup"
	Msg_GetServerTime_FullMethodName                    = "/openim.msg.msg/GetServerTime"
	Msg_ClearMsg_FullMethodName                         = "/openim.msg.msg/ClearMsg"
	Msg_DestructMsgs_FullMethodName                     = "/openim.msg.msg/DestructMsgs"
)

Variables

View Source 
var File_msg_msg_proto protoreflect.FileDescriptor
View Source 
var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "openim.msg.msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMaxSeq",
			Handler:    _Msg_GetMaxSeq_Handler,
		},
		{
			MethodName: "GetMaxSeqs",
			Handler:    _Msg_GetMaxSeqs_Handler,
		},
		{
			MethodName: "GetHasReadSeqs",
			Handler:    _Msg_GetHasReadSeqs_Handler,
		},
		{
			MethodName: "GetMsgByConversationIDs",
			Handler:    _Msg_GetMsgByConversationIDs_Handler,
		},
		{
			MethodName: "GetConversationMaxSeq",
			Handler:    _Msg_GetConversationMaxSeq_Handler,
		},
		{
			MethodName: "PullMessageBySeqs",
			Handler:    _Msg_PullMessageBySeqs_Handler,
		},
		{
			MethodName: "GetSeqMessage",
			Handler:    _Msg_GetSeqMessage_Handler,
		},
		{
			MethodName: "SearchMessage",
			Handler:    _Msg_SearchMessage_Handler,
		},
		{
			MethodName: "SendMsg",
			Handler:    _Msg_SendMsg_Handler,
		},
		{
			MethodName: "SetUserConversationsMinSeq",
			Handler:    _Msg_SetUserConversationsMinSeq_Handler,
		},
		{
			MethodName: "ClearConversationsMsg",
			Handler:    _Msg_ClearConversationsMsg_Handler,
		},
		{
			MethodName: "UserClearAllMsg",
			Handler:    _Msg_UserClearAllMsg_Handler,
		},
		{
			MethodName: "DeleteMsgs",
			Handler:    _Msg_DeleteMsgs_Handler,
		},
		{
			MethodName: "DeleteMsgPhysicalBySeq",
			Handler:    _Msg_DeleteMsgPhysicalBySeq_Handler,
		},
		{
			MethodName: "DeleteMsgPhysical",
			Handler:    _Msg_DeleteMsgPhysical_Handler,
		},
		{
			MethodName: "SetSendMsgStatus",
			Handler:    _Msg_SetSendMsgStatus_Handler,
		},
		{
			MethodName: "GetSendMsgStatus",
			Handler:    _Msg_GetSendMsgStatus_Handler,
		},
		{
			MethodName: "RevokeMsg",
			Handler:    _Msg_RevokeMsg_Handler,
		},
		{
			MethodName: "MarkMsgsAsRead",
			Handler:    _Msg_MarkMsgsAsRead_Handler,
		},
		{
			MethodName: "MarkConversationAsRead",
			Handler:    _Msg_MarkConversationAsRead_Handler,
		},
		{
			MethodName: "SetConversationHasReadSeq",
			Handler:    _Msg_SetConversationHasReadSeq_Handler,
		},
		{
			MethodName: "GetConversationsHasReadAndMaxSeq",
			Handler:    _Msg_GetConversationsHasReadAndMaxSeq_Handler,
		},
		{
			MethodName: "GetActiveUser",
			Handler:    _Msg_GetActiveUser_Handler,
		},
		{
			MethodName: "GetActiveGroup",
			Handler:    _Msg_GetActiveGroup_Handler,
		},
		{
			MethodName: "GetServerTime",
			Handler:    _Msg_GetServerTime_Handler,
		},
		{
			MethodName: "ClearMsg",
			Handler:    _Msg_ClearMsg_Handler,
		},
		{
			MethodName: "DestructMsgs",
			Handler:    _Msg_DestructMsgs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "msg/msg.proto",
}

Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMsgServer 

func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)

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) Descriptor() ([]byte, []int)

Deprecated: Use ChatLog.ProtoReflect.Descriptor instead.

func (*ChatLog) GetClientMsgID 

func (x *ChatLog) GetClientMsgID() string

func (*ChatLog) GetContent 

func (x *ChatLog) GetContent() string

func (*ChatLog) GetContentType 

func (x *ChatLog) GetContentType() int32

func (*ChatLog) GetCreateTime 

func (x *ChatLog) GetCreateTime() int64

func (*ChatLog) GetEx 

func (x *ChatLog) GetEx() string

func (*ChatLog) GetGroupFaceURL 

func (x *ChatLog) GetGroupFaceURL() string

func (*ChatLog) GetGroupID 

func (x *ChatLog) GetGroupID() string

func (*ChatLog) GetGroupMemberCount 

func (x *ChatLog) GetGroupMemberCount() uint32

func (*ChatLog) GetGroupName 

func (x *ChatLog) GetGroupName() string

func (*ChatLog) GetGroupOwner 

func (x *ChatLog) GetGroupOwner() string

func (*ChatLog) GetGroupType 

func (x *ChatLog) GetGroupType() int32

func (*ChatLog) GetMsgFrom 

func (x *ChatLog) GetMsgFrom() int32

func (*ChatLog) GetRecvID 

func (x *ChatLog) GetRecvID() string

func (*ChatLog) GetRecvNickname 

func (x *ChatLog) GetRecvNickname() string

func (*ChatLog) GetSendID 

func (x *ChatLog) GetSendID() string

func (*ChatLog) GetSendTime 

func (x *ChatLog) GetSendTime() int64

func (*ChatLog) GetSenderFaceURL 

func (x *ChatLog) GetSenderFaceURL() string

func (*ChatLog) GetSenderNickname 

func (x *ChatLog) GetSenderNickname() string

func (*ChatLog) GetSenderPlatformID 

func (x *ChatLog) GetSenderPlatformID() int32

func (*ChatLog) GetSeq 

func (x *ChatLog) GetSeq() int64

func (*ChatLog) GetServerMsgID 

func (x *ChatLog) GetServerMsgID() string

func (*ChatLog) GetSessionType 

func (x *ChatLog) GetSessionType() int32

func (*ChatLog) GetStatus 

func (x *ChatLog) GetStatus() int32

func (*ChatLog) ProtoMessage 

func (*ChatLog) ProtoMessage()

func (*ChatLog) ProtoReflect 

func (x *ChatLog) ProtoReflect() protoreflect.Message

func (*ChatLog) Reset 

func (x *ChatLog) Reset()

func (*ChatLog) String 

func (x *ChatLog) String() string

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 

type ClearMsgReq struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp"`
	// contains filtered or unexported fields
}

func (*ClearMsgReq) Descriptor deprecated 

func (*ClearMsgReq) Descriptor() ([]byte, []int)

Deprecated: Use ClearMsgReq.ProtoReflect.Descriptor instead.

func (*ClearMsgReq) GetTimestamp 

func (x *ClearMsgReq) GetTimestamp() int64

func (*ClearMsgReq) ProtoMessage 

func (*ClearMsgReq) ProtoMessage()

func (*ClearMsgReq) ProtoReflect 

func (x *ClearMsgReq) ProtoReflect() protoreflect.Message

func (*ClearMsgReq) Reset 

func (x *ClearMsgReq) Reset()

func (*ClearMsgReq) String 

func (x *ClearMsgReq) String() string

type ClearMsgResp 

type ClearMsgResp struct {
	// contains filtered or unexported fields
}

func (*ClearMsgResp) Descriptor deprecated 

func (*ClearMsgResp) Descriptor() ([]byte, []int)

Deprecated: Use ClearMsgResp.ProtoReflect.Descriptor instead.

func (*ClearMsgResp) ProtoMessage 

func (*ClearMsgResp) ProtoMessage()

func (*ClearMsgResp) ProtoReflect 

func (x *ClearMsgResp) ProtoReflect() protoreflect.Message

func (*ClearMsgResp) Reset 

func (x *ClearMsgResp) Reset()

func (*ClearMsgResp) String 

func (x *ClearMsgResp) String() string

type ConversationSeqs 

type ConversationSeqs struct {
	ConversationID string  `protobuf:"bytes,2,opt,name=conversationID,proto3" json:"conversationID"`
	Seqs           []int64 `protobuf:"varint,3,rep,packed,name=seqs,proto3" json:"seqs"`
	// contains filtered or unexported fields
}

func (*ConversationSeqs) Descriptor deprecated 

func (*ConversationSeqs) Descriptor() ([]byte, []int)

Deprecated: Use ConversationSeqs.ProtoReflect.Descriptor instead.

func (*ConversationSeqs) GetConversationID 

func (x *ConversationSeqs) GetConversationID() string

func (*ConversationSeqs) GetSeqs 

func (x *ConversationSeqs) GetSeqs() []int64

func (*ConversationSeqs) ProtoMessage 

func (*ConversationSeqs) ProtoMessage()

func (*ConversationSeqs) ProtoReflect 

func (x *ConversationSeqs) ProtoReflect() protoreflect.Message

func (*ConversationSeqs) Reset 

func (x *ConversationSeqs) Reset()

func (*ConversationSeqs) String 

func (x *ConversationSeqs) 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 DestructMsgsReq 

type DestructMsgsReq struct {
	Conversations []*conversation.Conversation `protobuf:"bytes,1,rep,name=conversations,proto3" json:"conversations"`
	// contains filtered or unexported fields
}

func (*DestructMsgsReq) Descriptor deprecated 

func (*DestructMsgsReq) Descriptor() ([]byte, []int)

Deprecated: Use DestructMsgsReq.ProtoReflect.Descriptor instead.

func (*DestructMsgsReq) GetConversations 

func (x *DestructMsgsReq) GetConversations() []*conversation.Conversation

func (*DestructMsgsReq) ProtoMessage 

func (*DestructMsgsReq) ProtoMessage()

func (*DestructMsgsReq) ProtoReflect 

func (x *DestructMsgsReq) ProtoReflect() protoreflect.Message

func (*DestructMsgsReq) Reset 

func (x *DestructMsgsReq) Reset()

func (*DestructMsgsReq) String 

func (x *DestructMsgsReq) String() string

type DestructMsgsResp 

type DestructMsgsResp struct {
	// contains filtered or unexported fields
}

func (*DestructMsgsResp) Descriptor deprecated 

func (*DestructMsgsResp) Descriptor() ([]byte, []int)

Deprecated: Use DestructMsgsResp.ProtoReflect.Descriptor instead.

func (*DestructMsgsResp) ProtoMessage 

func (*DestructMsgsResp) ProtoMessage()

func (*DestructMsgsResp) ProtoReflect 

func (x *DestructMsgsResp) ProtoReflect() protoreflect.Message

func (*DestructMsgsResp) Reset 

func (x *DestructMsgsResp) Reset()

func (*DestructMsgsResp) String 

func (x *DestructMsgsResp) 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) Format 

func (x *GetConversationMaxSeqResp) Format() any

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) Format 

func (x *GetConversationsHasReadAndMaxSeqResp) Format() any

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,1,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 GetSeqMessageReq 

type GetSeqMessageReq struct {
	UserID        string              `protobuf:"bytes,1,opt,name=userID,proto3" json:"userID"`
	Conversations []*ConversationSeqs `protobuf:"bytes,2,rep,name=conversations,proto3" json:"conversations"`
	// contains filtered or unexported fields
}

func (*GetSeqMessageReq) Descriptor deprecated 

func (*GetSeqMessageReq) Descriptor() ([]byte, []int)

Deprecated: Use GetSeqMessageReq.ProtoReflect.Descriptor instead.

func (*GetSeqMessageReq) GetConversations 

func (x *GetSeqMessageReq) GetConversations() []*ConversationSeqs

func (*GetSeqMessageReq) GetUserID 

func (x *GetSeqMessageReq) GetUserID() string

func (*GetSeqMessageReq) ProtoMessage 

func (*GetSeqMessageReq) ProtoMessage()

func (*GetSeqMessageReq) ProtoReflect 

func (x *GetSeqMessageReq) ProtoReflect() protoreflect.Message

func (*GetSeqMessageReq) Reset 

func (x *GetSeqMessageReq) Reset()

func (*GetSeqMessageReq) String 

func (x *GetSeqMessageReq) String() string

type GetSeqMessageResp 

type GetSeqMessageResp struct {
	Msgs             map[string]*sdkws.PullMsgs `` /* 149-byte string literal not displayed */
	NotificationMsgs map[string]*sdkws.PullMsgs `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSeqMessageResp) Descriptor deprecated 

func (*GetSeqMessageResp) Descriptor() ([]byte, []int)

Deprecated: Use GetSeqMessageResp.ProtoReflect.Descriptor instead.

func (*GetSeqMessageResp) GetMsgs 

func (x *GetSeqMessageResp) GetMsgs() map[string]*sdkws.PullMsgs

func (*GetSeqMessageResp) GetNotificationMsgs 

func (x *GetSeqMessageResp) GetNotificationMsgs() map[string]*sdkws.PullMsgs

func (*GetSeqMessageResp) ProtoMessage 

func (*GetSeqMessageResp) ProtoMessage()

func (*GetSeqMessageResp) ProtoReflect 

func (x *GetSeqMessageResp) ProtoReflect() protoreflect.Message

func (*GetSeqMessageResp) Reset 

func (x *GetSeqMessageResp) Reset()

func (*GetSeqMessageResp) String 

func (x *GetSeqMessageResp) 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)
	GetSeqMessage(ctx context.Context, in *GetSeqMessageReq, opts ...grpc.CallOption) (*GetSeqMessageResp, error)
	SearchMessage(ctx context.Context, in *SearchMessageReq, opts ...grpc.CallOption) (*SearchMessageResp, error)
	// 发送消息
	SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error)
	SetUserConversationsMinSeq(ctx context.Context, in *SetUserConversationsMinSeqReq, opts ...grpc.CallOption) (*SetUserConversationsMinSeqResp, 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)
	DestructMsgs(ctx context.Context, in *DestructMsgsReq, opts ...grpc.CallOption) (*DestructMsgsResp, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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)
	GetSeqMessage(context.Context, *GetSeqMessageReq) (*GetSeqMessageResp, error)
	SearchMessage(context.Context, *SearchMessageReq) (*SearchMessageResp, error)
	// 发送消息
	SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
	SetUserConversationsMinSeq(context.Context, *SetUserConversationsMinSeqReq) (*SetUserConversationsMinSeqResp, 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)
	DestructMsgs(context.Context, *DestructMsgsReq) (*DestructMsgsResp, error)
}

MsgServer is the server API for Msg service. All implementations should embed UnimplementedMsgServer for forward compatibility.

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) Descriptor() ([]byte, []int)

Deprecated: Use Seqs.ProtoReflect.Descriptor instead.

func (*Seqs) GetHasReadSeq 

func (x *Seqs) GetHasReadSeq() int64

func (*Seqs) GetMaxSeq 

func (x *Seqs) GetMaxSeq() int64

func (*Seqs) ProtoMessage 

func (*Seqs) ProtoMessage()

func (*Seqs) ProtoReflect 

func (x *Seqs) ProtoReflect() protoreflect.Message

func (*Seqs) Reset 

func (x *Seqs) Reset()

func (*Seqs) String 

func (x *Seqs) String() string

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) Format 

func (x *SeqsInfoResp) Format() any

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"`
	NoNotification bool   `protobuf:"varint,4,opt,name=noNotification,proto3" json:"noNotification"`
	// 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) GetNoNotification 

func (x *SetConversationHasReadSeqReq) GetNoNotification() bool

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 SetUserConversationsMinSeqReq 

type SetUserConversationsMinSeqReq struct {
	UserIDs        []string `protobuf:"bytes,1,rep,name=userIDs,proto3" json:"userIDs"`
	ConversationID string   `protobuf:"bytes,2,opt,name=conversationID,proto3" json:"conversationID"`
	Seq            int64    `protobuf:"varint,3,opt,name=seq,proto3" json:"seq"`
	// contains filtered or unexported fields
}

func (*SetUserConversationsMinSeqReq) Descriptor deprecated 

func (*SetUserConversationsMinSeqReq) Descriptor() ([]byte, []int)

Deprecated: Use SetUserConversationsMinSeqReq.ProtoReflect.Descriptor instead.

func (*SetUserConversationsMinSeqReq) GetConversationID 

func (x *SetUserConversationsMinSeqReq) GetConversationID() string

func (*SetUserConversationsMinSeqReq) GetSeq 

func (x *SetUserConversationsMinSeqReq) GetSeq() int64

func (*SetUserConversationsMinSeqReq) GetUserIDs 

func (x *SetUserConversationsMinSeqReq) GetUserIDs() []string

func (*SetUserConversationsMinSeqReq) ProtoMessage 

func (*SetUserConversationsMinSeqReq) ProtoMessage()

func (*SetUserConversationsMinSeqReq) ProtoReflect 

func (x *SetUserConversationsMinSeqReq) ProtoReflect() protoreflect.Message

func (*SetUserConversationsMinSeqReq) Reset 

func (x *SetUserConversationsMinSeqReq) Reset()

func (*SetUserConversationsMinSeqReq) String 

func (x *SetUserConversationsMinSeqReq) String() string

type SetUserConversationsMinSeqResp 

type SetUserConversationsMinSeqResp struct {
	// contains filtered or unexported fields
}

func (*SetUserConversationsMinSeqResp) Descriptor deprecated 

func (*SetUserConversationsMinSeqResp) Descriptor() ([]byte, []int)

Deprecated: Use SetUserConversationsMinSeqResp.ProtoReflect.Descriptor instead.

func (*SetUserConversationsMinSeqResp) ProtoMessage 

func (*SetUserConversationsMinSeqResp) ProtoMessage()

func (*SetUserConversationsMinSeqResp) ProtoReflect 

func (x *SetUserConversationsMinSeqResp) ProtoReflect() protoreflect.Message

func (*SetUserConversationsMinSeqResp) Reset 

func (x *SetUserConversationsMinSeqResp) Reset()

func (*SetUserConversationsMinSeqResp) String 

func (x *SetUserConversationsMinSeqResp) String() string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct{}

UnimplementedMsgServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMsgServer) ClearConversationsMsg 

func (UnimplementedMsgServer) ClearConversationsMsg(context.Context, *ClearConversationsMsgReq) (*ClearConversationsMsgResp, error)

func (UnimplementedMsgServer) ClearMsg 

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) DestructMsgs 

func (UnimplementedMsgServer) DestructMsgs(context.Context, *DestructMsgsReq) (*DestructMsgsResp, 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) GetSeqMessage 

func (UnimplementedMsgServer) GetSeqMessage(context.Context, *GetSeqMessageReq) (*GetSeqMessageResp, 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) SetUserConversationsMinSeq 

func (UnimplementedMsgServer) SetUserConversationsMinSeq(context.Context, *SetUserConversationsMinSeqReq) (*SetUserConversationsMinSeqResp, error)

func (UnimplementedMsgServer) UserClearAllMsg 

func (UnimplementedMsgServer) UserClearAllMsg(context.Context, *UserClearAllMsgReq) (*UserClearAllMsgResp, error)

type UnsafeMsgServer 

type UnsafeMsgServer interface {
	// contains filtered or unexported methods
}

UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.