blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-28 04:48:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

modify msg

Browse Source
This commit is contained in:
wangchuxiao 2022-12-09 16:42:43 +08:00
parent 0fbf882059
commit 7f449aed5b
2 changed files with 64 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

111
pkg/proto/msg/msg.pb.go
View File

@ -38,7 +38,7 @@ func (m *MsgDataToMQ) Reset() { *m = MsgDataToMQ{} }
func (m *MsgDataToMQ) String() string { return proto.CompactTextString(m) } func (m *MsgDataToMQ) String() string { return proto.CompactTextString(m) }
func (*MsgDataToMQ) ProtoMessage() {} func (*MsgDataToMQ) ProtoMessage() {}
func (*MsgDataToMQ) Descriptor() ([]byte, []int) { func (*MsgDataToMQ) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{0} return fileDescriptor_msg_21d1ceb5221a9786, []int{0}
} }
func (m *MsgDataToMQ) XXX_Unmarshal(b []byte) error { func (m *MsgDataToMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToMQ.Unmarshal(m, b) return xxx_messageInfo_MsgDataToMQ.Unmarshal(m, b)
@ -91,7 +91,7 @@ func (m *MsgDataToDB) Reset() { *m = MsgDataToDB{} }
func (m *MsgDataToDB) String() string { return proto.CompactTextString(m) } func (m *MsgDataToDB) String() string { return proto.CompactTextString(m) }
func (*MsgDataToDB) ProtoMessage() {} func (*MsgDataToDB) ProtoMessage() {}
func (*MsgDataToDB) Descriptor() ([]byte, []int) { func (*MsgDataToDB) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{1} return fileDescriptor_msg_21d1ceb5221a9786, []int{1}
} }
func (m *MsgDataToDB) XXX_Unmarshal(b []byte) error { func (m *MsgDataToDB) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToDB.Unmarshal(m, b) return xxx_messageInfo_MsgDataToDB.Unmarshal(m, b)
@ -138,7 +138,7 @@ func (m *PushMsgDataToMQ) Reset() { *m = PushMsgDataToMQ{} }
func (m *PushMsgDataToMQ) String() string { return proto.CompactTextString(m) } func (m *PushMsgDataToMQ) String() string { return proto.CompactTextString(m) }
func (*PushMsgDataToMQ) ProtoMessage() {} func (*PushMsgDataToMQ) ProtoMessage() {}
func (*PushMsgDataToMQ) Descriptor() ([]byte, []int) { func (*PushMsgDataToMQ) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{2} return fileDescriptor_msg_21d1ceb5221a9786, []int{2}
} }
func (m *PushMsgDataToMQ) XXX_Unmarshal(b []byte) error { func (m *PushMsgDataToMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PushMsgDataToMQ.Unmarshal(m, b) return xxx_messageInfo_PushMsgDataToMQ.Unmarshal(m, b)
@ -193,7 +193,7 @@ func (m *MsgDataToMongoByMQ) Reset() { *m = MsgDataToMongoByMQ{} }
func (m *MsgDataToMongoByMQ) String() string { return proto.CompactTextString(m) } func (m *MsgDataToMongoByMQ) String() string { return proto.CompactTextString(m) }
func (*MsgDataToMongoByMQ) ProtoMessage() {} func (*MsgDataToMongoByMQ) ProtoMessage() {}
func (*MsgDataToMongoByMQ) Descriptor() ([]byte, []int) { func (*MsgDataToMongoByMQ) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{3} return fileDescriptor_msg_21d1ceb5221a9786, []int{3}
} }
func (m *MsgDataToMongoByMQ) XXX_Unmarshal(b []byte) error { func (m *MsgDataToMongoByMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToMongoByMQ.Unmarshal(m, b) return xxx_messageInfo_MsgDataToMongoByMQ.Unmarshal(m, b)
@ -273,7 +273,7 @@ func (m *GetMaxAndMinSeqReq) Reset() { *m = GetMaxAndMinSeqReq{} }
func (m *GetMaxAndMinSeqReq) String() string { return proto.CompactTextString(m) } func (m *GetMaxAndMinSeqReq) String() string { return proto.CompactTextString(m) }
func (*GetMaxAndMinSeqReq) ProtoMessage() {} func (*GetMaxAndMinSeqReq) ProtoMessage() {}
func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int) { func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{4} return fileDescriptor_msg_21d1ceb5221a9786, []int{4}
} }
func (m *GetMaxAndMinSeqReq) XXX_Unmarshal(b []byte) error { func (m *GetMaxAndMinSeqReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMaxAndMinSeqReq.Unmarshal(m, b) return xxx_messageInfo_GetMaxAndMinSeqReq.Unmarshal(m, b)
@ -321,7 +321,7 @@ func (m *GetMaxAndMinSeqResp) Reset() { *m = GetMaxAndMinSeqResp{} }
func (m *GetMaxAndMinSeqResp) String() string { return proto.CompactTextString(m) } func (m *GetMaxAndMinSeqResp) String() string { return proto.CompactTextString(m) }
func (*GetMaxAndMinSeqResp) ProtoMessage() {} func (*GetMaxAndMinSeqResp) ProtoMessage() {}
func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int) { func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{5} return fileDescriptor_msg_21d1ceb5221a9786, []int{5}
} }
func (m *GetMaxAndMinSeqResp) XXX_Unmarshal(b []byte) error { func (m *GetMaxAndMinSeqResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMaxAndMinSeqResp.Unmarshal(m, b) return xxx_messageInfo_GetMaxAndMinSeqResp.Unmarshal(m, b)
@ -382,7 +382,7 @@ func (m *SendMsgReq) Reset() { *m = SendMsgReq{} }
func (m *SendMsgReq) String() string { return proto.CompactTextString(m) } func (m *SendMsgReq) String() string { return proto.CompactTextString(m) }
func (*SendMsgReq) ProtoMessage() {} func (*SendMsgReq) ProtoMessage() {}
func (*SendMsgReq) Descriptor() ([]byte, []int) { func (*SendMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{6} return fileDescriptor_msg_21d1ceb5221a9786, []int{6}
} }
func (m *SendMsgReq) XXX_Unmarshal(b []byte) error { func (m *SendMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SendMsgReq.Unmarshal(m, b) return xxx_messageInfo_SendMsgReq.Unmarshal(m, b)
@ -438,7 +438,7 @@ func (m *SendMsgResp) Reset() { *m = SendMsgResp{} }
func (m *SendMsgResp) String() string { return proto.CompactTextString(m) } func (m *SendMsgResp) String() string { return proto.CompactTextString(m) }
func (*SendMsgResp) ProtoMessage() {} func (*SendMsgResp) ProtoMessage() {}
func (*SendMsgResp) Descriptor() ([]byte, []int) { func (*SendMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{7} return fileDescriptor_msg_21d1ceb5221a9786, []int{7}
} }
func (m *SendMsgResp) XXX_Unmarshal(b []byte) error { func (m *SendMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SendMsgResp.Unmarshal(m, b) return xxx_messageInfo_SendMsgResp.Unmarshal(m, b)
@ -506,7 +506,7 @@ func (m *ClearMsgReq) Reset() { *m = ClearMsgReq{} }
func (m *ClearMsgReq) String() string { return proto.CompactTextString(m) } func (m *ClearMsgReq) String() string { return proto.CompactTextString(m) }
func (*ClearMsgReq) ProtoMessage() {} func (*ClearMsgReq) ProtoMessage() {}
func (*ClearMsgReq) Descriptor() ([]byte, []int) { func (*ClearMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{8} return fileDescriptor_msg_21d1ceb5221a9786, []int{8}
} }
func (m *ClearMsgReq) XXX_Unmarshal(b []byte) error { func (m *ClearMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ClearMsgReq.Unmarshal(m, b) return xxx_messageInfo_ClearMsgReq.Unmarshal(m, b)
@ -559,7 +559,7 @@ func (m *ClearMsgResp) Reset() { *m = ClearMsgResp{} }
func (m *ClearMsgResp) String() string { return proto.CompactTextString(m) } func (m *ClearMsgResp) String() string { return proto.CompactTextString(m) }
func (*ClearMsgResp) ProtoMessage() {} func (*ClearMsgResp) ProtoMessage() {}
func (*ClearMsgResp) Descriptor() ([]byte, []int) { func (*ClearMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{9} return fileDescriptor_msg_21d1ceb5221a9786, []int{9}
} }
func (m *ClearMsgResp) XXX_Unmarshal(b []byte) error { func (m *ClearMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ClearMsgResp.Unmarshal(m, b) return xxx_messageInfo_ClearMsgResp.Unmarshal(m, b)
@ -608,7 +608,7 @@ func (m *SetMsgMinSeqReq) Reset() { *m = SetMsgMinSeqReq{} }
func (m *SetMsgMinSeqReq) String() string { return proto.CompactTextString(m) } func (m *SetMsgMinSeqReq) String() string { return proto.CompactTextString(m) }
func (*SetMsgMinSeqReq) ProtoMessage() {} func (*SetMsgMinSeqReq) ProtoMessage() {}
func (*SetMsgMinSeqReq) Descriptor() ([]byte, []int) { func (*SetMsgMinSeqReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{10} return fileDescriptor_msg_21d1ceb5221a9786, []int{10}
} }
func (m *SetMsgMinSeqReq) XXX_Unmarshal(b []byte) error { func (m *SetMsgMinSeqReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetMsgMinSeqReq.Unmarshal(m, b) return xxx_messageInfo_SetMsgMinSeqReq.Unmarshal(m, b)
@ -675,7 +675,7 @@ func (m *SetMsgMinSeqResp) Reset() { *m = SetMsgMinSeqResp{} }
func (m *SetMsgMinSeqResp) String() string { return proto.CompactTextString(m) } func (m *SetMsgMinSeqResp) String() string { return proto.CompactTextString(m) }
func (*SetMsgMinSeqResp) ProtoMessage() {} func (*SetMsgMinSeqResp) ProtoMessage() {}
func (*SetMsgMinSeqResp) Descriptor() ([]byte, []int) { func (*SetMsgMinSeqResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{11} return fileDescriptor_msg_21d1ceb5221a9786, []int{11}
} }
func (m *SetMsgMinSeqResp) XXX_Unmarshal(b []byte) error { func (m *SetMsgMinSeqResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetMsgMinSeqResp.Unmarshal(m, b) return xxx_messageInfo_SetMsgMinSeqResp.Unmarshal(m, b)
@ -721,7 +721,7 @@ func (m *SetSendMsgStatusReq) Reset() { *m = SetSendMsgStatusReq{} }
func (m *SetSendMsgStatusReq) String() string { return proto.CompactTextString(m) } func (m *SetSendMsgStatusReq) String() string { return proto.CompactTextString(m) }
func (*SetSendMsgStatusReq) ProtoMessage() {} func (*SetSendMsgStatusReq) ProtoMessage() {}
func (*SetSendMsgStatusReq) Descriptor() ([]byte, []int) { func (*SetSendMsgStatusReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{12} return fileDescriptor_msg_21d1ceb5221a9786, []int{12}
} }
func (m *SetSendMsgStatusReq) XXX_Unmarshal(b []byte) error { func (m *SetSendMsgStatusReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetSendMsgStatusReq.Unmarshal(m, b) return xxx_messageInfo_SetSendMsgStatusReq.Unmarshal(m, b)
@ -767,7 +767,7 @@ func (m *SetSendMsgStatusResp) Reset() { *m = SetSendMsgStatusResp{} }
func (m *SetSendMsgStatusResp) String() string { return proto.CompactTextString(m) } func (m *SetSendMsgStatusResp) String() string { return proto.CompactTextString(m) }
func (*SetSendMsgStatusResp) ProtoMessage() {} func (*SetSendMsgStatusResp) ProtoMessage() {}
func (*SetSendMsgStatusResp) Descriptor() ([]byte, []int) { func (*SetSendMsgStatusResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{13} return fileDescriptor_msg_21d1ceb5221a9786, []int{13}
} }
func (m *SetSendMsgStatusResp) XXX_Unmarshal(b []byte) error { func (m *SetSendMsgStatusResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetSendMsgStatusResp.Unmarshal(m, b) return xxx_messageInfo_SetSendMsgStatusResp.Unmarshal(m, b)
@ -812,7 +812,7 @@ func (m *GetSendMsgStatusReq) Reset() { *m = GetSendMsgStatusReq{} }
func (m *GetSendMsgStatusReq) String() string { return proto.CompactTextString(m) } func (m *GetSendMsgStatusReq) String() string { return proto.CompactTextString(m) }
func (*GetSendMsgStatusReq) ProtoMessage() {} func (*GetSendMsgStatusReq) ProtoMessage() {}
func (*GetSendMsgStatusReq) Descriptor() ([]byte, []int) { func (*GetSendMsgStatusReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{14} return fileDescriptor_msg_21d1ceb5221a9786, []int{14}
} }
func (m *GetSendMsgStatusReq) XXX_Unmarshal(b []byte) error { func (m *GetSendMsgStatusReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSendMsgStatusReq.Unmarshal(m, b) return xxx_messageInfo_GetSendMsgStatusReq.Unmarshal(m, b)
@ -852,7 +852,7 @@ func (m *GetSendMsgStatusResp) Reset() { *m = GetSendMsgStatusResp{} }
func (m *GetSendMsgStatusResp) String() string { return proto.CompactTextString(m) } func (m *GetSendMsgStatusResp) String() string { return proto.CompactTextString(m) }
func (*GetSendMsgStatusResp) ProtoMessage() {} func (*GetSendMsgStatusResp) ProtoMessage() {}
func (*GetSendMsgStatusResp) Descriptor() ([]byte, []int) { func (*GetSendMsgStatusResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{15} return fileDescriptor_msg_21d1ceb5221a9786, []int{15}
} }
func (m *GetSendMsgStatusResp) XXX_Unmarshal(b []byte) error { func (m *GetSendMsgStatusResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSendMsgStatusResp.Unmarshal(m, b) return xxx_messageInfo_GetSendMsgStatusResp.Unmarshal(m, b)
@ -907,7 +907,7 @@ func (m *DelSuperGroupMsgReq) Reset() { *m = DelSuperGroupMsgReq{} }
func (m *DelSuperGroupMsgReq) String() string { return proto.CompactTextString(m) } func (m *DelSuperGroupMsgReq) String() string { return proto.CompactTextString(m) }
func (*DelSuperGroupMsgReq) ProtoMessage() {} func (*DelSuperGroupMsgReq) ProtoMessage() {}
func (*DelSuperGroupMsgReq) Descriptor() ([]byte, []int) { func (*DelSuperGroupMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{16} return fileDescriptor_msg_21d1ceb5221a9786, []int{16}
} }
func (m *DelSuperGroupMsgReq) XXX_Unmarshal(b []byte) error { func (m *DelSuperGroupMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelSuperGroupMsgReq.Unmarshal(m, b) return xxx_messageInfo_DelSuperGroupMsgReq.Unmarshal(m, b)
@ -967,7 +967,7 @@ func (m *DelSuperGroupMsgResp) Reset() { *m = DelSuperGroupMsgResp{} }
func (m *DelSuperGroupMsgResp) String() string { return proto.CompactTextString(m) } func (m *DelSuperGroupMsgResp) String() string { return proto.CompactTextString(m) }
func (*DelSuperGroupMsgResp) ProtoMessage() {} func (*DelSuperGroupMsgResp) ProtoMessage() {}
func (*DelSuperGroupMsgResp) Descriptor() ([]byte, []int) { func (*DelSuperGroupMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{17} return fileDescriptor_msg_21d1ceb5221a9786, []int{17}
} }
func (m *DelSuperGroupMsgResp) XXX_Unmarshal(b []byte) error { func (m *DelSuperGroupMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelSuperGroupMsgResp.Unmarshal(m, b) return xxx_messageInfo_DelSuperGroupMsgResp.Unmarshal(m, b)
@ -1014,7 +1014,7 @@ func (m *GetSuperGroupMsgReq) Reset() { *m = GetSuperGroupMsgReq{} }
func (m *GetSuperGroupMsgReq) String() string { return proto.CompactTextString(m) } func (m *GetSuperGroupMsgReq) String() string { return proto.CompactTextString(m) }
func (*GetSuperGroupMsgReq) ProtoMessage() {} func (*GetSuperGroupMsgReq) ProtoMessage() {}
func (*GetSuperGroupMsgReq) Descriptor() ([]byte, []int) { func (*GetSuperGroupMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{18} return fileDescriptor_msg_21d1ceb5221a9786, []int{18}
} }
func (m *GetSuperGroupMsgReq) XXX_Unmarshal(b []byte) error { func (m *GetSuperGroupMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSuperGroupMsgReq.Unmarshal(m, b) return xxx_messageInfo_GetSuperGroupMsgReq.Unmarshal(m, b)
@ -1068,7 +1068,7 @@ func (m *GetSuperGroupMsgResp) Reset() { *m = GetSuperGroupMsgResp{} }
func (m *GetSuperGroupMsgResp) String() string { return proto.CompactTextString(m) } func (m *GetSuperGroupMsgResp) String() string { return proto.CompactTextString(m) }
func (*GetSuperGroupMsgResp) ProtoMessage() {} func (*GetSuperGroupMsgResp) ProtoMessage() {}
func (*GetSuperGroupMsgResp) Descriptor() ([]byte, []int) { func (*GetSuperGroupMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{19} return fileDescriptor_msg_21d1ceb5221a9786, []int{19}
} }
func (m *GetSuperGroupMsgResp) XXX_Unmarshal(b []byte) error { func (m *GetSuperGroupMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSuperGroupMsgResp.Unmarshal(m, b) return xxx_messageInfo_GetSuperGroupMsgResp.Unmarshal(m, b)
@ -1121,7 +1121,7 @@ func (m *GetWriteDiffMsgReq) Reset() { *m = GetWriteDiffMsgReq{} }
func (m *GetWriteDiffMsgReq) String() string { return proto.CompactTextString(m) } func (m *GetWriteDiffMsgReq) String() string { return proto.CompactTextString(m) }
func (*GetWriteDiffMsgReq) ProtoMessage() {} func (*GetWriteDiffMsgReq) ProtoMessage() {}
func (*GetWriteDiffMsgReq) Descriptor() ([]byte, []int) { func (*GetWriteDiffMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{20} return fileDescriptor_msg_21d1ceb5221a9786, []int{20}
} }
func (m *GetWriteDiffMsgReq) XXX_Unmarshal(b []byte) error { func (m *GetWriteDiffMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWriteDiffMsgReq.Unmarshal(m, b) return xxx_messageInfo_GetWriteDiffMsgReq.Unmarshal(m, b)
@ -1168,7 +1168,7 @@ func (m *GetWriteDiffMsgResp) Reset() { *m = GetWriteDiffMsgResp{} }
func (m *GetWriteDiffMsgResp) String() string { return proto.CompactTextString(m) } func (m *GetWriteDiffMsgResp) String() string { return proto.CompactTextString(m) }
func (*GetWriteDiffMsgResp) ProtoMessage() {} func (*GetWriteDiffMsgResp) ProtoMessage() {}
func (*GetWriteDiffMsgResp) Descriptor() ([]byte, []int) { func (*GetWriteDiffMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{21} return fileDescriptor_msg_21d1ceb5221a9786, []int{21}
} }
func (m *GetWriteDiffMsgResp) XXX_Unmarshal(b []byte) error { func (m *GetWriteDiffMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWriteDiffMsgResp.Unmarshal(m, b) return xxx_messageInfo_GetWriteDiffMsgResp.Unmarshal(m, b)
@ -1230,7 +1230,7 @@ func (m *ModifyMessageReactionExtensionsReq) Reset() { *m = ModifyMessag
func (m *ModifyMessageReactionExtensionsReq) String() string { return proto.CompactTextString(m) } func (m *ModifyMessageReactionExtensionsReq) String() string { return proto.CompactTextString(m) }
func (*ModifyMessageReactionExtensionsReq) ProtoMessage() {} func (*ModifyMessageReactionExtensionsReq) ProtoMessage() {}
func (*ModifyMessageReactionExtensionsReq) Descriptor() ([]byte, []int) { func (*ModifyMessageReactionExtensionsReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{22} return fileDescriptor_msg_21d1ceb5221a9786, []int{22}
} }
func (m *ModifyMessageReactionExtensionsReq) XXX_Unmarshal(b []byte) error { func (m *ModifyMessageReactionExtensionsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ModifyMessageReactionExtensionsReq.Unmarshal(m, b) return xxx_messageInfo_ModifyMessageReactionExtensionsReq.Unmarshal(m, b)
@ -1341,7 +1341,7 @@ func (m *ModifyMessageReactionExtensionsResp) Reset() { *m = ModifyMessa
func (m *ModifyMessageReactionExtensionsResp) String() string { return proto.CompactTextString(m) } func (m *ModifyMessageReactionExtensionsResp) String() string { return proto.CompactTextString(m) }
func (*ModifyMessageReactionExtensionsResp) ProtoMessage() {} func (*ModifyMessageReactionExtensionsResp) ProtoMessage() {}
func (*ModifyMessageReactionExtensionsResp) Descriptor() ([]byte, []int) { func (*ModifyMessageReactionExtensionsResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{23} return fileDescriptor_msg_21d1ceb5221a9786, []int{23}
} }
func (m *ModifyMessageReactionExtensionsResp) XXX_Unmarshal(b []byte) error { func (m *ModifyMessageReactionExtensionsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ModifyMessageReactionExtensionsResp.Unmarshal(m, b) return xxx_messageInfo_ModifyMessageReactionExtensionsResp.Unmarshal(m, b)
@ -1393,7 +1393,7 @@ type OperateMessageListReactionExtensionsReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"` OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
OpUserID string `protobuf:"bytes,2,opt,name=opUserID" json:"opUserID,omitempty"` OpUserID string `protobuf:"bytes,2,opt,name=opUserID" json:"opUserID,omitempty"`
SourceID string `protobuf:"bytes,3,opt,name=sourceID" json:"sourceID,omitempty"` SourceID string `protobuf:"bytes,3,opt,name=sourceID" json:"sourceID,omitempty"`
SessionType string `protobuf:"bytes,4,opt,name=sessionType" json:"sessionType,omitempty"` SessionType int32 `protobuf:"varint,4,opt,name=sessionType" json:"sessionType,omitempty"`
MessageReactionKeyList []*OperateMessageListReactionExtensionsReq_MessageReactionKey `protobuf:"bytes,5,rep,name=messageReactionKeyList" json:"messageReactionKeyList,omitempty"` MessageReactionKeyList []*OperateMessageListReactionExtensionsReq_MessageReactionKey `protobuf:"bytes,5,rep,name=messageReactionKeyList" json:"messageReactionKeyList,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
@ -1406,7 +1406,7 @@ func (m *OperateMessageListReactionExtensionsReq) Reset() {
func (m *OperateMessageListReactionExtensionsReq) String() string { return proto.CompactTextString(m) } func (m *OperateMessageListReactionExtensionsReq) String() string { return proto.CompactTextString(m) }
func (*OperateMessageListReactionExtensionsReq) ProtoMessage() {} func (*OperateMessageListReactionExtensionsReq) ProtoMessage() {}
func (*OperateMessageListReactionExtensionsReq) Descriptor() ([]byte, []int) { func (*OperateMessageListReactionExtensionsReq) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{24} return fileDescriptor_msg_21d1ceb5221a9786, []int{24}
} }
func (m *OperateMessageListReactionExtensionsReq) XXX_Unmarshal(b []byte) error { func (m *OperateMessageListReactionExtensionsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OperateMessageListReactionExtensionsReq.Unmarshal(m, b) return xxx_messageInfo_OperateMessageListReactionExtensionsReq.Unmarshal(m, b)
@ -1447,11 +1447,11 @@ func (m *OperateMessageListReactionExtensionsReq) GetSourceID() string {
return "" return ""
} }
func (m *OperateMessageListReactionExtensionsReq) GetSessionType() string { func (m *OperateMessageListReactionExtensionsReq) GetSessionType() int32 {
if m != nil { if m != nil {
return m.SessionType return m.SessionType
} }
return "" return 0
} }
func (m *OperateMessageListReactionExtensionsReq) GetMessageReactionKeyList() []*OperateMessageListReactionExtensionsReq_MessageReactionKey { func (m *OperateMessageListReactionExtensionsReq) GetMessageReactionKeyList() []*OperateMessageListReactionExtensionsReq_MessageReactionKey {
@ -1478,7 +1478,7 @@ func (m *OperateMessageListReactionExtensionsReq_MessageReactionKey) String() st
} }
func (*OperateMessageListReactionExtensionsReq_MessageReactionKey) ProtoMessage() {} func (*OperateMessageListReactionExtensionsReq_MessageReactionKey) ProtoMessage() {}
func (*OperateMessageListReactionExtensionsReq_MessageReactionKey) Descriptor() ([]byte, []int) { func (*OperateMessageListReactionExtensionsReq_MessageReactionKey) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{24, 0} return fileDescriptor_msg_21d1ceb5221a9786, []int{24, 0}
} }
func (m *OperateMessageListReactionExtensionsReq_MessageReactionKey) XXX_Unmarshal(b []byte) error { func (m *OperateMessageListReactionExtensionsReq_MessageReactionKey) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OperateMessageListReactionExtensionsReq_MessageReactionKey.Unmarshal(m, b) return xxx_messageInfo_OperateMessageListReactionExtensionsReq_MessageReactionKey.Unmarshal(m, b)
@ -1535,7 +1535,7 @@ func (m *OperateMessageListReactionExtensionsResp) Reset() {
func (m *OperateMessageListReactionExtensionsResp) String() string { return proto.CompactTextString(m) } func (m *OperateMessageListReactionExtensionsResp) String() string { return proto.CompactTextString(m) }
func (*OperateMessageListReactionExtensionsResp) ProtoMessage() {} func (*OperateMessageListReactionExtensionsResp) ProtoMessage() {}
func (*OperateMessageListReactionExtensionsResp) Descriptor() ([]byte, []int) { func (*OperateMessageListReactionExtensionsResp) Descriptor() ([]byte, []int) {
return fileDescriptor_msg_c6fbff1b04f5a192, []int{25} return fileDescriptor_msg_21d1ceb5221a9786, []int{25}
} }
func (m *OperateMessageListReactionExtensionsResp) XXX_Unmarshal(b []byte) error { func (m *OperateMessageListReactionExtensionsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_OperateMessageListReactionExtensionsResp.Unmarshal(m, b) return xxx_messageInfo_OperateMessageListReactionExtensionsResp.Unmarshal(m, b)
@ -2150,10 +2150,10 @@ var _Msg_serviceDesc = grpc.ServiceDesc{
Metadata: "msg/msg.proto", Metadata: "msg/msg.proto",
} }
func init() { proto.RegisterFile("msg/msg.proto", fileDescriptor_msg_c6fbff1b04f5a192) } func init() { proto.RegisterFile("msg/msg.proto", fileDescriptor_msg_21d1ceb5221a9786) }
var fileDescriptor_msg_c6fbff1b04f5a192 = []byte{ var fileDescriptor_msg_21d1ceb5221a9786 = []byte{
// 1363 bytes of a gzipped FileDescriptorProto // 1360 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x58, 0x4f, 0x6f, 0x1b, 0x45, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x58, 0x4f, 0x6f, 0x1b, 0x45,
0x14, 0xd7, 0xda, 0x71, 0xfe, 0x3c, 0xa7, 0x4a, 0x98, 0xa6, 0x61, 0xbb, 0x8d, 0x84, 0x59, 0xfe, 0x14, 0xd7, 0xda, 0x71, 0xfe, 0x3c, 0xa7, 0x4a, 0x98, 0xa6, 0x61, 0xbb, 0x8d, 0x84, 0x59, 0xfe,
0xd4, 0x82, 0xd6, 0x11, 0x01, 0x09, 0x44, 0x11, 0xb4, 0xa9, 0x83, 0x1b, 0x95, 0x25, 0xcd, 0x3a, 0xd4, 0x82, 0xd6, 0x11, 0x01, 0x09, 0x44, 0x11, 0xb4, 0xa9, 0x83, 0x1b, 0x95, 0x25, 0xcd, 0x3a,
@ -2217,27 +2217,26 @@ var fileDescriptor_msg_c6fbff1b04f5a192 = []byte{
0x50, 0x66, 0xbd, 0x56, 0x0b, 0x19, 0x53, 0xba, 0xcc, 0xad, 0x1c, 0x58, 0x62, 0x25, 0xd1, 0xf5, 0x50, 0x66, 0xbd, 0x56, 0x0b, 0x19, 0x53, 0xba, 0xcc, 0xad, 0x1c, 0x58, 0x62, 0x25, 0xd1, 0xf5,
0xa8, 0x13, 0xc8, 0x67, 0x00, 0x27, 0x8e, 0xd7, 0xc1, 0xb6, 0x98, 0xbe, 0x30, 0xc3, 0x74, 0x25, 0xa8, 0x13, 0xc8, 0x67, 0x00, 0x27, 0x8e, 0xd7, 0xc1, 0xb6, 0x98, 0xbe, 0x30, 0xc3, 0x74, 0x25,
0xde, 0x7c, 0x51, 0x84, 0x9b, 0xb2, 0xa3, 0x44, 0x6b, 0xdc, 0xc6, 0xbe, 0xc2, 0x81, 0x9b, 0xd8, 0xde, 0x7c, 0x51, 0x84, 0x9b, 0xb2, 0xa3, 0x44, 0x6b, 0xdc, 0xc6, 0xbe, 0xc2, 0x81, 0x9b, 0xd8,
0xd1, 0xa8, 0x87, 0xb1, 0x98, 0x3a, 0x8c, 0x39, 0x07, 0x6e, 0x25, 0x79, 0xe0, 0xce, 0x61, 0xb3, 0xd1, 0xa8, 0x87, 0xb1, 0x98, 0x3a, 0x8c, 0xd3, 0x0f, 0xdc, 0x39, 0x6c, 0x76, 0x93, 0x85, 0x7f,
0x9b, 0x2c, 0xfc, 0x43, 0x1c, 0x28, 0x27, 0xee, 0x0b, 0x71, 0xe2, 0x66, 0x64, 0x52, 0xb3, 0x32, 0x88, 0x03, 0xe5, 0xc4, 0x7d, 0x21, 0x4e, 0xdc, 0x8c, 0x4c, 0x6a, 0x56, 0x26, 0x95, 0x3d, 0x21,
0xa9, 0xec, 0x09, 0xe9, 0x8d, 0xbf, 0xf9, 0xdb, 0x22, 0x33, 0x94, 0x3e, 0x86, 0x5a, 0xf6, 0x18, 0xbd, 0xf1, 0x37, 0x7f, 0x5b, 0x64, 0x86, 0xd2, 0xc7, 0x50, 0xcb, 0x1e, 0xc3, 0x7c, 0x21, 0x17,
0xe6, 0x0b, 0xb9, 0x30, 0x49, 0xc8, 0xe4, 0x70, 0xd2, 0x27, 0x45, 0x2a, 0xe2, 0xa5, 0x42, 0xcd, 0x26, 0x09, 0x99, 0x1c, 0x4e, 0xfa, 0xa4, 0x48, 0x45, 0xbc, 0x54, 0xa8, 0xf9, 0x33, 0xcd, 0x17,
0x9f, 0x69, 0xbe, 0xd0, 0xa0, 0x3a, 0x5b, 0x49, 0xfe, 0x7f, 0xca, 0xdd, 0xf9, 0x1d, 0x80, 0x3f, 0x1a, 0x54, 0x67, 0x2b, 0xc9, 0xff, 0x4f, 0xb9, 0x3b, 0xbf, 0x03, 0xf0, 0xa7, 0x3c, 0x79, 0x0c,
0xe5, 0xc9, 0x63, 0x58, 0x4b, 0xbd, 0x81, 0xc8, 0x3b, 0x39, 0x49, 0xb2, 0xef, 0x2e, 0xe3, 0xdd, 0x6b, 0xa9, 0x37, 0x10, 0x79, 0x27, 0x27, 0x49, 0xf6, 0xdd, 0x65, 0xbc, 0x3b, 0x4b, 0x18, 0x0b,
0x59, 0xc2, 0x58, 0x48, 0x02, 0xd8, 0x78, 0xd4, 0xeb, 0x74, 0xe2, 0x12, 0xee, 0x0e, 0x9a, 0x78, 0x49, 0x00, 0x1b, 0x8f, 0x7a, 0x9d, 0x4e, 0x5c, 0xc2, 0xdd, 0x41, 0x13, 0xcf, 0x04, 0xfe, 0xf7,
0x26, 0xf0, 0xbf, 0x97, 0x33, 0x3f, 0x2f, 0x90, 0xaf, 0xf5, 0xfe, 0xcc, 0xb1, 0x2c, 0x24, 0xb7, 0x72, 0xe6, 0xe7, 0x05, 0xf2, 0xb5, 0xde, 0x9f, 0x39, 0x96, 0x85, 0xe4, 0x16, 0x2c, 0xc5, 0xfd,
0x60, 0x29, 0xee, 0xef, 0xc8, 0x9a, 0xd0, 0xf5, 0xf8, 0xad, 0x65, 0xac, 0x27, 0x1d, 0x2c, 0x24, 0x1d, 0x59, 0x13, 0xba, 0x1e, 0xbf, 0xb5, 0x8c, 0xf5, 0xa4, 0x83, 0x85, 0xe4, 0x10, 0xa0, 0x8e,
0x87, 0x00, 0x75, 0xec, 0x58, 0xcc, 0x95, 0xf7, 0x43, 0xce, 0x42, 0xe3, 0x61, 0x9e, 0xe1, 0xcd, 0x1d, 0x8b, 0xb9, 0xf2, 0x7e, 0xc8, 0x59, 0x68, 0x3c, 0xcc, 0x33, 0xbc, 0x39, 0x25, 0x82, 0x85,
0x29, 0x11, 0x2c, 0x24, 0x0d, 0x58, 0x4f, 0x77, 0x5e, 0x44, 0x17, 0x0b, 0xe7, 0xf4, 0x85, 0xc6, 0xa4, 0x01, 0xeb, 0xe9, 0xce, 0x8b, 0xe8, 0x62, 0xe1, 0x9c, 0xbe, 0xd0, 0xb8, 0x3e, 0x61, 0x84,
0xf5, 0x09, 0x23, 0x2c, 0x24, 0xdb, 0xb0, 0x3c, 0x7c, 0xa4, 0x10, 0x89, 0x5c, 0x79, 0x18, 0x19, 0x85, 0x64, 0x1b, 0x96, 0x87, 0x8f, 0x14, 0x22, 0x91, 0x2b, 0x0f, 0x23, 0xe3, 0xb5, 0x94, 0x87,
0xaf, 0xa5, 0x3c, 0x2c, 0x24, 0x77, 0x60, 0x55, 0xed, 0xfb, 0xc9, 0x46, 0x4c, 0x37, 0xf1, 0x4a, 0x85, 0xe4, 0x0e, 0xac, 0xaa, 0x7d, 0x3f, 0xd9, 0x88, 0xe9, 0x26, 0x5e, 0x29, 0xc6, 0xb5, 0x1c,
0x31, 0xae, 0xe5, 0x78, 0x25, 0xec, 0x74, 0x77, 0x1e, 0xc3, 0xce, 0x79, 0x05, 0xc4, 0xb0, 0x73, 0xaf, 0x84, 0x9d, 0xee, 0xce, 0x63, 0xd8, 0x39, 0xaf, 0x80, 0x18, 0x76, 0x6e, 0x3b, 0xdf, 0x80,
0xdb, 0xf9, 0x06, 0xac, 0x37, 0xf2, 0x13, 0x35, 0x26, 0x26, 0x6a, 0xbc, 0x24, 0x51, 0x4e, 0x21, 0xf5, 0x46, 0x7e, 0xa2, 0xc6, 0xc4, 0x44, 0x8d, 0x97, 0x24, 0xca, 0x29, 0x64, 0x4e, 0x3f, 0xaa,
0x73, 0xfa, 0x51, 0x25, 0x51, 0xa6, 0x90, 0x75, 0xa1, 0x72, 0xb5, 0x25, 0x23, 0xaf, 0x0f, 0xa3, 0x24, 0xca, 0x14, 0xb2, 0x2e, 0x54, 0xae, 0xb6, 0x64, 0xe4, 0xf5, 0x61, 0x74, 0xaa, 0xe5, 0x33,
0x53, 0x2d, 0x9f, 0xa1, 0xe7, 0x0f, 0xb0, 0x90, 0x9c, 0xc1, 0x16, 0x2f, 0xda, 0xa4, 0x1b, 0x8c, 0xf4, 0xfc, 0x01, 0x16, 0x92, 0x33, 0xd8, 0xe2, 0x45, 0x9b, 0x74, 0x83, 0x91, 0x9b, 0x33, 0xf6,
0xdc, 0x9c, 0xb1, 0x6f, 0x31, 0xaa, 0xb3, 0x05, 0xb2, 0x90, 0xfc, 0x0c, 0x95, 0xc6, 0x68, 0xc9, 0x2d, 0x46, 0x75, 0xb6, 0x40, 0x16, 0x92, 0x9f, 0xa1, 0xd2, 0x18, 0x2d, 0x99, 0xff, 0xf9, 0x21,
0xfc, 0xcf, 0x0f, 0xb9, 0x75, 0x91, 0x8f, 0xb7, 0x71, 0xfb, 0x02, 0xd1, 0x92, 0xf3, 0xbd, 0x76, 0xb7, 0x2e, 0xf2, 0xf1, 0x36, 0x6e, 0x5f, 0x20, 0x5a, 0x72, 0xbe, 0xd7, 0x6e, 0x5f, 0x2a, 0xe7,
0xfb, 0x52, 0x39, 0x3f, 0x87, 0x37, 0xea, 0xd8, 0xc1, 0x11, 0xba, 0x4b, 0xa6, 0xbc, 0x7b, 0xe3, 0xe7, 0xf0, 0x46, 0x1d, 0x3b, 0x38, 0x42, 0x77, 0xc9, 0x94, 0x77, 0x6f, 0x7c, 0x7f, 0xfd, 0x20,
0xfb, 0xeb, 0x07, 0x21, 0xfa, 0xc7, 0xfb, 0x96, 0xf2, 0x77, 0x65, 0x97, 0xb9, 0x77, 0xba, 0xcc, 0x44, 0xff, 0x78, 0xdf, 0x52, 0xfe, 0xae, 0xec, 0x32, 0xf7, 0x4e, 0x97, 0xb9, 0x4f, 0x16, 0x85,
0x7d, 0xb2, 0x28, 0xcc, 0x0f, 0xff, 0x0d, 0x00, 0x00, 0xff, 0xff, 0x60, 0xb9, 0x8a, 0xda, 0x17, 0xf9, 0xe1, 0xbf, 0x01, 0x00, 0x00, 0xff, 0xff, 0x7b, 0xb1, 0xa4, 0x31, 0x17, 0x15, 0x00, 0x00,
0x15, 0x00, 0x00,
} }

12
pkg/proto/msg/msg.proto
View File

@ -179,7 +179,7 @@ message OperateMessageListReactionExtensionsReq {
string operationID = 1; string operationID = 1;
string opUserID = 2; string opUserID = 2;
string sourceID = 3; string sourceID = 3;
string sessionType = 4; int32 sessionType = 4;
message MessageReactionKey { message MessageReactionKey {
string clientMsgID = 1; string clientMsgID = 1;
int64 msgFirstModifyTime = 2; int64 msgFirstModifyTime = 2;
@ -191,8 +191,14 @@ message OperateMessageListReactionExtensionsReq {
message OperateMessageListReactionExtensionsResp { message OperateMessageListReactionExtensionsResp {
int32 errCode = 1; int32 errCode = 1;
string errMsg = 2; string errMsg = 2;
repeated server_api_params.ExtendMsg successList = 3; repeated ExtendMsgResp successList = 3;
repeated server_api_params.ExtendMsg failedList = 4; repeated ExtendMsgResp failedList = 4;
}
message ExtendMsgResp {
server_api_params.ExtendMsg extendMsg = 1;
int32 errCode = 2;
string errMsg = 3;
} }
service msg { service msg {