msg

package
v0.0.72-alpha.69 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2024 License: Apache-2.0 Imports: 13 Imported by: 7

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"
	Msg_GetActiveConversation_FullMethodName            = "/openim.msg.msg/GetActiveConversation"
	Msg_AppendStreamMsg_FullMethodName                  = "/openim.msg.msg/AppendStreamMsg"
	Msg_GetStreamMsg_FullMethodName                     = "/openim.msg.msg/GetStreamMsg"
	Msg_SetUserConversationMaxSeq_FullMethodName        = "/openim.msg.msg/SetUserConversationMaxSeq"
	Msg_SetUserConversationMinSeq_FullMethodName        = "/openim.msg.msg/SetUserConversationMinSeq"
	Msg_GetLastMessageSeqByTime_FullMethodName          = "/openim.msg.msg/GetLastMessageSeqByTime"
)

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,
		},
		{
			MethodName: "GetActiveConversation",
			Handler:    _Msg_GetActiveConversation_Handler,
		},
		{
			MethodName: "AppendStreamMsg",
			Handler:    _Msg_AppendStreamMsg_Handler,
		},
		{
			MethodName: "GetStreamMsg",
			Handler:    _Msg_GetStreamMsg_Handler,
		},
		{
			MethodName: "SetUserConversationMaxSeq",
			Handler:    _Msg_SetUserConversationMaxSeq_Handler,
		},
		{
			MethodName: "SetUserConversationMinSeq",
			Handler:    _Msg_SetUserConversationMinSeq_Handler,
		},
		{
			MethodName: "GetLastMessageSeqByTime",
			Handler:    _Msg_GetLastMessageSeqByTime_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 ActiveConversation added in v0.0.72 

type ActiveConversation struct {
	ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"`
	LastTime       int64  `protobuf:"varint,2,opt,name=lastTime,proto3" json:"lastTime"`
	MaxSeq         int64  `protobuf:"varint,3,opt,name=maxSeq,proto3" json:"maxSeq"`
	// contains filtered or unexported fields
}

func (*ActiveConversation) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use ActiveConversation.ProtoReflect.Descriptor instead.

func (*ActiveConversation) GetConversationID added in v0.0.72 

func (x *ActiveConversation) GetConversationID() string

func (*ActiveConversation) GetLastTime added in v0.0.72 

func (x *ActiveConversation) GetLastTime() int64

func (*ActiveConversation) GetMaxSeq added in v0.0.72 

func (x *ActiveConversation) GetMaxSeq() int64

func (*ActiveConversation) ProtoMessage added in v0.0.72 

func (*ActiveConversation) ProtoMessage()

func (*ActiveConversation) ProtoReflect added in v0.0.72 

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

func (*ActiveConversation) Reset added in v0.0.72 

func (x *ActiveConversation) Reset()

func (*ActiveConversation) String added in v0.0.72 

func (x *ActiveConversation) String() string

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 AppendStreamMsgReq 

type AppendStreamMsgReq struct {
	ClientMsgID string   `protobuf:"bytes,1,opt,name=clientMsgID,proto3" json:"clientMsgID"`
	StartIndex  int64    `protobuf:"varint,2,opt,name=startIndex,proto3" json:"startIndex"`
	Packets     []string `protobuf:"bytes,3,rep,name=packets,proto3" json:"packets"`
	End         bool     `protobuf:"varint,4,opt,name=end,proto3" json:"end"`
	// contains filtered or unexported fields
}

func (*AppendStreamMsgReq) Descriptor deprecated 

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

Deprecated: Use AppendStreamMsgReq.ProtoReflect.Descriptor instead.

func (*AppendStreamMsgReq) GetClientMsgID 

func (x *AppendStreamMsgReq) GetClientMsgID() string

func (*AppendStreamMsgReq) GetEnd 

func (x *AppendStreamMsgReq) GetEnd() bool

func (*AppendStreamMsgReq) GetPackets 

func (x *AppendStreamMsgReq) GetPackets() []string

func (*AppendStreamMsgReq) GetStartIndex 

func (x *AppendStreamMsgReq) GetStartIndex() int64

func (*AppendStreamMsgReq) ProtoMessage 

func (*AppendStreamMsgReq) ProtoMessage()

func (*AppendStreamMsgReq) ProtoReflect 

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

func (*AppendStreamMsgReq) Reset 

func (x *AppendStreamMsgReq) Reset()

func (*AppendStreamMsgReq) String 

func (x *AppendStreamMsgReq) String() string

type AppendStreamMsgResp 

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

func (*AppendStreamMsgResp) Descriptor deprecated 

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

Deprecated: Use AppendStreamMsgResp.ProtoReflect.Descriptor instead.

func (*AppendStreamMsgResp) ProtoMessage 

func (*AppendStreamMsgResp) ProtoMessage()

func (*AppendStreamMsgResp) ProtoReflect 

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

func (*AppendStreamMsgResp) Reset 

func (x *AppendStreamMsgResp) Reset()

func (*AppendStreamMsgResp) String 

func (x *AppendStreamMsgResp) 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 added in v0.0.65 

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

func (*ClearMsgReq) Descriptor deprecated added in v0.0.65 

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

Deprecated: Use ClearMsgReq.ProtoReflect.Descriptor instead.

func (*ClearMsgReq) GetConversations 

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

func (*ClearMsgReq) ProtoMessage added in v0.0.65 

func (*ClearMsgReq) ProtoMessage()

func (*ClearMsgReq) ProtoReflect added in v0.0.65 

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

func (*ClearMsgReq) Reset added in v0.0.65 

func (x *ClearMsgReq) Reset()

func (*ClearMsgReq) String added in v0.0.65 

func (x *ClearMsgReq) String() string

type ClearMsgResp added in v0.0.65 

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

func (*ClearMsgResp) Descriptor deprecated added in v0.0.65 

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

Deprecated: Use ClearMsgResp.ProtoReflect.Descriptor instead.

func (*ClearMsgResp) ProtoMessage added in v0.0.65 

func (*ClearMsgResp) ProtoMessage()

func (*ClearMsgResp) ProtoReflect added in v0.0.65 

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

func (*ClearMsgResp) Reset added in v0.0.65 

func (x *ClearMsgResp) Reset()

func (*ClearMsgResp) String added in v0.0.65 

func (x *ClearMsgResp) String() string

type ConversationSeqs added in v0.0.72 

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 added in v0.0.72 

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

Deprecated: Use ConversationSeqs.ProtoReflect.Descriptor instead.

func (*ConversationSeqs) GetConversationID added in v0.0.72 

func (x *ConversationSeqs) GetConversationID() string

func (*ConversationSeqs) GetSeqs added in v0.0.72 

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

func (*ConversationSeqs) ProtoMessage added in v0.0.72 

func (*ConversationSeqs) ProtoMessage()

func (*ConversationSeqs) ProtoReflect added in v0.0.72 

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

func (*ConversationSeqs) Reset added in v0.0.72 

func (x *ConversationSeqs) Reset()

func (*ConversationSeqs) String added in v0.0.72 

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 added in v0.0.69 

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

func (*DestructMsgsReq) Check 

func (x *DestructMsgsReq) Check() error

func (*DestructMsgsReq) Descriptor deprecated added in v0.0.69 

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

Deprecated: Use DestructMsgsReq.ProtoReflect.Descriptor instead.

func (*DestructMsgsReq) GetLimit 

func (x *DestructMsgsReq) GetLimit() int32

func (*DestructMsgsReq) GetTimestamp 

func (x *DestructMsgsReq) GetTimestamp() int64

func (*DestructMsgsReq) ProtoMessage added in v0.0.69 

func (*DestructMsgsReq) ProtoMessage()

func (*DestructMsgsReq) ProtoReflect added in v0.0.69 

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

func (*DestructMsgsReq) Reset added in v0.0.69 

func (x *DestructMsgsReq) Reset()

func (*DestructMsgsReq) String added in v0.0.69 

func (x *DestructMsgsReq) String() string

type DestructMsgsResp added in v0.0.69 

type DestructMsgsResp struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count"`
	// contains filtered or unexported fields
}

func (*DestructMsgsResp) Descriptor deprecated added in v0.0.69 

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

Deprecated: Use DestructMsgsResp.ProtoReflect.Descriptor instead.

func (*DestructMsgsResp) GetCount 

func (x *DestructMsgsResp) GetCount() int32

func (*DestructMsgsResp) ProtoMessage added in v0.0.69 

func (*DestructMsgsResp) ProtoMessage()

func (*DestructMsgsResp) ProtoReflect added in v0.0.69 

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

func (*DestructMsgsResp) Reset added in v0.0.69 

func (x *DestructMsgsResp) Reset()

func (*DestructMsgsResp) String added in v0.0.69 

func (x *DestructMsgsResp) String() string

type GetActiveConversationReq added in v0.0.72 

type GetActiveConversationReq struct {
	ConversationIDs []string `protobuf:"bytes,1,rep,name=conversationIDs,proto3" json:"conversationIDs"`
	Limit           int64    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit"`
	// contains filtered or unexported fields
}

func (*GetActiveConversationReq) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use GetActiveConversationReq.ProtoReflect.Descriptor instead.

func (*GetActiveConversationReq) GetConversationIDs added in v0.0.72 

func (x *GetActiveConversationReq) GetConversationIDs() []string

func (*GetActiveConversationReq) GetLimit added in v0.0.72 

func (x *GetActiveConversationReq) GetLimit() int64

func (*GetActiveConversationReq) ProtoMessage added in v0.0.72 

func (*GetActiveConversationReq) ProtoMessage()

func (*GetActiveConversationReq) ProtoReflect added in v0.0.72 

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

func (*GetActiveConversationReq) Reset added in v0.0.72 

func (x *GetActiveConversationReq) Reset()

func (*GetActiveConversationReq) String added in v0.0.72 

func (x *GetActiveConversationReq) String() string

type GetActiveConversationResp added in v0.0.72 

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

func (*GetActiveConversationResp) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use GetActiveConversationResp.ProtoReflect.Descriptor instead.

func (*GetActiveConversationResp) GetConversations added in v0.0.72 

func (x *GetActiveConversationResp) GetConversations() []*ActiveConversation

func (*GetActiveConversationResp) ProtoMessage added in v0.0.72 

func (*GetActiveConversationResp) ProtoMessage()

func (*GetActiveConversationResp) ProtoReflect added in v0.0.72 

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

func (*GetActiveConversationResp) Reset added in v0.0.72 

func (x *GetActiveConversationResp) Reset()

func (*GetActiveConversationResp) String added in v0.0.72 

func (x *GetActiveConversationResp) 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 added in v0.0.69 

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 added in v0.0.69 

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 GetLastMessageSeqByTimeReq 

type GetLastMessageSeqByTimeReq struct {
	ConversationID string `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"`
	Time           int64  `protobuf:"varint,2,opt,name=time,proto3" json:"time"`
	// contains filtered or unexported fields
}

func (*GetLastMessageSeqByTimeReq) Descriptor deprecated 

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

Deprecated: Use GetLastMessageSeqByTimeReq.ProtoReflect.Descriptor instead.

func (*GetLastMessageSeqByTimeReq) GetConversationID 

func (x *GetLastMessageSeqByTimeReq) GetConversationID() string

func (*GetLastMessageSeqByTimeReq) GetTime 

func (x *GetLastMessageSeqByTimeReq) GetTime() int64

func (*GetLastMessageSeqByTimeReq) ProtoMessage 

func (*GetLastMessageSeqByTimeReq) ProtoMessage()

func (*GetLastMessageSeqByTimeReq) ProtoReflect 

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

func (*GetLastMessageSeqByTimeReq) Reset 

func (x *GetLastMessageSeqByTimeReq) Reset()

func (*GetLastMessageSeqByTimeReq) String 

func (x *GetLastMessageSeqByTimeReq) String() string

type GetLastMessageSeqByTimeResp 

type GetLastMessageSeqByTimeResp struct {
	Seq int64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq"`
	// contains filtered or unexported fields
}

func (*GetLastMessageSeqByTimeResp) Descriptor deprecated 

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

Deprecated: Use GetLastMessageSeqByTimeResp.ProtoReflect.Descriptor instead.

func (*GetLastMessageSeqByTimeResp) GetSeq 

func (x *GetLastMessageSeqByTimeResp) GetSeq() int64

func (*GetLastMessageSeqByTimeResp) ProtoMessage 

func (*GetLastMessageSeqByTimeResp) ProtoMessage()

func (*GetLastMessageSeqByTimeResp) ProtoReflect 

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

func (*GetLastMessageSeqByTimeResp) Reset 

func (x *GetLastMessageSeqByTimeResp) Reset()

func (*GetLastMessageSeqByTimeResp) String 

func (x *GetLastMessageSeqByTimeResp) 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 added in v0.0.72 

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"`
	Order         sdkws.PullOrder     `protobuf:"varint,3,opt,name=order,proto3,enum=openim.sdkws.PullOrder" json:"order"`
	// contains filtered or unexported fields
}

func (*GetSeqMessageReq) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use GetSeqMessageReq.ProtoReflect.Descriptor instead.

func (*GetSeqMessageReq) GetConversations added in v0.0.72 

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

func (*GetSeqMessageReq) GetOrder 

func (x *GetSeqMessageReq) GetOrder() sdkws.PullOrder

func (*GetSeqMessageReq) GetUserID added in v0.0.72 

func (x *GetSeqMessageReq) GetUserID() string

func (*GetSeqMessageReq) ProtoMessage added in v0.0.72 

func (*GetSeqMessageReq) ProtoMessage()

func (*GetSeqMessageReq) ProtoReflect added in v0.0.72 

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

func (*GetSeqMessageReq) Reset added in v0.0.72 

func (x *GetSeqMessageReq) Reset()

func (*GetSeqMessageReq) String added in v0.0.72 

func (x *GetSeqMessageReq) String() string

type GetSeqMessageResp added in v0.0.72 

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 added in v0.0.72 

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

Deprecated: Use GetSeqMessageResp.ProtoReflect.Descriptor instead.

func (*GetSeqMessageResp) GetMsgs added in v0.0.72 

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

func (*GetSeqMessageResp) GetNotificationMsgs added in v0.0.72 

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

func (*GetSeqMessageResp) ProtoMessage added in v0.0.72 

func (*GetSeqMessageResp) ProtoMessage()

func (*GetSeqMessageResp) ProtoReflect added in v0.0.72 

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

func (*GetSeqMessageResp) Reset added in v0.0.72 

func (x *GetSeqMessageResp) Reset()

func (*GetSeqMessageResp) String added in v0.0.72 

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 GetStreamMsgReq 

type GetStreamMsgReq struct {
	ClientMsgID string `protobuf:"bytes,1,opt,name=clientMsgID,proto3" json:"clientMsgID"`
	// contains filtered or unexported fields
}

func (*GetStreamMsgReq) Descriptor deprecated 

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

Deprecated: Use GetStreamMsgReq.ProtoReflect.Descriptor instead.

func (*GetStreamMsgReq) GetClientMsgID 

func (x *GetStreamMsgReq) GetClientMsgID() string

func (*GetStreamMsgReq) ProtoMessage 

func (*GetStreamMsgReq) ProtoMessage()

func (*GetStreamMsgReq) ProtoReflect 

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

func (*GetStreamMsgReq) Reset 

func (x *GetStreamMsgReq) Reset()

func (*GetStreamMsgReq) String 

func (x *GetStreamMsgReq) String() string

type GetStreamMsgResp 

type GetStreamMsgResp struct {
	ClientMsgID    string   `protobuf:"bytes,1,opt,name=clientMsgID,proto3" json:"clientMsgID"`
	ConversationID string   `protobuf:"bytes,2,opt,name=conversationID,proto3" json:"conversationID"`
	UserID         string   `protobuf:"bytes,3,opt,name=userID,proto3" json:"userID"`
	Packets        []string `protobuf:"bytes,4,rep,name=packets,proto3" json:"packets"`
	End            bool     `protobuf:"varint,5,opt,name=end,proto3" json:"end"`
	CreateTime     int64    `protobuf:"varint,6,opt,name=createTime,proto3" json:"createTime"`
	DeadlineTime   int64    `protobuf:"varint,7,opt,name=deadlineTime,proto3" json:"deadlineTime"`
	// contains filtered or unexported fields
}

func (*GetStreamMsgResp) Descriptor deprecated 

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

Deprecated: Use GetStreamMsgResp.ProtoReflect.Descriptor instead.

func (*GetStreamMsgResp) GetClientMsgID 

func (x *GetStreamMsgResp) GetClientMsgID() string

func (*GetStreamMsgResp) GetConversationID 

func (x *GetStreamMsgResp) GetConversationID() string

func (*GetStreamMsgResp) GetCreateTime 

func (x *GetStreamMsgResp) GetCreateTime() int64

func (*GetStreamMsgResp) GetDeadlineTime 

func (x *GetStreamMsgResp) GetDeadlineTime() int64

func (*GetStreamMsgResp) GetEnd 

func (x *GetStreamMsgResp) GetEnd() bool

func (*GetStreamMsgResp) GetPackets 

func (x *GetStreamMsgResp) GetPackets() []string

func (*GetStreamMsgResp) GetUserID 

func (x *GetStreamMsgResp) GetUserID() string

func (*GetStreamMsgResp) ProtoMessage 

func (*GetStreamMsgResp) ProtoMessage()

func (*GetStreamMsgResp) ProtoReflect 

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

func (*GetStreamMsgResp) Reset 

func (x *GetStreamMsgResp) Reset()

func (*GetStreamMsgResp) String 

func (x *GetStreamMsgResp) 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)
	GetActiveConversation(ctx context.Context, in *GetActiveConversationReq, opts ...grpc.CallOption) (*GetActiveConversationResp, error)
	AppendStreamMsg(ctx context.Context, in *AppendStreamMsgReq, opts ...grpc.CallOption) (*AppendStreamMsgResp, error)
	GetStreamMsg(ctx context.Context, in *GetStreamMsgReq, opts ...grpc.CallOption) (*GetStreamMsgResp, error)
	SetUserConversationMaxSeq(ctx context.Context, in *SetUserConversationMaxSeqReq, opts ...grpc.CallOption) (*SetUserConversationMaxSeqResp, error)
	SetUserConversationMinSeq(ctx context.Context, in *SetUserConversationMinSeqReq, opts ...grpc.CallOption) (*SetUserConversationMinSeqResp, error)
	GetLastMessageSeqByTime(ctx context.Context, in *GetLastMessageSeqByTimeReq, opts ...grpc.CallOption) (*GetLastMessageSeqByTimeResp, 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)
	GetActiveConversation(context.Context, *GetActiveConversationReq) (*GetActiveConversationResp, error)
	AppendStreamMsg(context.Context, *AppendStreamMsgReq) (*AppendStreamMsgResp, error)
	GetStreamMsg(context.Context, *GetStreamMsgReq) (*GetStreamMsgResp, error)
	SetUserConversationMaxSeq(context.Context, *SetUserConversationMaxSeqReq) (*SetUserConversationMaxSeqResp, error)
	SetUserConversationMinSeq(context.Context, *SetUserConversationMinSeqReq) (*SetUserConversationMinSeqResp, error)
	GetLastMessageSeqByTime(context.Context, *GetLastMessageSeqByTimeReq) (*GetLastMessageSeqByTimeResp, error)
	// contains filtered or unexported methods
}

MsgServer is the server API for Msg service. All implementations must 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 SearchChatLog added in v0.0.72 

type SearchChatLog struct {
	ChatLog   *ChatLog `protobuf:"bytes,1,opt,name=chatLog,proto3" json:"chatLog"`
	IsRevoked bool     `protobuf:"varint,2,opt,name=isRevoked,proto3" json:"isRevoked"`
	// contains filtered or unexported fields
}

func (*SearchChatLog) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use SearchChatLog.ProtoReflect.Descriptor instead.

func (*SearchChatLog) GetChatLog added in v0.0.72 

func (x *SearchChatLog) GetChatLog() *ChatLog

func (*SearchChatLog) GetIsRevoked added in v0.0.72 

func (x *SearchChatLog) GetIsRevoked() bool

func (*SearchChatLog) ProtoMessage added in v0.0.72 

func (*SearchChatLog) ProtoMessage()

func (*SearchChatLog) ProtoReflect added in v0.0.72 

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

func (*SearchChatLog) Reset added in v0.0.72 

func (x *SearchChatLog) Reset()

func (*SearchChatLog) String added in v0.0.72 

func (x *SearchChatLog) 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    []*SearchChatLog `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() []*SearchChatLog

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 SearchedMsgData added in v0.0.72 

type SearchedMsgData struct {
	MsgData   *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData,proto3" json:"msgData"`
	IsRevoked bool           `protobuf:"varint,2,opt,name=isRevoked,proto3" json:"isRevoked"`
	// contains filtered or unexported fields
}

func (*SearchedMsgData) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use SearchedMsgData.ProtoReflect.Descriptor instead.

func (*SearchedMsgData) GetIsRevoked added in v0.0.72 

func (x *SearchedMsgData) GetIsRevoked() bool

func (*SearchedMsgData) GetMsgData added in v0.0.72 

func (x *SearchedMsgData) GetMsgData() *sdkws.MsgData

func (*SearchedMsgData) ProtoMessage added in v0.0.72 

func (*SearchedMsgData) ProtoMessage()

func (*SearchedMsgData) ProtoReflect added in v0.0.72 

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

func (*SearchedMsgData) Reset added in v0.0.72 

func (x *SearchedMsgData) Reset()

func (*SearchedMsgData) String added in v0.0.72 

func (x *SearchedMsgData) 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"`
	MaxSeqTime int64 `protobuf:"varint,3,opt,name=maxSeqTime,proto3" json:"maxSeqTime"`
	// 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) GetMaxSeqTime added in v0.0.72 

func (x *Seqs) GetMaxSeqTime() 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 added in v0.0.69 

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 added in v0.0.72 

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 SetUserConversationMaxSeqReq 

type SetUserConversationMaxSeqReq struct {
	ConversationID string   `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"`
	OwnerUserID    []string `protobuf:"bytes,2,rep,name=ownerUserID,proto3" json:"ownerUserID"`
	MaxSeq         int64    `protobuf:"varint,3,opt,name=maxSeq,proto3" json:"maxSeq"`
	// contains filtered or unexported fields
}

func (*SetUserConversationMaxSeqReq) Descriptor deprecated 

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

Deprecated: Use SetUserConversationMaxSeqReq.ProtoReflect.Descriptor instead.

func (*SetUserConversationMaxSeqReq) GetConversationID 

func (x *SetUserConversationMaxSeqReq) GetConversationID() string

func (*SetUserConversationMaxSeqReq) GetMaxSeq 

func (x *SetUserConversationMaxSeqReq) GetMaxSeq() int64

func (*SetUserConversationMaxSeqReq) GetOwnerUserID 

func (x *SetUserConversationMaxSeqReq) GetOwnerUserID() []string

func (*SetUserConversationMaxSeqReq) ProtoMessage 

func (*SetUserConversationMaxSeqReq) ProtoMessage()

func (*SetUserConversationMaxSeqReq) ProtoReflect 

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

func (*SetUserConversationMaxSeqReq) Reset 

func (x *SetUserConversationMaxSeqReq) Reset()

func (*SetUserConversationMaxSeqReq) String 

func (x *SetUserConversationMaxSeqReq) String() string

type SetUserConversationMaxSeqResp 

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

func (*SetUserConversationMaxSeqResp) Descriptor deprecated 

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

Deprecated: Use SetUserConversationMaxSeqResp.ProtoReflect.Descriptor instead.

func (*SetUserConversationMaxSeqResp) ProtoMessage 

func (*SetUserConversationMaxSeqResp) ProtoMessage()

func (*SetUserConversationMaxSeqResp) ProtoReflect 

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

func (*SetUserConversationMaxSeqResp) Reset 

func (x *SetUserConversationMaxSeqResp) Reset()

func (*SetUserConversationMaxSeqResp) String 

func (x *SetUserConversationMaxSeqResp) String() string

type SetUserConversationMinSeqReq 

type SetUserConversationMinSeqReq struct {
	ConversationID string   `protobuf:"bytes,1,opt,name=conversationID,proto3" json:"conversationID"`
	OwnerUserID    []string `protobuf:"bytes,2,rep,name=ownerUserID,proto3" json:"ownerUserID"`
	MinSeq         int64    `protobuf:"varint,3,opt,name=minSeq,proto3" json:"minSeq"`
	// contains filtered or unexported fields
}

func (*SetUserConversationMinSeqReq) Descriptor deprecated 

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

Deprecated: Use SetUserConversationMinSeqReq.ProtoReflect.Descriptor instead.

func (*SetUserConversationMinSeqReq) GetConversationID 

func (x *SetUserConversationMinSeqReq) GetConversationID() string

func (*SetUserConversationMinSeqReq) GetMinSeq 

func (x *SetUserConversationMinSeqReq) GetMinSeq() int64

func (*SetUserConversationMinSeqReq) GetOwnerUserID 

func (x *SetUserConversationMinSeqReq) GetOwnerUserID() []string

func (*SetUserConversationMinSeqReq) ProtoMessage 

func (*SetUserConversationMinSeqReq) ProtoMessage()

func (*SetUserConversationMinSeqReq) ProtoReflect 

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

func (*SetUserConversationMinSeqReq) Reset 

func (x *SetUserConversationMinSeqReq) Reset()

func (*SetUserConversationMinSeqReq) String 

func (x *SetUserConversationMinSeqReq) String() string

type SetUserConversationMinSeqResp 

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

func (*SetUserConversationMinSeqResp) Descriptor deprecated 

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

Deprecated: Use SetUserConversationMinSeqResp.ProtoReflect.Descriptor instead.

func (*SetUserConversationMinSeqResp) ProtoMessage 

func (*SetUserConversationMinSeqResp) ProtoMessage()

func (*SetUserConversationMinSeqResp) ProtoReflect 

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

func (*SetUserConversationMinSeqResp) Reset 

func (x *SetUserConversationMinSeqResp) Reset()

func (*SetUserConversationMinSeqResp) String 

func (x *SetUserConversationMinSeqResp) String() string

type SetUserConversationsMinSeqReq added in v0.0.72 

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 added in v0.0.72 

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

Deprecated: Use SetUserConversationsMinSeqReq.ProtoReflect.Descriptor instead.

func (*SetUserConversationsMinSeqReq) GetConversationID added in v0.0.72 

func (x *SetUserConversationsMinSeqReq) GetConversationID() string

func (*SetUserConversationsMinSeqReq) GetSeq added in v0.0.72 

func (x *SetUserConversationsMinSeqReq) GetSeq() int64

func (*SetUserConversationsMinSeqReq) GetUserIDs added in v0.0.72 

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

func (*SetUserConversationsMinSeqReq) ProtoMessage added in v0.0.72 

func (*SetUserConversationsMinSeqReq) ProtoMessage()

func (*SetUserConversationsMinSeqReq) ProtoReflect added in v0.0.72 

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

func (*SetUserConversationsMinSeqReq) Reset added in v0.0.72 

func (x *SetUserConversationsMinSeqReq) Reset()

func (*SetUserConversationsMinSeqReq) String added in v0.0.72 

func (x *SetUserConversationsMinSeqReq) String() string

type SetUserConversationsMinSeqResp added in v0.0.72 

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

func (*SetUserConversationsMinSeqResp) Descriptor deprecated added in v0.0.72 

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

Deprecated: Use SetUserConversationsMinSeqResp.ProtoReflect.Descriptor instead.

func (*SetUserConversationsMinSeqResp) ProtoMessage added in v0.0.72 

func (*SetUserConversationsMinSeqResp) ProtoMessage()

func (*SetUserConversationsMinSeqResp) ProtoReflect added in v0.0.72 

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

func (*SetUserConversationsMinSeqResp) Reset added in v0.0.72 

func (x *SetUserConversationsMinSeqResp) Reset()

func (*SetUserConversationsMinSeqResp) String added in v0.0.72 

func (x *SetUserConversationsMinSeqResp) String() string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct{}

UnimplementedMsgServer must 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) AppendStreamMsg 

func (UnimplementedMsgServer) AppendStreamMsg(context.Context, *AppendStreamMsgReq) (*AppendStreamMsgResp, error)

func (UnimplementedMsgServer) ClearConversationsMsg 

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

func (UnimplementedMsgServer) ClearMsg added in v0.0.65 

func (UnimplementedMsgServer) ClearMsg(context.Context, *ClearMsgReq) (*ClearMsgResp, error)

func (UnimplementedMsgServer) DeleteMsgPhysical 

func (UnimplementedMsgServer) DeleteMsgPhysical(context.Context, *DeleteMsgPhysicalReq) (*DeleteMsgPhysicalResp, error)

func (UnimplementedMsgServer) DeleteMsgPhysicalBySeq 

func (UnimplementedMsgServer) DeleteMsgPhysicalBySeq(context.Context, *DeleteMsgPhysicalBySeqReq) (*DeleteMsgPhysicalBySeqResp, error)

func (UnimplementedMsgServer) DeleteMsgs 

func (UnimplementedMsgServer) DeleteMsgs(context.Context, *DeleteMsgsReq) (*DeleteMsgsResp, error)

func (UnimplementedMsgServer) DestructMsgs added in v0.0.69 

func (UnimplementedMsgServer) DestructMsgs(context.Context, *DestructMsgsReq) (*DestructMsgsResp, error)

func (UnimplementedMsgServer) GetActiveConversation added in v0.0.72 

func (UnimplementedMsgServer) GetActiveConversation(context.Context, *GetActiveConversationReq) (*GetActiveConversationResp, 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) GetLastMessageSeqByTime 

func (UnimplementedMsgServer) GetLastMessageSeqByTime(context.Context, *GetLastMessageSeqByTimeReq) (*GetLastMessageSeqByTimeResp, 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 added in v0.0.72 

func (UnimplementedMsgServer) GetSeqMessage(context.Context, *GetSeqMessageReq) (*GetSeqMessageResp, error)

func (UnimplementedMsgServer) GetServerTime 

func (UnimplementedMsgServer) GetServerTime(context.Context, *GetServerTimeReq) (*GetServerTimeResp, error)

func (UnimplementedMsgServer) GetStreamMsg 

func (UnimplementedMsgServer) GetStreamMsg(context.Context, *GetStreamMsgReq) (*GetStreamMsgResp, 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) SetUserConversationMaxSeq 

func (UnimplementedMsgServer) SetUserConversationMaxSeq(context.Context, *SetUserConversationMaxSeqReq) (*SetUserConversationMaxSeqResp, error)

func (UnimplementedMsgServer) SetUserConversationMinSeq 

func (UnimplementedMsgServer) SetUserConversationMinSeq(context.Context, *SetUserConversationMinSeqReq) (*SetUserConversationMinSeqResp, error)

func (UnimplementedMsgServer) SetUserConversationsMinSeq added in v0.0.72 

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.