You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Open-IM-Server/pkg/proto/msg/msg.pb.go

2724 lines
103 KiB

2 years ago
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: msg/msg.proto
2 years ago
package msg // import "OpenIM/pkg/proto/msg"
2 years ago
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
2 years ago
import sdkws "OpenIM/pkg/proto/sdkws"
2 years ago
import wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
2 years ago
import (
2 years ago
context "golang.org/x/net/context"
2 years ago
grpc "google.golang.org/grpc"
)
2 years ago
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
2 years ago
2 years ago
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
2 years ago
2 years ago
type MsgDataToMQ struct {
Token string `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
OperationID string `protobuf:"bytes,2,opt,name=operationID" json:"operationID,omitempty"`
MsgData *sdkws.MsgData `protobuf:"bytes,3,opt,name=msgData" json:"msgData,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *MsgDataToMQ) Reset() { *m = MsgDataToMQ{} }
func (m *MsgDataToMQ) String() string { return proto.CompactTextString(m) }
func (*MsgDataToMQ) ProtoMessage() {}
func (*MsgDataToMQ) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{0}
2 years ago
}
2 years ago
func (m *MsgDataToMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToMQ.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *MsgDataToMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgDataToMQ.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *MsgDataToMQ) XXX_Merge(src proto.Message) {
xxx_messageInfo_MsgDataToMQ.Merge(dst, src)
2 years ago
}
2 years ago
func (m *MsgDataToMQ) XXX_Size() int {
return xxx_messageInfo_MsgDataToMQ.Size(m)
}
func (m *MsgDataToMQ) XXX_DiscardUnknown() {
xxx_messageInfo_MsgDataToMQ.DiscardUnknown(m)
}
var xxx_messageInfo_MsgDataToMQ proto.InternalMessageInfo
2 years ago
2 years ago
func (m *MsgDataToMQ) GetToken() string {
if m != nil {
return m.Token
2 years ago
}
return ""
}
2 years ago
func (m *MsgDataToMQ) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
return ""
}
func (m *MsgDataToMQ) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
2 years ago
}
return nil
}
type MsgDataToDB struct {
MsgData *sdkws.MsgData `protobuf:"bytes,1,opt,name=msgData" json:"msgData,omitempty"`
OperationID string `protobuf:"bytes,2,opt,name=operationID" json:"operationID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *MsgDataToDB) Reset() { *m = MsgDataToDB{} }
func (m *MsgDataToDB) String() string { return proto.CompactTextString(m) }
func (*MsgDataToDB) ProtoMessage() {}
func (*MsgDataToDB) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{1}
2 years ago
}
2 years ago
func (m *MsgDataToDB) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToDB.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *MsgDataToDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgDataToDB.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *MsgDataToDB) XXX_Merge(src proto.Message) {
xxx_messageInfo_MsgDataToDB.Merge(dst, src)
}
func (m *MsgDataToDB) XXX_Size() int {
return xxx_messageInfo_MsgDataToDB.Size(m)
}
func (m *MsgDataToDB) XXX_DiscardUnknown() {
xxx_messageInfo_MsgDataToDB.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_MsgDataToDB proto.InternalMessageInfo
func (m *MsgDataToDB) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
2 years ago
}
return nil
}
2 years ago
func (m *MsgDataToDB) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
return ""
}
type PushMsgDataToMQ struct {
OperationID string `protobuf:"bytes,1,opt,name=OperationID" json:"OperationID,omitempty"`
MsgData *sdkws.MsgData `protobuf:"bytes,2,opt,name=msgData" json:"msgData,omitempty"`
PushToUserID string `protobuf:"bytes,3,opt,name=pushToUserID" json:"pushToUserID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *PushMsgDataToMQ) Reset() { *m = PushMsgDataToMQ{} }
func (m *PushMsgDataToMQ) String() string { return proto.CompactTextString(m) }
func (*PushMsgDataToMQ) ProtoMessage() {}
func (*PushMsgDataToMQ) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{2}
2 years ago
}
2 years ago
func (m *PushMsgDataToMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PushMsgDataToMQ.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *PushMsgDataToMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PushMsgDataToMQ.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *PushMsgDataToMQ) XXX_Merge(src proto.Message) {
xxx_messageInfo_PushMsgDataToMQ.Merge(dst, src)
2 years ago
}
2 years ago
func (m *PushMsgDataToMQ) XXX_Size() int {
return xxx_messageInfo_PushMsgDataToMQ.Size(m)
}
func (m *PushMsgDataToMQ) XXX_DiscardUnknown() {
xxx_messageInfo_PushMsgDataToMQ.DiscardUnknown(m)
}
var xxx_messageInfo_PushMsgDataToMQ proto.InternalMessageInfo
2 years ago
2 years ago
func (m *PushMsgDataToMQ) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
return ""
}
func (m *PushMsgDataToMQ) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
2 years ago
}
return nil
}
2 years ago
func (m *PushMsgDataToMQ) GetPushToUserID() string {
if m != nil {
return m.PushToUserID
2 years ago
}
return ""
}
type MsgDataToMongoByMQ struct {
2 years ago
LastSeq uint64 `protobuf:"varint,1,opt,name=lastSeq" json:"lastSeq,omitempty"`
AggregationID string `protobuf:"bytes,2,opt,name=aggregationID" json:"aggregationID,omitempty"`
MessageList []*MsgDataToMQ `protobuf:"bytes,3,rep,name=messageList" json:"messageList,omitempty"`
TriggerID string `protobuf:"bytes,4,opt,name=triggerID" json:"triggerID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MsgDataToMongoByMQ) Reset() { *m = MsgDataToMongoByMQ{} }
func (m *MsgDataToMongoByMQ) String() string { return proto.CompactTextString(m) }
func (*MsgDataToMongoByMQ) ProtoMessage() {}
func (*MsgDataToMongoByMQ) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{3}
2 years ago
}
2 years ago
func (m *MsgDataToMongoByMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToMongoByMQ.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *MsgDataToMongoByMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgDataToMongoByMQ.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *MsgDataToMongoByMQ) XXX_Merge(src proto.Message) {
xxx_messageInfo_MsgDataToMongoByMQ.Merge(dst, src)
2 years ago
}
2 years ago
func (m *MsgDataToMongoByMQ) XXX_Size() int {
return xxx_messageInfo_MsgDataToMongoByMQ.Size(m)
}
func (m *MsgDataToMongoByMQ) XXX_DiscardUnknown() {
xxx_messageInfo_MsgDataToMongoByMQ.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_MsgDataToMongoByMQ proto.InternalMessageInfo
func (m *MsgDataToMongoByMQ) GetLastSeq() uint64 {
if m != nil {
return m.LastSeq
2 years ago
}
return 0
}
2 years ago
func (m *MsgDataToMongoByMQ) GetAggregationID() string {
if m != nil {
return m.AggregationID
2 years ago
}
return ""
}
2 years ago
func (m *MsgDataToMongoByMQ) GetMessageList() []*MsgDataToMQ {
if m != nil {
return m.MessageList
2 years ago
}
return nil
}
2 years ago
func (m *MsgDataToMongoByMQ) GetTriggerID() string {
if m != nil {
return m.TriggerID
2 years ago
}
return ""
}
type GetMaxAndMinSeqReq struct {
2 years ago
UserID string `protobuf:"bytes,1,opt,name=UserID" json:"UserID,omitempty"`
OperationID string `protobuf:"bytes,2,opt,name=OperationID" json:"OperationID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *GetMaxAndMinSeqReq) Reset() { *m = GetMaxAndMinSeqReq{} }
func (m *GetMaxAndMinSeqReq) String() string { return proto.CompactTextString(m) }
func (*GetMaxAndMinSeqReq) ProtoMessage() {}
func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{4}
2 years ago
}
2 years ago
func (m *GetMaxAndMinSeqReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMaxAndMinSeqReq.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *GetMaxAndMinSeqReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetMaxAndMinSeqReq.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *GetMaxAndMinSeqReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetMaxAndMinSeqReq.Merge(dst, src)
}
func (m *GetMaxAndMinSeqReq) XXX_Size() int {
return xxx_messageInfo_GetMaxAndMinSeqReq.Size(m)
}
func (m *GetMaxAndMinSeqReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetMaxAndMinSeqReq.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_GetMaxAndMinSeqReq proto.InternalMessageInfo
func (m *GetMaxAndMinSeqReq) GetUserID() string {
if m != nil {
return m.UserID
2 years ago
}
return ""
}
2 years ago
func (m *GetMaxAndMinSeqReq) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
return ""
}
type GetMaxAndMinSeqResp struct {
2 years ago
ErrCode int32 `protobuf:"varint,1,opt,name=ErrCode" json:"ErrCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=ErrMsg" json:"ErrMsg,omitempty"`
MaxSeq uint32 `protobuf:"varint,3,opt,name=MaxSeq" json:"MaxSeq,omitempty"`
MinSeq uint32 `protobuf:"varint,4,opt,name=MinSeq" json:"MinSeq,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetMaxAndMinSeqResp) Reset() { *m = GetMaxAndMinSeqResp{} }
func (m *GetMaxAndMinSeqResp) String() string { return proto.CompactTextString(m) }
func (*GetMaxAndMinSeqResp) ProtoMessage() {}
func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{5}
2 years ago
}
2 years ago
func (m *GetMaxAndMinSeqResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMaxAndMinSeqResp.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *GetMaxAndMinSeqResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetMaxAndMinSeqResp.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *GetMaxAndMinSeqResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetMaxAndMinSeqResp.Merge(dst, src)
2 years ago
}
2 years ago
func (m *GetMaxAndMinSeqResp) XXX_Size() int {
return xxx_messageInfo_GetMaxAndMinSeqResp.Size(m)
2 years ago
}
2 years ago
func (m *GetMaxAndMinSeqResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetMaxAndMinSeqResp.DiscardUnknown(m)
}
var xxx_messageInfo_GetMaxAndMinSeqResp proto.InternalMessageInfo
2 years ago
2 years ago
func (m *GetMaxAndMinSeqResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
2 years ago
}
return 0
}
2 years ago
func (m *GetMaxAndMinSeqResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
2 years ago
}
return ""
}
2 years ago
func (m *GetMaxAndMinSeqResp) GetMaxSeq() uint32 {
if m != nil {
return m.MaxSeq
2 years ago
}
return 0
}
2 years ago
func (m *GetMaxAndMinSeqResp) GetMinSeq() uint32 {
if m != nil {
return m.MinSeq
2 years ago
}
return 0
}
type SendMsgReq struct {
MsgData *sdkws.MsgData `protobuf:"bytes,3,opt,name=msgData" json:"msgData,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *SendMsgReq) Reset() { *m = SendMsgReq{} }
func (m *SendMsgReq) String() string { return proto.CompactTextString(m) }
func (*SendMsgReq) ProtoMessage() {}
func (*SendMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{6}
2 years ago
}
2 years ago
func (m *SendMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SendMsgReq.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *SendMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SendMsgReq.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *SendMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_SendMsgReq.Merge(dst, src)
}
func (m *SendMsgReq) XXX_Size() int {
return xxx_messageInfo_SendMsgReq.Size(m)
}
func (m *SendMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_SendMsgReq.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_SendMsgReq proto.InternalMessageInfo
func (m *SendMsgReq) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
2 years ago
}
return nil
}
type SendMsgResp struct {
2 years ago
ServerMsgID string `protobuf:"bytes,4,opt,name=serverMsgID" json:"serverMsgID,omitempty"`
ClientMsgID string `protobuf:"bytes,5,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
SendTime int64 `protobuf:"varint,6,opt,name=sendTime" json:"sendTime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SendMsgResp) Reset() { *m = SendMsgResp{} }
func (m *SendMsgResp) String() string { return proto.CompactTextString(m) }
func (*SendMsgResp) ProtoMessage() {}
func (*SendMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{7}
2 years ago
}
2 years ago
func (m *SendMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SendMsgResp.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *SendMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SendMsgResp.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *SendMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_SendMsgResp.Merge(dst, src)
2 years ago
}
2 years ago
func (m *SendMsgResp) XXX_Size() int {
return xxx_messageInfo_SendMsgResp.Size(m)
2 years ago
}
2 years ago
func (m *SendMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_SendMsgResp.DiscardUnknown(m)
}
var xxx_messageInfo_SendMsgResp proto.InternalMessageInfo
2 years ago
2 years ago
func (m *SendMsgResp) GetServerMsgID() string {
if m != nil {
return m.ServerMsgID
2 years ago
}
return ""
}
2 years ago
func (m *SendMsgResp) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
2 years ago
}
return ""
}
2 years ago
func (m *SendMsgResp) GetSendTime() int64 {
if m != nil {
return m.SendTime
2 years ago
}
return 0
}
type ClearMsgReq struct {
2 years ago
UserID string `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *ClearMsgReq) Reset() { *m = ClearMsgReq{} }
func (m *ClearMsgReq) String() string { return proto.CompactTextString(m) }
func (*ClearMsgReq) ProtoMessage() {}
func (*ClearMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{8}
2 years ago
}
2 years ago
func (m *ClearMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ClearMsgReq.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *ClearMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ClearMsgReq.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *ClearMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_ClearMsgReq.Merge(dst, src)
}
func (m *ClearMsgReq) XXX_Size() int {
return xxx_messageInfo_ClearMsgReq.Size(m)
}
func (m *ClearMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_ClearMsgReq.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_ClearMsgReq proto.InternalMessageInfo
func (m *ClearMsgReq) GetUserID() string {
if m != nil {
return m.UserID
2 years ago
}
return ""
}
type ClearMsgResp struct {
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *ClearMsgResp) Reset() { *m = ClearMsgResp{} }
func (m *ClearMsgResp) String() string { return proto.CompactTextString(m) }
func (*ClearMsgResp) ProtoMessage() {}
func (*ClearMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{9}
2 years ago
}
2 years ago
func (m *ClearMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ClearMsgResp.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *ClearMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ClearMsgResp.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *ClearMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_ClearMsgResp.Merge(dst, src)
2 years ago
}
2 years ago
func (m *ClearMsgResp) XXX_Size() int {
return xxx_messageInfo_ClearMsgResp.Size(m)
}
func (m *ClearMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_ClearMsgResp.DiscardUnknown(m)
}
var xxx_messageInfo_ClearMsgResp proto.InternalMessageInfo
2 years ago
type SetMsgMinSeqReq struct {
2 years ago
UserID string `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
GroupID string `protobuf:"bytes,2,opt,name=groupID" json:"groupID,omitempty"`
MinSeq uint32 `protobuf:"varint,3,opt,name=minSeq" json:"minSeq,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SetMsgMinSeqReq) Reset() { *m = SetMsgMinSeqReq{} }
func (m *SetMsgMinSeqReq) String() string { return proto.CompactTextString(m) }
func (*SetMsgMinSeqReq) ProtoMessage() {}
func (*SetMsgMinSeqReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{10}
2 years ago
}
2 years ago
func (m *SetMsgMinSeqReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetMsgMinSeqReq.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *SetMsgMinSeqReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetMsgMinSeqReq.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *SetMsgMinSeqReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetMsgMinSeqReq.Merge(dst, src)
2 years ago
}
2 years ago
func (m *SetMsgMinSeqReq) XXX_Size() int {
return xxx_messageInfo_SetMsgMinSeqReq.Size(m)
}
func (m *SetMsgMinSeqReq) XXX_DiscardUnknown() {
xxx_messageInfo_SetMsgMinSeqReq.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_SetMsgMinSeqReq proto.InternalMessageInfo
func (m *SetMsgMinSeqReq) GetUserID() string {
if m != nil {
return m.UserID
2 years ago
}
return ""
}
2 years ago
func (m *SetMsgMinSeqReq) GetGroupID() string {
if m != nil {
return m.GroupID
2 years ago
}
return ""
}
2 years ago
func (m *SetMsgMinSeqReq) GetMinSeq() uint32 {
if m != nil {
return m.MinSeq
2 years ago
}
return 0
}
type SetMsgMinSeqResp struct {
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *SetMsgMinSeqResp) Reset() { *m = SetMsgMinSeqResp{} }
func (m *SetMsgMinSeqResp) String() string { return proto.CompactTextString(m) }
func (*SetMsgMinSeqResp) ProtoMessage() {}
func (*SetMsgMinSeqResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{11}
2 years ago
}
2 years ago
func (m *SetMsgMinSeqResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetMsgMinSeqResp.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *SetMsgMinSeqResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetMsgMinSeqResp.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *SetMsgMinSeqResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetMsgMinSeqResp.Merge(dst, src)
}
func (m *SetMsgMinSeqResp) XXX_Size() int {
return xxx_messageInfo_SetMsgMinSeqResp.Size(m)
}
func (m *SetMsgMinSeqResp) XXX_DiscardUnknown() {
xxx_messageInfo_SetMsgMinSeqResp.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_SetMsgMinSeqResp proto.InternalMessageInfo
2 years ago
type SetSendMsgStatusReq struct {
2 years ago
Status int32 `protobuf:"varint,2,opt,name=status" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *SetSendMsgStatusReq) Reset() { *m = SetSendMsgStatusReq{} }
func (m *SetSendMsgStatusReq) String() string { return proto.CompactTextString(m) }
func (*SetSendMsgStatusReq) ProtoMessage() {}
func (*SetSendMsgStatusReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{12}
2 years ago
}
2 years ago
func (m *SetSendMsgStatusReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetSendMsgStatusReq.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *SetSendMsgStatusReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetSendMsgStatusReq.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *SetSendMsgStatusReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetSendMsgStatusReq.Merge(dst, src)
}
func (m *SetSendMsgStatusReq) XXX_Size() int {
return xxx_messageInfo_SetSendMsgStatusReq.Size(m)
2 years ago
}
2 years ago
func (m *SetSendMsgStatusReq) XXX_DiscardUnknown() {
xxx_messageInfo_SetSendMsgStatusReq.DiscardUnknown(m)
}
var xxx_messageInfo_SetSendMsgStatusReq proto.InternalMessageInfo
2 years ago
2 years ago
func (m *SetSendMsgStatusReq) GetStatus() int32 {
if m != nil {
return m.Status
2 years ago
}
return 0
}
type SetSendMsgStatusResp struct {
2 years ago
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *SetSendMsgStatusResp) Reset() { *m = SetSendMsgStatusResp{} }
func (m *SetSendMsgStatusResp) String() string { return proto.CompactTextString(m) }
func (*SetSendMsgStatusResp) ProtoMessage() {}
func (*SetSendMsgStatusResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{13}
2 years ago
}
2 years ago
func (m *SetSendMsgStatusResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetSendMsgStatusResp.Unmarshal(m, b)
2 years ago
}
2 years ago
func (m *SetSendMsgStatusResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetSendMsgStatusResp.Marshal(b, m, deterministic)
2 years ago
}
2 years ago
func (dst *SetSendMsgStatusResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetSendMsgStatusResp.Merge(dst, src)
}
func (m *SetSendMsgStatusResp) XXX_Size() int {
return xxx_messageInfo_SetSendMsgStatusResp.Size(m)
}
func (m *SetSendMsgStatusResp) XXX_DiscardUnknown() {
xxx_messageInfo_SetSendMsgStatusResp.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_SetSendMsgStatusResp proto.InternalMessageInfo
2 years ago
type GetSendMsgStatusReq struct {
2 years ago
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *GetSendMsgStatusReq) Reset() { *m = GetSendMsgStatusReq{} }
func (m *GetSendMsgStatusReq) String() string { return proto.CompactTextString(m) }
func (*GetSendMsgStatusReq) ProtoMessage() {}
func (*GetSendMsgStatusReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{14}
2 years ago
}
2 years ago
func (m *GetSendMsgStatusReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSendMsgStatusReq.Unmarshal(m, b)
}
func (m *GetSendMsgStatusReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetSendMsgStatusReq.Marshal(b, m, deterministic)
}
func (dst *GetSendMsgStatusReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetSendMsgStatusReq.Merge(dst, src)
}
func (m *GetSendMsgStatusReq) XXX_Size() int {
return xxx_messageInfo_GetSendMsgStatusReq.Size(m)
}
func (m *GetSendMsgStatusReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetSendMsgStatusReq.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_GetSendMsgStatusReq proto.InternalMessageInfo
2 years ago
2 years ago
func (m *GetSendMsgStatusReq) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
2 years ago
return ""
2 years ago
}
2 years ago
type GetSendMsgStatusResp struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
Status int32 `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *GetSendMsgStatusResp) Reset() { *m = GetSendMsgStatusResp{} }
func (m *GetSendMsgStatusResp) String() string { return proto.CompactTextString(m) }
func (*GetSendMsgStatusResp) ProtoMessage() {}
func (*GetSendMsgStatusResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{15}
2 years ago
}
func (m *GetSendMsgStatusResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSendMsgStatusResp.Unmarshal(m, b)
}
func (m *GetSendMsgStatusResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetSendMsgStatusResp.Marshal(b, m, deterministic)
}
func (dst *GetSendMsgStatusResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetSendMsgStatusResp.Merge(dst, src)
}
func (m *GetSendMsgStatusResp) XXX_Size() int {
return xxx_messageInfo_GetSendMsgStatusResp.Size(m)
}
func (m *GetSendMsgStatusResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetSendMsgStatusResp.DiscardUnknown(m)
2 years ago
}
2 years ago
var xxx_messageInfo_GetSendMsgStatusResp proto.InternalMessageInfo
2 years ago
2 years ago
func (m *GetSendMsgStatusResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
2 years ago
}
2 years ago
2 years ago
func (m *GetSendMsgStatusResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
2 years ago
}
2 years ago
return ""
2 years ago
}
2 years ago
2 years ago
func (m *GetSendMsgStatusResp) GetStatus() int32 {
if m != nil {
return m.Status
}
return 0
2 years ago
}
2 years ago
2 years ago
type DelSuperGroupMsgReq struct {
UserID string `protobuf:"bytes,2,opt,name=userID" json:"userID,omitempty"`
GroupID string `protobuf:"bytes,3,opt,name=groupID" json:"groupID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DelSuperGroupMsgReq) Reset() { *m = DelSuperGroupMsgReq{} }
func (m *DelSuperGroupMsgReq) String() string { return proto.CompactTextString(m) }
func (*DelSuperGroupMsgReq) ProtoMessage() {}
func (*DelSuperGroupMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{16}
2 years ago
}
func (m *DelSuperGroupMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelSuperGroupMsgReq.Unmarshal(m, b)
}
func (m *DelSuperGroupMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DelSuperGroupMsgReq.Marshal(b, m, deterministic)
}
func (dst *DelSuperGroupMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_DelSuperGroupMsgReq.Merge(dst, src)
}
func (m *DelSuperGroupMsgReq) XXX_Size() int {
return xxx_messageInfo_DelSuperGroupMsgReq.Size(m)
}
func (m *DelSuperGroupMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_DelSuperGroupMsgReq.DiscardUnknown(m)
}
2 years ago
2 years ago
var xxx_messageInfo_DelSuperGroupMsgReq proto.InternalMessageInfo
func (m *DelSuperGroupMsgReq) GetUserID() string {
if m != nil {
return m.UserID
}
return ""
2 years ago
}
2 years ago
2 years ago
func (m *DelSuperGroupMsgReq) GetGroupID() string {
if m != nil {
return m.GroupID
2 years ago
}
2 years ago
return ""
2 years ago
}
2 years ago
type DelSuperGroupMsgResp struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
func (m *DelSuperGroupMsgResp) Reset() { *m = DelSuperGroupMsgResp{} }
func (m *DelSuperGroupMsgResp) String() string { return proto.CompactTextString(m) }
func (*DelSuperGroupMsgResp) ProtoMessage() {}
func (*DelSuperGroupMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{17}
2 years ago
}
func (m *DelSuperGroupMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelSuperGroupMsgResp.Unmarshal(m, b)
}
func (m *DelSuperGroupMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DelSuperGroupMsgResp.Marshal(b, m, deterministic)
}
func (dst *DelSuperGroupMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_DelSuperGroupMsgResp.Merge(dst, src)
}
func (m *DelSuperGroupMsgResp) XXX_Size() int {
return xxx_messageInfo_DelSuperGroupMsgResp.Size(m)
}
func (m *DelSuperGroupMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_DelSuperGroupMsgResp.DiscardUnknown(m)
}
var xxx_messageInfo_DelSuperGroupMsgResp proto.InternalMessageInfo
2 years ago
2 years ago
type GetSuperGroupMsgReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
Seq uint32 `protobuf:"varint,2,opt,name=Seq" json:"Seq,omitempty"`
GroupID string `protobuf:"bytes,3,opt,name=groupID" json:"groupID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
2 years ago
func (m *GetSuperGroupMsgReq) Reset() { *m = GetSuperGroupMsgReq{} }
func (m *GetSuperGroupMsgReq) String() string { return proto.CompactTextString(m) }
func (*GetSuperGroupMsgReq) ProtoMessage() {}
func (*GetSuperGroupMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{18}
2 years ago
}
func (m *GetSuperGroupMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSuperGroupMsgReq.Unmarshal(m, b)
}
func (m *GetSuperGroupMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetSuperGroupMsgReq.Marshal(b, m, deterministic)
}
func (dst *GetSuperGroupMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetSuperGroupMsgReq.Merge(dst, src)
}
func (m *GetSuperGroupMsgReq) XXX_Size() int {
return xxx_messageInfo_GetSuperGroupMsgReq.Size(m)
}
func (m *GetSuperGroupMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetSuperGroupMsgReq.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_GetSuperGroupMsgReq proto.InternalMessageInfo
2 years ago
2 years ago
func (m *GetSuperGroupMsgReq) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
2 years ago
return ""
2 years ago
}
2 years ago
func (m *GetSuperGroupMsgReq) GetSeq() uint32 {
if m != nil {
return m.Seq
}
return 0
2 years ago
}
2 years ago
2 years ago
func (m *GetSuperGroupMsgReq) GetGroupID() string {
if m != nil {
return m.GroupID
2 years ago
}
return ""
}
2 years ago
type GetSuperGroupMsgResp struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
MsgData *sdkws.MsgData `protobuf:"bytes,3,opt,name=msgData" json:"msgData,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *GetSuperGroupMsgResp) Reset() { *m = GetSuperGroupMsgResp{} }
func (m *GetSuperGroupMsgResp) String() string { return proto.CompactTextString(m) }
func (*GetSuperGroupMsgResp) ProtoMessage() {}
func (*GetSuperGroupMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{19}
2 years ago
}
func (m *GetSuperGroupMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetSuperGroupMsgResp.Unmarshal(m, b)
}
func (m *GetSuperGroupMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetSuperGroupMsgResp.Marshal(b, m, deterministic)
}
func (dst *GetSuperGroupMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetSuperGroupMsgResp.Merge(dst, src)
}
func (m *GetSuperGroupMsgResp) XXX_Size() int {
return xxx_messageInfo_GetSuperGroupMsgResp.Size(m)
}
func (m *GetSuperGroupMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetSuperGroupMsgResp.DiscardUnknown(m)
}
var xxx_messageInfo_GetSuperGroupMsgResp proto.InternalMessageInfo
func (m *GetSuperGroupMsgResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
2 years ago
}
2 years ago
return 0
2 years ago
}
2 years ago
func (m *GetSuperGroupMsgResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
2 years ago
}
return ""
}
func (m *GetSuperGroupMsgResp) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
2 years ago
}
2 years ago
return nil
2 years ago
}
2 years ago
type GetWriteDiffMsgReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
Seq uint32 `protobuf:"varint,2,opt,name=Seq" json:"Seq,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
2 years ago
2 years ago
func (m *GetWriteDiffMsgReq) Reset() { *m = GetWriteDiffMsgReq{} }
func (m *GetWriteDiffMsgReq) String() string { return proto.CompactTextString(m) }
func (*GetWriteDiffMsgReq) ProtoMessage() {}
func (*GetWriteDiffMsgReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{20}
2 years ago
}
func (m *GetWriteDiffMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWriteDiffMsgReq.Unmarshal(m, b)
}
func (m *GetWriteDiffMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetWriteDiffMsgReq.Marshal(b, m, deterministic)
}
func (dst *GetWriteDiffMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetWriteDiffMsgReq.Merge(dst, src)
}
func (m *GetWriteDiffMsgReq) XXX_Size() int {
return xxx_messageInfo_GetWriteDiffMsgReq.Size(m)
2 years ago
}
2 years ago
func (m *GetWriteDiffMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetWriteDiffMsgReq.DiscardUnknown(m)
}
var xxx_messageInfo_GetWriteDiffMsgReq proto.InternalMessageInfo
2 years ago
2 years ago
func (m *GetWriteDiffMsgReq) GetOperationID() string {
if m != nil {
return m.OperationID
2 years ago
}
2 years ago
return ""
2 years ago
}
2 years ago
2 years ago
func (m *GetWriteDiffMsgReq) GetSeq() uint32 {
if m != nil {
return m.Seq
}
return 0
2 years ago
}
2 years ago
2 years ago
type GetWriteDiffMsgResp struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
MsgData *sdkws.MsgData `protobuf:"bytes,3,opt,name=msgData" json:"msgData,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
2 years ago
func (m *GetWriteDiffMsgResp) Reset() { *m = GetWriteDiffMsgResp{} }
func (m *GetWriteDiffMsgResp) String() string { return proto.CompactTextString(m) }
func (*GetWriteDiffMsgResp) ProtoMessage() {}
func (*GetWriteDiffMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{21}
2 years ago
}
func (m *GetWriteDiffMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetWriteDiffMsgResp.Unmarshal(m, b)
}
func (m *GetWriteDiffMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetWriteDiffMsgResp.Marshal(b, m, deterministic)
}
func (dst *GetWriteDiffMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetWriteDiffMsgResp.Merge(dst, src)
}
func (m *GetWriteDiffMsgResp) XXX_Size() int {
return xxx_messageInfo_GetWriteDiffMsgResp.Size(m)
}
func (m *GetWriteDiffMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetWriteDiffMsgResp.DiscardUnknown(m)
2 years ago
}
2 years ago
2 years ago
var xxx_messageInfo_GetWriteDiffMsgResp proto.InternalMessageInfo
func (m *GetWriteDiffMsgResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
2 years ago
}
return 0
}
2 years ago
func (m *GetWriteDiffMsgResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
2 years ago
}
return ""
}
func (m *GetWriteDiffMsgResp) GetMsgData() *sdkws.MsgData {
2 years ago
if m != nil {
return m.MsgData
}
return nil
}
2 years ago
2 years ago
type ModifyMessageReactionExtensionsReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
SourceID string `protobuf:"bytes,2,opt,name=sourceID" json:"sourceID,omitempty"`
OpUserID string `protobuf:"bytes,3,opt,name=opUserID" json:"opUserID,omitempty"`
SessionType int32 `protobuf:"varint,4,opt,name=sessionType" json:"sessionType,omitempty"`
ReactionExtensionList map[string]*sdkws.KeyValue `protobuf:"bytes,5,rep,name=reactionExtensionList" json:"reactionExtensionList,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
ClientMsgID string `protobuf:"bytes,6,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
Ex *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=ex" json:"ex,omitempty"`
AttachedInfo *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=attachedInfo" json:"attachedInfo,omitempty"`
IsReact bool `protobuf:"varint,9,opt,name=isReact" json:"isReact,omitempty"`
IsExternalExtensions bool `protobuf:"varint,10,opt,name=isExternalExtensions" json:"isExternalExtensions,omitempty"`
MsgFirstModifyTime int64 `protobuf:"varint,11,opt,name=msgFirstModifyTime" json:"msgFirstModifyTime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *ModifyMessageReactionExtensionsReq) Reset() { *m = ModifyMessageReactionExtensionsReq{} }
func (m *ModifyMessageReactionExtensionsReq) String() string { return proto.CompactTextString(m) }
func (*ModifyMessageReactionExtensionsReq) ProtoMessage() {}
func (*ModifyMessageReactionExtensionsReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{22}
2 years ago
}
func (m *ModifyMessageReactionExtensionsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ModifyMessageReactionExtensionsReq.Unmarshal(m, b)
}
func (m *ModifyMessageReactionExtensionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ModifyMessageReactionExtensionsReq.Marshal(b, m, deterministic)
}
func (dst *ModifyMessageReactionExtensionsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_ModifyMessageReactionExtensionsReq.Merge(dst, src)
}
func (m *ModifyMessageReactionExtensionsReq) XXX_Size() int {
return xxx_messageInfo_ModifyMessageReactionExtensionsReq.Size(m)
}
func (m *ModifyMessageReactionExtensionsReq) XXX_DiscardUnknown() {
xxx_messageInfo_ModifyMessageReactionExtensionsReq.DiscardUnknown(m)
}
var xxx_messageInfo_ModifyMessageReactionExtensionsReq proto.InternalMessageInfo
func (m *ModifyMessageReactionExtensionsReq) GetOperationID() string {
if m != nil {
return m.OperationID
}
return ""
}
func (m *ModifyMessageReactionExtensionsReq) GetSourceID() string {
if m != nil {
return m.SourceID
}
return ""
}
func (m *ModifyMessageReactionExtensionsReq) GetOpUserID() string {
if m != nil {
return m.OpUserID
}
return ""
}
func (m *ModifyMessageReactionExtensionsReq) GetSessionType() int32 {
if m != nil {
return m.SessionType
}
return 0
}
func (m *ModifyMessageReactionExtensionsReq) GetReactionExtensionList() map[string]*sdkws.KeyValue {
2 years ago
if m != nil {
return m.ReactionExtensionList
}
return nil
}
func (m *ModifyMessageReactionExtensionsReq) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
}
return ""
}
func (m *ModifyMessageReactionExtensionsReq) GetEx() *wrapperspb.StringValue {
if m != nil {
return m.Ex
}
return nil
}
func (m *ModifyMessageReactionExtensionsReq) GetAttachedInfo() *wrapperspb.StringValue {
if m != nil {
return m.AttachedInfo
}
return nil
}
func (m *ModifyMessageReactionExtensionsReq) GetIsReact() bool {
if m != nil {
return m.IsReact
}
return false
}
func (m *ModifyMessageReactionExtensionsReq) GetIsExternalExtensions() bool {
if m != nil {
return m.IsExternalExtensions
}
return false
}
func (m *ModifyMessageReactionExtensionsReq) GetMsgFirstModifyTime() int64 {
if m != nil {
return m.MsgFirstModifyTime
}
return 0
}
type SetMessageReactionExtensionsReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
SourceID string `protobuf:"bytes,2,opt,name=sourceID" json:"sourceID,omitempty"`
OpUserID string `protobuf:"bytes,3,opt,name=opUserID" json:"opUserID,omitempty"`
SessionType int32 `protobuf:"varint,4,opt,name=sessionType" json:"sessionType,omitempty"`
ReactionExtensionList map[string]*sdkws.KeyValue `protobuf:"bytes,5,rep,name=reactionExtensionList" json:"reactionExtensionList,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
ClientMsgID string `protobuf:"bytes,6,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
Ex *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=ex" json:"ex,omitempty"`
AttachedInfo *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=attachedInfo" json:"attachedInfo,omitempty"`
IsReact bool `protobuf:"varint,9,opt,name=isReact" json:"isReact,omitempty"`
IsExternalExtensions bool `protobuf:"varint,10,opt,name=isExternalExtensions" json:"isExternalExtensions,omitempty"`
MsgFirstModifyTime int64 `protobuf:"varint,11,opt,name=msgFirstModifyTime" json:"msgFirstModifyTime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SetMessageReactionExtensionsReq) Reset() { *m = SetMessageReactionExtensionsReq{} }
func (m *SetMessageReactionExtensionsReq) String() string { return proto.CompactTextString(m) }
func (*SetMessageReactionExtensionsReq) ProtoMessage() {}
func (*SetMessageReactionExtensionsReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{23}
}
func (m *SetMessageReactionExtensionsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetMessageReactionExtensionsReq.Unmarshal(m, b)
}
func (m *SetMessageReactionExtensionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetMessageReactionExtensionsReq.Marshal(b, m, deterministic)
}
func (dst *SetMessageReactionExtensionsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetMessageReactionExtensionsReq.Merge(dst, src)
}
func (m *SetMessageReactionExtensionsReq) XXX_Size() int {
return xxx_messageInfo_SetMessageReactionExtensionsReq.Size(m)
}
func (m *SetMessageReactionExtensionsReq) XXX_DiscardUnknown() {
xxx_messageInfo_SetMessageReactionExtensionsReq.DiscardUnknown(m)
}
var xxx_messageInfo_SetMessageReactionExtensionsReq proto.InternalMessageInfo
func (m *SetMessageReactionExtensionsReq) GetOperationID() string {
if m != nil {
return m.OperationID
}
return ""
}
func (m *SetMessageReactionExtensionsReq) GetSourceID() string {
if m != nil {
return m.SourceID
}
return ""
}
func (m *SetMessageReactionExtensionsReq) GetOpUserID() string {
if m != nil {
return m.OpUserID
}
return ""
}
func (m *SetMessageReactionExtensionsReq) GetSessionType() int32 {
if m != nil {
return m.SessionType
}
return 0
}
func (m *SetMessageReactionExtensionsReq) GetReactionExtensionList() map[string]*sdkws.KeyValue {
if m != nil {
return m.ReactionExtensionList
}
return nil
}
func (m *SetMessageReactionExtensionsReq) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
}
return ""
}
func (m *SetMessageReactionExtensionsReq) GetEx() *wrapperspb.StringValue {
if m != nil {
return m.Ex
}
return nil
}
func (m *SetMessageReactionExtensionsReq) GetAttachedInfo() *wrapperspb.StringValue {
if m != nil {
return m.AttachedInfo
}
return nil
}
func (m *SetMessageReactionExtensionsReq) GetIsReact() bool {
if m != nil {
return m.IsReact
}
return false
}
func (m *SetMessageReactionExtensionsReq) GetIsExternalExtensions() bool {
if m != nil {
return m.IsExternalExtensions
}
return false
}
func (m *SetMessageReactionExtensionsReq) GetMsgFirstModifyTime() int64 {
if m != nil {
return m.MsgFirstModifyTime
}
return 0
}
type SetMessageReactionExtensionsResp struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
ClientMsgID string `protobuf:"bytes,3,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
MsgFirstModifyTime int64 `protobuf:"varint,4,opt,name=msgFirstModifyTime" json:"msgFirstModifyTime,omitempty"`
IsReact bool `protobuf:"varint,5,opt,name=isReact" json:"isReact,omitempty"`
Result []*KeyValueResp `protobuf:"bytes,6,rep,name=result" json:"result,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SetMessageReactionExtensionsResp) Reset() { *m = SetMessageReactionExtensionsResp{} }
func (m *SetMessageReactionExtensionsResp) String() string { return proto.CompactTextString(m) }
func (*SetMessageReactionExtensionsResp) ProtoMessage() {}
func (*SetMessageReactionExtensionsResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{24}
}
func (m *SetMessageReactionExtensionsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetMessageReactionExtensionsResp.Unmarshal(m, b)
}
func (m *SetMessageReactionExtensionsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetMessageReactionExtensionsResp.Marshal(b, m, deterministic)
}
func (dst *SetMessageReactionExtensionsResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetMessageReactionExtensionsResp.Merge(dst, src)
}
func (m *SetMessageReactionExtensionsResp) XXX_Size() int {
return xxx_messageInfo_SetMessageReactionExtensionsResp.Size(m)
}
func (m *SetMessageReactionExtensionsResp) XXX_DiscardUnknown() {
xxx_messageInfo_SetMessageReactionExtensionsResp.DiscardUnknown(m)
}
var xxx_messageInfo_SetMessageReactionExtensionsResp proto.InternalMessageInfo
func (m *SetMessageReactionExtensionsResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
}
func (m *SetMessageReactionExtensionsResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
}
return ""
}
func (m *SetMessageReactionExtensionsResp) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
}
return ""
}
func (m *SetMessageReactionExtensionsResp) GetMsgFirstModifyTime() int64 {
if m != nil {
return m.MsgFirstModifyTime
}
return 0
}
func (m *SetMessageReactionExtensionsResp) GetIsReact() bool {
if m != nil {
return m.IsReact
}
return false
}
func (m *SetMessageReactionExtensionsResp) GetResult() []*KeyValueResp {
if m != nil {
return m.Result
}
return nil
}
type GetMessageListReactionExtensionsReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
OpUserID string `protobuf:"bytes,2,opt,name=opUserID" json:"opUserID,omitempty"`
SourceID string `protobuf:"bytes,3,opt,name=sourceID" json:"sourceID,omitempty"`
SessionType int32 `protobuf:"varint,4,opt,name=sessionType" json:"sessionType,omitempty"`
MessageReactionKeyList []*GetMessageListReactionExtensionsReq_MessageReactionKey `protobuf:"bytes,5,rep,name=messageReactionKeyList" json:"messageReactionKeyList,omitempty"`
2 years ago
TypeKeyList []string `protobuf:"bytes,6,rep,name=TypeKeyList" json:"TypeKeyList,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetMessageListReactionExtensionsReq) Reset() { *m = GetMessageListReactionExtensionsReq{} }
func (m *GetMessageListReactionExtensionsReq) String() string { return proto.CompactTextString(m) }
func (*GetMessageListReactionExtensionsReq) ProtoMessage() {}
func (*GetMessageListReactionExtensionsReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{25}
}
func (m *GetMessageListReactionExtensionsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMessageListReactionExtensionsReq.Unmarshal(m, b)
}
func (m *GetMessageListReactionExtensionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetMessageListReactionExtensionsReq.Marshal(b, m, deterministic)
}
func (dst *GetMessageListReactionExtensionsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetMessageListReactionExtensionsReq.Merge(dst, src)
}
func (m *GetMessageListReactionExtensionsReq) XXX_Size() int {
return xxx_messageInfo_GetMessageListReactionExtensionsReq.Size(m)
}
func (m *GetMessageListReactionExtensionsReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetMessageListReactionExtensionsReq.DiscardUnknown(m)
}
var xxx_messageInfo_GetMessageListReactionExtensionsReq proto.InternalMessageInfo
func (m *GetMessageListReactionExtensionsReq) GetOperationID() string {
if m != nil {
return m.OperationID
}
return ""
}
func (m *GetMessageListReactionExtensionsReq) GetOpUserID() string {
if m != nil {
return m.OpUserID
}
return ""
}
func (m *GetMessageListReactionExtensionsReq) GetSourceID() string {
if m != nil {
return m.SourceID
}
return ""
}
func (m *GetMessageListReactionExtensionsReq) GetSessionType() int32 {
if m != nil {
return m.SessionType
}
return 0
}
func (m *GetMessageListReactionExtensionsReq) GetMessageReactionKeyList() []*GetMessageListReactionExtensionsReq_MessageReactionKey {
if m != nil {
return m.MessageReactionKeyList
}
return nil
}
2 years ago
func (m *GetMessageListReactionExtensionsReq) GetTypeKeyList() []string {
if m != nil {
return m.TypeKeyList
}
return nil
}
type GetMessageListReactionExtensionsReq_MessageReactionKey struct {
ClientMsgID string `protobuf:"bytes,1,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
MsgFirstModifyTime int64 `protobuf:"varint,2,opt,name=msgFirstModifyTime" json:"msgFirstModifyTime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) Reset() {
*m = GetMessageListReactionExtensionsReq_MessageReactionKey{}
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) String() string {
return proto.CompactTextString(m)
}
func (*GetMessageListReactionExtensionsReq_MessageReactionKey) ProtoMessage() {}
func (*GetMessageListReactionExtensionsReq_MessageReactionKey) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{25, 0}
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMessageListReactionExtensionsReq_MessageReactionKey.Unmarshal(m, b)
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetMessageListReactionExtensionsReq_MessageReactionKey.Marshal(b, m, deterministic)
}
func (dst *GetMessageListReactionExtensionsReq_MessageReactionKey) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetMessageListReactionExtensionsReq_MessageReactionKey.Merge(dst, src)
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) XXX_Size() int {
return xxx_messageInfo_GetMessageListReactionExtensionsReq_MessageReactionKey.Size(m)
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) XXX_DiscardUnknown() {
xxx_messageInfo_GetMessageListReactionExtensionsReq_MessageReactionKey.DiscardUnknown(m)
}
var xxx_messageInfo_GetMessageListReactionExtensionsReq_MessageReactionKey proto.InternalMessageInfo
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
}
return ""
}
func (m *GetMessageListReactionExtensionsReq_MessageReactionKey) GetMsgFirstModifyTime() int64 {
if m != nil {
return m.MsgFirstModifyTime
}
return 0
}
type GetMessageListReactionExtensionsResp struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
SingleMessageResult []*SingleMessageExtensionResult `protobuf:"bytes,3,rep,name=singleMessageResult" json:"singleMessageResult,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetMessageListReactionExtensionsResp) Reset() { *m = GetMessageListReactionExtensionsResp{} }
func (m *GetMessageListReactionExtensionsResp) String() string { return proto.CompactTextString(m) }
func (*GetMessageListReactionExtensionsResp) ProtoMessage() {}
func (*GetMessageListReactionExtensionsResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{26}
}
func (m *GetMessageListReactionExtensionsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMessageListReactionExtensionsResp.Unmarshal(m, b)
}
func (m *GetMessageListReactionExtensionsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetMessageListReactionExtensionsResp.Marshal(b, m, deterministic)
}
func (dst *GetMessageListReactionExtensionsResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetMessageListReactionExtensionsResp.Merge(dst, src)
}
func (m *GetMessageListReactionExtensionsResp) XXX_Size() int {
return xxx_messageInfo_GetMessageListReactionExtensionsResp.Size(m)
}
func (m *GetMessageListReactionExtensionsResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetMessageListReactionExtensionsResp.DiscardUnknown(m)
}
var xxx_messageInfo_GetMessageListReactionExtensionsResp proto.InternalMessageInfo
func (m *GetMessageListReactionExtensionsResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
}
func (m *GetMessageListReactionExtensionsResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
}
return ""
}
func (m *GetMessageListReactionExtensionsResp) GetSingleMessageResult() []*SingleMessageExtensionResult {
if m != nil {
return m.SingleMessageResult
}
return nil
}
type SingleMessageExtensionResult struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
ReactionExtensionList map[string]*sdkws.KeyValue `protobuf:"bytes,3,rep,name=reactionExtensionList" json:"reactionExtensionList,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
ClientMsgID string `protobuf:"bytes,4,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SingleMessageExtensionResult) Reset() { *m = SingleMessageExtensionResult{} }
func (m *SingleMessageExtensionResult) String() string { return proto.CompactTextString(m) }
func (*SingleMessageExtensionResult) ProtoMessage() {}
func (*SingleMessageExtensionResult) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{27}
}
func (m *SingleMessageExtensionResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SingleMessageExtensionResult.Unmarshal(m, b)
}
func (m *SingleMessageExtensionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SingleMessageExtensionResult.Marshal(b, m, deterministic)
}
func (dst *SingleMessageExtensionResult) XXX_Merge(src proto.Message) {
xxx_messageInfo_SingleMessageExtensionResult.Merge(dst, src)
}
func (m *SingleMessageExtensionResult) XXX_Size() int {
return xxx_messageInfo_SingleMessageExtensionResult.Size(m)
}
func (m *SingleMessageExtensionResult) XXX_DiscardUnknown() {
xxx_messageInfo_SingleMessageExtensionResult.DiscardUnknown(m)
}
var xxx_messageInfo_SingleMessageExtensionResult proto.InternalMessageInfo
func (m *SingleMessageExtensionResult) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
}
func (m *SingleMessageExtensionResult) GetErrMsg() string {
if m != nil {
return m.ErrMsg
}
return ""
}
func (m *SingleMessageExtensionResult) GetReactionExtensionList() map[string]*sdkws.KeyValue {
if m != nil {
return m.ReactionExtensionList
}
return nil
}
func (m *SingleMessageExtensionResult) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
}
return ""
}
2 years ago
type ModifyMessageReactionExtensionsResp struct {
2 years ago
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
SuccessList []*ExtendMsgResp `protobuf:"bytes,3,rep,name=successList" json:"successList,omitempty"`
FailedList []*ExtendMsgResp `protobuf:"bytes,4,rep,name=failedList" json:"failedList,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *ModifyMessageReactionExtensionsResp) Reset() { *m = ModifyMessageReactionExtensionsResp{} }
func (m *ModifyMessageReactionExtensionsResp) String() string { return proto.CompactTextString(m) }
func (*ModifyMessageReactionExtensionsResp) ProtoMessage() {}
func (*ModifyMessageReactionExtensionsResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{28}
2 years ago
}
func (m *ModifyMessageReactionExtensionsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ModifyMessageReactionExtensionsResp.Unmarshal(m, b)
}
func (m *ModifyMessageReactionExtensionsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ModifyMessageReactionExtensionsResp.Marshal(b, m, deterministic)
}
func (dst *ModifyMessageReactionExtensionsResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_ModifyMessageReactionExtensionsResp.Merge(dst, src)
}
func (m *ModifyMessageReactionExtensionsResp) XXX_Size() int {
return xxx_messageInfo_ModifyMessageReactionExtensionsResp.Size(m)
}
func (m *ModifyMessageReactionExtensionsResp) XXX_DiscardUnknown() {
xxx_messageInfo_ModifyMessageReactionExtensionsResp.DiscardUnknown(m)
}
var xxx_messageInfo_ModifyMessageReactionExtensionsResp proto.InternalMessageInfo
func (m *ModifyMessageReactionExtensionsResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
}
func (m *ModifyMessageReactionExtensionsResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
}
return ""
}
2 years ago
func (m *ModifyMessageReactionExtensionsResp) GetSuccessList() []*ExtendMsgResp {
2 years ago
if m != nil {
return m.SuccessList
}
return nil
}
2 years ago
func (m *ModifyMessageReactionExtensionsResp) GetFailedList() []*ExtendMsgResp {
2 years ago
if m != nil {
return m.FailedList
}
return nil
}
type DeleteMessageListReactionExtensionsReq struct {
OperationID string `protobuf:"bytes,1,opt,name=operationID" json:"operationID,omitempty"`
OpUserID string `protobuf:"bytes,2,opt,name=opUserID" json:"opUserID,omitempty"`
SourceID string `protobuf:"bytes,3,opt,name=sourceID" json:"sourceID,omitempty"`
SessionType int32 `protobuf:"varint,4,opt,name=sessionType" json:"sessionType,omitempty"`
ClientMsgID string `protobuf:"bytes,5,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
IsExternalExtensions bool `protobuf:"varint,6,opt,name=isExternalExtensions" json:"isExternalExtensions,omitempty"`
MsgFirstModifyTime int64 `protobuf:"varint,7,opt,name=msgFirstModifyTime" json:"msgFirstModifyTime,omitempty"`
ReactionExtensionList []*sdkws.KeyValue `protobuf:"bytes,8,rep,name=reactionExtensionList" json:"reactionExtensionList,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) Reset() {
*m = DeleteMessageListReactionExtensionsReq{}
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) String() string { return proto.CompactTextString(m) }
func (*DeleteMessageListReactionExtensionsReq) ProtoMessage() {}
func (*DeleteMessageListReactionExtensionsReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{29}
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeleteMessageListReactionExtensionsReq.Unmarshal(m, b)
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeleteMessageListReactionExtensionsReq.Marshal(b, m, deterministic)
2 years ago
}
func (dst *DeleteMessageListReactionExtensionsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeleteMessageListReactionExtensionsReq.Merge(dst, src)
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) XXX_Size() int {
return xxx_messageInfo_DeleteMessageListReactionExtensionsReq.Size(m)
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) XXX_DiscardUnknown() {
xxx_messageInfo_DeleteMessageListReactionExtensionsReq.DiscardUnknown(m)
2 years ago
}
var xxx_messageInfo_DeleteMessageListReactionExtensionsReq proto.InternalMessageInfo
2 years ago
func (m *DeleteMessageListReactionExtensionsReq) GetOperationID() string {
2 years ago
if m != nil {
return m.OperationID
}
return ""
}
func (m *DeleteMessageListReactionExtensionsReq) GetOpUserID() string {
2 years ago
if m != nil {
return m.OpUserID
}
return ""
}
func (m *DeleteMessageListReactionExtensionsReq) GetSourceID() string {
2 years ago
if m != nil {
return m.SourceID
}
return ""
}
func (m *DeleteMessageListReactionExtensionsReq) GetSessionType() int32 {
2 years ago
if m != nil {
return m.SessionType
}
2 years ago
return 0
2 years ago
}
func (m *DeleteMessageListReactionExtensionsReq) GetClientMsgID() string {
2 years ago
if m != nil {
return m.ClientMsgID
}
return ""
}
2 years ago
func (m *DeleteMessageListReactionExtensionsReq) GetIsExternalExtensions() bool {
if m != nil {
return m.IsExternalExtensions
}
return false
}
func (m *DeleteMessageListReactionExtensionsReq) GetMsgFirstModifyTime() int64 {
2 years ago
if m != nil {
return m.MsgFirstModifyTime
}
return 0
}
func (m *DeleteMessageListReactionExtensionsReq) GetReactionExtensionList() []*sdkws.KeyValue {
2 years ago
if m != nil {
return m.ReactionExtensionList
}
return nil
}
type DeleteMessageListReactionExtensionsResp struct {
ErrCode int32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=errMsg" json:"errMsg,omitempty"`
Result []*KeyValueResp `protobuf:"bytes,6,rep,name=result" json:"result,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *DeleteMessageListReactionExtensionsResp) Reset() {
*m = DeleteMessageListReactionExtensionsResp{}
2 years ago
}
func (m *DeleteMessageListReactionExtensionsResp) String() string { return proto.CompactTextString(m) }
func (*DeleteMessageListReactionExtensionsResp) ProtoMessage() {}
func (*DeleteMessageListReactionExtensionsResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{30}
2 years ago
}
func (m *DeleteMessageListReactionExtensionsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeleteMessageListReactionExtensionsResp.Unmarshal(m, b)
2 years ago
}
func (m *DeleteMessageListReactionExtensionsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeleteMessageListReactionExtensionsResp.Marshal(b, m, deterministic)
2 years ago
}
func (dst *DeleteMessageListReactionExtensionsResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeleteMessageListReactionExtensionsResp.Merge(dst, src)
2 years ago
}
func (m *DeleteMessageListReactionExtensionsResp) XXX_Size() int {
return xxx_messageInfo_DeleteMessageListReactionExtensionsResp.Size(m)
2 years ago
}
func (m *DeleteMessageListReactionExtensionsResp) XXX_DiscardUnknown() {
xxx_messageInfo_DeleteMessageListReactionExtensionsResp.DiscardUnknown(m)
2 years ago
}
var xxx_messageInfo_DeleteMessageListReactionExtensionsResp proto.InternalMessageInfo
2 years ago
func (m *DeleteMessageListReactionExtensionsResp) GetErrCode() int32 {
2 years ago
if m != nil {
return m.ErrCode
}
return 0
}
func (m *DeleteMessageListReactionExtensionsResp) GetErrMsg() string {
2 years ago
if m != nil {
return m.ErrMsg
}
return ""
}
func (m *DeleteMessageListReactionExtensionsResp) GetResult() []*KeyValueResp {
2 years ago
if m != nil {
return m.Result
2 years ago
}
return nil
}
2 years ago
type ExtendMsgResp struct {
2 years ago
ExtendMsg *ExtendMsg `protobuf:"bytes,1,opt,name=extendMsg" json:"extendMsg,omitempty"`
ErrCode int32 `protobuf:"varint,2,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,3,opt,name=errMsg" json:"errMsg,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *ExtendMsgResp) Reset() { *m = ExtendMsgResp{} }
func (m *ExtendMsgResp) String() string { return proto.CompactTextString(m) }
func (*ExtendMsgResp) ProtoMessage() {}
func (*ExtendMsgResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{31}
2 years ago
}
func (m *ExtendMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ExtendMsgResp.Unmarshal(m, b)
}
func (m *ExtendMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ExtendMsgResp.Marshal(b, m, deterministic)
}
func (dst *ExtendMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_ExtendMsgResp.Merge(dst, src)
}
func (m *ExtendMsgResp) XXX_Size() int {
return xxx_messageInfo_ExtendMsgResp.Size(m)
}
func (m *ExtendMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_ExtendMsgResp.DiscardUnknown(m)
}
var xxx_messageInfo_ExtendMsgResp proto.InternalMessageInfo
2 years ago
func (m *ExtendMsgResp) GetExtendMsg() *ExtendMsg {
2 years ago
if m != nil {
return m.ExtendMsg
}
return nil
}
func (m *ExtendMsgResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
}
func (m *ExtendMsgResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
}
return ""
}
2 years ago
type ExtendMsg struct {
ReactionExtensionList map[string]*KeyValueResp `protobuf:"bytes,1,rep,name=reactionExtensionList" json:"reactionExtensionList,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
ClientMsgID string `protobuf:"bytes,2,opt,name=clientMsgID" json:"clientMsgID,omitempty"`
MsgFirstModifyTime int64 `protobuf:"varint,3,opt,name=msgFirstModifyTime" json:"msgFirstModifyTime,omitempty"`
AttachedInfo string `protobuf:"bytes,4,opt,name=attachedInfo" json:"attachedInfo,omitempty"`
Ex string `protobuf:"bytes,5,opt,name=ex" json:"ex,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ExtendMsg) Reset() { *m = ExtendMsg{} }
func (m *ExtendMsg) String() string { return proto.CompactTextString(m) }
func (*ExtendMsg) ProtoMessage() {}
func (*ExtendMsg) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{32}
2 years ago
}
func (m *ExtendMsg) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ExtendMsg.Unmarshal(m, b)
}
func (m *ExtendMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ExtendMsg.Marshal(b, m, deterministic)
}
func (dst *ExtendMsg) XXX_Merge(src proto.Message) {
xxx_messageInfo_ExtendMsg.Merge(dst, src)
}
func (m *ExtendMsg) XXX_Size() int {
return xxx_messageInfo_ExtendMsg.Size(m)
}
func (m *ExtendMsg) XXX_DiscardUnknown() {
xxx_messageInfo_ExtendMsg.DiscardUnknown(m)
}
var xxx_messageInfo_ExtendMsg proto.InternalMessageInfo
func (m *ExtendMsg) GetReactionExtensionList() map[string]*KeyValueResp {
if m != nil {
return m.ReactionExtensionList
}
return nil
}
func (m *ExtendMsg) GetClientMsgID() string {
if m != nil {
return m.ClientMsgID
}
return ""
}
func (m *ExtendMsg) GetMsgFirstModifyTime() int64 {
if m != nil {
return m.MsgFirstModifyTime
}
return 0
}
func (m *ExtendMsg) GetAttachedInfo() string {
if m != nil {
return m.AttachedInfo
}
return ""
}
func (m *ExtendMsg) GetEx() string {
if m != nil {
return m.Ex
}
return ""
}
type KeyValueResp struct {
KeyValue *sdkws.KeyValue `protobuf:"bytes,1,opt,name=keyValue" json:"keyValue,omitempty"`
ErrCode int32 `protobuf:"varint,2,opt,name=errCode" json:"errCode,omitempty"`
ErrMsg string `protobuf:"bytes,3,opt,name=errMsg" json:"errMsg,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
2 years ago
}
func (m *KeyValueResp) Reset() { *m = KeyValueResp{} }
func (m *KeyValueResp) String() string { return proto.CompactTextString(m) }
func (*KeyValueResp) ProtoMessage() {}
func (*KeyValueResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{33}
2 years ago
}
func (m *KeyValueResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_KeyValueResp.Unmarshal(m, b)
}
func (m *KeyValueResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_KeyValueResp.Marshal(b, m, deterministic)
}
func (dst *KeyValueResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_KeyValueResp.Merge(dst, src)
}
func (m *KeyValueResp) XXX_Size() int {
return xxx_messageInfo_KeyValueResp.Size(m)
}
func (m *KeyValueResp) XXX_DiscardUnknown() {
xxx_messageInfo_KeyValueResp.DiscardUnknown(m)
}
var xxx_messageInfo_KeyValueResp proto.InternalMessageInfo
func (m *KeyValueResp) GetKeyValue() *sdkws.KeyValue {
2 years ago
if m != nil {
return m.KeyValue
}
return nil
}
func (m *KeyValueResp) GetErrCode() int32 {
if m != nil {
return m.ErrCode
}
return 0
}
func (m *KeyValueResp) GetErrMsg() string {
if m != nil {
return m.ErrMsg
}
return ""
}
2 years ago
type MsgDataToModifyByMQ struct {
AggregationID string `protobuf:"bytes,1,opt,name=aggregationID" json:"aggregationID,omitempty"`
MessageList []*MsgDataToMQ `protobuf:"bytes,2,rep,name=messageList" json:"messageList,omitempty"`
TriggerID string `protobuf:"bytes,3,opt,name=triggerID" json:"triggerID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MsgDataToModifyByMQ) Reset() { *m = MsgDataToModifyByMQ{} }
func (m *MsgDataToModifyByMQ) String() string { return proto.CompactTextString(m) }
func (*MsgDataToModifyByMQ) ProtoMessage() {}
func (*MsgDataToModifyByMQ) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{34}
2 years ago
}
func (m *MsgDataToModifyByMQ) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgDataToModifyByMQ.Unmarshal(m, b)
}
func (m *MsgDataToModifyByMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgDataToModifyByMQ.Marshal(b, m, deterministic)
}
func (dst *MsgDataToModifyByMQ) XXX_Merge(src proto.Message) {
xxx_messageInfo_MsgDataToModifyByMQ.Merge(dst, src)
}
func (m *MsgDataToModifyByMQ) XXX_Size() int {
return xxx_messageInfo_MsgDataToModifyByMQ.Size(m)
}
func (m *MsgDataToModifyByMQ) XXX_DiscardUnknown() {
xxx_messageInfo_MsgDataToModifyByMQ.DiscardUnknown(m)
}
var xxx_messageInfo_MsgDataToModifyByMQ proto.InternalMessageInfo
func (m *MsgDataToModifyByMQ) GetAggregationID() string {
if m != nil {
return m.AggregationID
}
return ""
}
func (m *MsgDataToModifyByMQ) GetMessageList() []*MsgDataToMQ {
if m != nil {
return m.MessageList
}
return nil
}
func (m *MsgDataToModifyByMQ) GetTriggerID() string {
if m != nil {
return m.TriggerID
}
return ""
}
2 years ago
type DelMsgListReq struct {
UserID string `protobuf:"bytes,2,opt,name=userID" json:"userID,omitempty"`
SeqList []uint32 `protobuf:"varint,3,rep,packed,name=seqList" json:"seqList,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DelMsgListReq) Reset() { *m = DelMsgListReq{} }
func (m *DelMsgListReq) String() string { return proto.CompactTextString(m) }
func (*DelMsgListReq) ProtoMessage() {}
func (*DelMsgListReq) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{35}
2 years ago
}
func (m *DelMsgListReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelMsgListReq.Unmarshal(m, b)
}
func (m *DelMsgListReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DelMsgListReq.Marshal(b, m, deterministic)
}
func (dst *DelMsgListReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_DelMsgListReq.Merge(dst, src)
}
func (m *DelMsgListReq) XXX_Size() int {
return xxx_messageInfo_DelMsgListReq.Size(m)
}
func (m *DelMsgListReq) XXX_DiscardUnknown() {
xxx_messageInfo_DelMsgListReq.DiscardUnknown(m)
}
var xxx_messageInfo_DelMsgListReq proto.InternalMessageInfo
func (m *DelMsgListReq) GetUserID() string {
if m != nil {
return m.UserID
}
return ""
}
func (m *DelMsgListReq) GetSeqList() []uint32 {
if m != nil {
return m.SeqList
}
return nil
}
type DelMsgListResp struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DelMsgListResp) Reset() { *m = DelMsgListResp{} }
func (m *DelMsgListResp) String() string { return proto.CompactTextString(m) }
func (*DelMsgListResp) ProtoMessage() {}
func (*DelMsgListResp) Descriptor() ([]byte, []int) {
2 years ago
return fileDescriptor_msg_6d33b8473e6e0931, []int{36}
2 years ago
}
func (m *DelMsgListResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelMsgListResp.Unmarshal(m, b)
}
func (m *DelMsgListResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DelMsgListResp.Marshal(b, m, deterministic)
}
func (dst *DelMsgListResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_DelMsgListResp.Merge(dst, src)
}
func (m *DelMsgListResp) XXX_Size() int {
return xxx_messageInfo_DelMsgListResp.Size(m)
}
func (m *DelMsgListResp) XXX_DiscardUnknown() {
xxx_messageInfo_DelMsgListResp.DiscardUnknown(m)
}
var xxx_messageInfo_DelMsgListResp proto.InternalMessageInfo
2 years ago
func init() {
proto.RegisterType((*MsgDataToMQ)(nil), "msg.MsgDataToMQ")
proto.RegisterType((*MsgDataToDB)(nil), "msg.MsgDataToDB")
proto.RegisterType((*PushMsgDataToMQ)(nil), "msg.PushMsgDataToMQ")
proto.RegisterType((*MsgDataToMongoByMQ)(nil), "msg.MsgDataToMongoByMQ")
proto.RegisterType((*GetMaxAndMinSeqReq)(nil), "msg.GetMaxAndMinSeqReq")
proto.RegisterType((*GetMaxAndMinSeqResp)(nil), "msg.GetMaxAndMinSeqResp")
proto.RegisterType((*SendMsgReq)(nil), "msg.SendMsgReq")
proto.RegisterType((*SendMsgResp)(nil), "msg.SendMsgResp")
proto.RegisterType((*ClearMsgReq)(nil), "msg.ClearMsgReq")
proto.RegisterType((*ClearMsgResp)(nil), "msg.ClearMsgResp")
proto.RegisterType((*SetMsgMinSeqReq)(nil), "msg.SetMsgMinSeqReq")
proto.RegisterType((*SetMsgMinSeqResp)(nil), "msg.SetMsgMinSeqResp")
proto.RegisterType((*SetSendMsgStatusReq)(nil), "msg.SetSendMsgStatusReq")
proto.RegisterType((*SetSendMsgStatusResp)(nil), "msg.SetSendMsgStatusResp")
proto.RegisterType((*GetSendMsgStatusReq)(nil), "msg.GetSendMsgStatusReq")
proto.RegisterType((*GetSendMsgStatusResp)(nil), "msg.GetSendMsgStatusResp")
proto.RegisterType((*DelSuperGroupMsgReq)(nil), "msg.DelSuperGroupMsgReq")
proto.RegisterType((*DelSuperGroupMsgResp)(nil), "msg.DelSuperGroupMsgResp")
proto.RegisterType((*GetSuperGroupMsgReq)(nil), "msg.GetSuperGroupMsgReq")
proto.RegisterType((*GetSuperGroupMsgResp)(nil), "msg.GetSuperGroupMsgResp")
proto.RegisterType((*GetWriteDiffMsgReq)(nil), "msg.GetWriteDiffMsgReq")
proto.RegisterType((*GetWriteDiffMsgResp)(nil), "msg.GetWriteDiffMsgResp")
2 years ago
proto.RegisterType((*ModifyMessageReactionExtensionsReq)(nil), "msg.ModifyMessageReactionExtensionsReq")
proto.RegisterMapType((map[string]*sdkws.KeyValue)(nil), "msg.ModifyMessageReactionExtensionsReq.ReactionExtensionListEntry")
proto.RegisterType((*SetMessageReactionExtensionsReq)(nil), "msg.SetMessageReactionExtensionsReq")
proto.RegisterMapType((map[string]*sdkws.KeyValue)(nil), "msg.SetMessageReactionExtensionsReq.ReactionExtensionListEntry")
proto.RegisterType((*SetMessageReactionExtensionsResp)(nil), "msg.SetMessageReactionExtensionsResp")
proto.RegisterType((*GetMessageListReactionExtensionsReq)(nil), "msg.GetMessageListReactionExtensionsReq")
proto.RegisterType((*GetMessageListReactionExtensionsReq_MessageReactionKey)(nil), "msg.GetMessageListReactionExtensionsReq.MessageReactionKey")
proto.RegisterType((*GetMessageListReactionExtensionsResp)(nil), "msg.GetMessageListReactionExtensionsResp")
proto.RegisterType((*SingleMessageExtensionResult)(nil), "msg.SingleMessageExtensionResult")
proto.RegisterMapType((map[string]*sdkws.KeyValue)(nil), "msg.SingleMessageExtensionResult.ReactionExtensionListEntry")
2 years ago
proto.RegisterType((*ModifyMessageReactionExtensionsResp)(nil), "msg.ModifyMessageReactionExtensionsResp")
proto.RegisterType((*DeleteMessageListReactionExtensionsReq)(nil), "msg.DeleteMessageListReactionExtensionsReq")
proto.RegisterType((*DeleteMessageListReactionExtensionsResp)(nil), "msg.DeleteMessageListReactionExtensionsResp")
2 years ago
proto.RegisterType((*ExtendMsgResp)(nil), "msg.ExtendMsgResp")
2 years ago
proto.RegisterType((*ExtendMsg)(nil), "msg.ExtendMsg")
proto.RegisterMapType((map[string]*KeyValueResp)(nil), "msg.ExtendMsg.ReactionExtensionListEntry")
proto.RegisterType((*KeyValueResp)(nil), "msg.KeyValueResp")
2 years ago
proto.RegisterType((*MsgDataToModifyByMQ)(nil), "msg.MsgDataToModifyByMQ")
2 years ago
proto.RegisterType((*DelMsgListReq)(nil), "msg.DelMsgListReq")
proto.RegisterType((*DelMsgListResp)(nil), "msg.DelMsgListResp")
2 years ago
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
2 years ago
var _ grpc.ClientConn
2 years ago
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
2 years ago
const _ = grpc.SupportPackageIsVersion4
// Client API for Msg service
2 years ago
type MsgClient interface {
// 获取最小最大seq包括用户的以及指定群组的
GetMaxAndMinSeq(ctx context.Context, in *sdkws.GetMaxAndMinSeqReq, opts ...grpc.CallOption) (*sdkws.GetMaxAndMinSeqResp, error)
// 拉取历史消息(包括用户的,以及指定群组的)
PullMessageBySeqList(ctx context.Context, in *sdkws.PullMessageBySeqListReq, opts ...grpc.CallOption) (*sdkws.PullMessageBySeqListResp, error)
// 发送消息
2 years ago
SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error)
// 删除某人消息
2 years ago
DelMsgList(ctx context.Context, in *DelMsgListReq, opts ...grpc.CallOption) (*DelMsgListResp, error)
// 删除某个用户某个大群消息
2 years ago
DelSuperGroupMsg(ctx context.Context, in *DelSuperGroupMsgReq, opts ...grpc.CallOption) (*DelSuperGroupMsgResp, error)
// 清空某人所有消息
2 years ago
ClearMsg(ctx context.Context, in *ClearMsgReq, opts ...grpc.CallOption) (*ClearMsgResp, error)
// 设置消息是否发送成功-针对api发送的消息
2 years ago
SetSendMsgStatus(ctx context.Context, in *SetSendMsgStatusReq, opts ...grpc.CallOption) (*SetSendMsgStatusResp, error)
// 获取消息发送状态
2 years ago
GetSendMsgStatus(ctx context.Context, in *GetSendMsgStatusReq, opts ...grpc.CallOption) (*GetSendMsgStatusResp, error)
// 修改消息
SetMessageReactionExtensions(ctx context.Context, in *SetMessageReactionExtensionsReq, opts ...grpc.CallOption) (*SetMessageReactionExtensionsResp, error)
GetMessageListReactionExtensions(ctx context.Context, in *GetMessageListReactionExtensionsReq, opts ...grpc.CallOption) (*GetMessageListReactionExtensionsResp, error)
2 years ago
AddMessageReactionExtensions(ctx context.Context, in *ModifyMessageReactionExtensionsReq, opts ...grpc.CallOption) (*ModifyMessageReactionExtensionsResp, error)
DeleteMessageReactionExtensions(ctx context.Context, in *DeleteMessageListReactionExtensionsReq, opts ...grpc.CallOption) (*DeleteMessageListReactionExtensionsResp, error)
2 years ago
}
type msgClient struct {
2 years ago
cc *grpc.ClientConn
2 years ago
}
2 years ago
func NewMsgClient(cc *grpc.ClientConn) MsgClient {
2 years ago
return &msgClient{cc}
}
func (c *msgClient) GetMaxAndMinSeq(ctx context.Context, in *sdkws.GetMaxAndMinSeqReq, opts ...grpc.CallOption) (*sdkws.GetMaxAndMinSeqResp, error) {
out := new(sdkws.GetMaxAndMinSeqResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/GetMaxAndMinSeq", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) PullMessageBySeqList(ctx context.Context, in *sdkws.PullMessageBySeqListReq, opts ...grpc.CallOption) (*sdkws.PullMessageBySeqListResp, error) {
out := new(sdkws.PullMessageBySeqListResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/PullMessageBySeqList", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error) {
out := new(SendMsgResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/SendMsg", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgClient) DelMsgList(ctx context.Context, in *DelMsgListReq, opts ...grpc.CallOption) (*DelMsgListResp, error) {
out := new(DelMsgListResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/DelMsgList", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) DelSuperGroupMsg(ctx context.Context, in *DelSuperGroupMsgReq, opts ...grpc.CallOption) (*DelSuperGroupMsgResp, error) {
out := new(DelSuperGroupMsgResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/DelSuperGroupMsg", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) ClearMsg(ctx context.Context, in *ClearMsgReq, opts ...grpc.CallOption) (*ClearMsgResp, error) {
out := new(ClearMsgResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/ClearMsg", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
func (c *msgClient) SetSendMsgStatus(ctx context.Context, in *SetSendMsgStatusReq, opts ...grpc.CallOption) (*SetSendMsgStatusResp, error) {
out := new(SetSendMsgStatusResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/SetSendMsgStatus", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) GetSendMsgStatus(ctx context.Context, in *GetSendMsgStatusReq, opts ...grpc.CallOption) (*GetSendMsgStatusResp, error) {
out := new(GetSendMsgStatusResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/GetSendMsgStatus", in, out, c.cc, opts...)
2 years ago
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) SetMessageReactionExtensions(ctx context.Context, in *SetMessageReactionExtensionsReq, opts ...grpc.CallOption) (*SetMessageReactionExtensionsResp, error) {
out := new(SetMessageReactionExtensionsResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/SetMessageReactionExtensions", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) GetMessageListReactionExtensions(ctx context.Context, in *GetMessageListReactionExtensionsReq, opts ...grpc.CallOption) (*GetMessageListReactionExtensionsResp, error) {
out := new(GetMessageListReactionExtensionsResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/GetMessageListReactionExtensions", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) AddMessageReactionExtensions(ctx context.Context, in *ModifyMessageReactionExtensionsReq, opts ...grpc.CallOption) (*ModifyMessageReactionExtensionsResp, error) {
out := new(ModifyMessageReactionExtensionsResp)
err := grpc.Invoke(ctx, "/msg.msg/AddMessageReactionExtensions", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *msgClient) DeleteMessageReactionExtensions(ctx context.Context, in *DeleteMessageListReactionExtensionsReq, opts ...grpc.CallOption) (*DeleteMessageListReactionExtensionsResp, error) {
out := new(DeleteMessageListReactionExtensionsResp)
2 years ago
err := grpc.Invoke(ctx, "/msg.msg/DeleteMessageReactionExtensions", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
2 years ago
// Server API for Msg service
2 years ago
type MsgServer interface {
// 获取最小最大seq包括用户的以及指定群组的
GetMaxAndMinSeq(context.Context, *sdkws.GetMaxAndMinSeqReq) (*sdkws.GetMaxAndMinSeqResp, error)
// 拉取历史消息(包括用户的,以及指定群组的)
PullMessageBySeqList(context.Context, *sdkws.PullMessageBySeqListReq) (*sdkws.PullMessageBySeqListResp, error)
// 发送消息
2 years ago
SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
// 删除某人消息
2 years ago
DelMsgList(context.Context, *DelMsgListReq) (*DelMsgListResp, error)
// 删除某个用户某个大群消息
2 years ago
DelSuperGroupMsg(context.Context, *DelSuperGroupMsgReq) (*DelSuperGroupMsgResp, error)
// 清空某人所有消息
2 years ago
ClearMsg(context.Context, *ClearMsgReq) (*ClearMsgResp, error)
// 设置消息是否发送成功-针对api发送的消息
2 years ago
SetSendMsgStatus(context.Context, *SetSendMsgStatusReq) (*SetSendMsgStatusResp, error)
// 获取消息发送状态
2 years ago
GetSendMsgStatus(context.Context, *GetSendMsgStatusReq) (*GetSendMsgStatusResp, error)
// 修改消息
SetMessageReactionExtensions(context.Context, *SetMessageReactionExtensionsReq) (*SetMessageReactionExtensionsResp, error)
GetMessageListReactionExtensions(context.Context, *GetMessageListReactionExtensionsReq) (*GetMessageListReactionExtensionsResp, error)
2 years ago
AddMessageReactionExtensions(context.Context, *ModifyMessageReactionExtensionsReq) (*ModifyMessageReactionExtensionsResp, error)
DeleteMessageReactionExtensions(context.Context, *DeleteMessageListReactionExtensionsReq) (*DeleteMessageListReactionExtensionsResp, error)
2 years ago
}
2 years ago
func RegisterMsgServer(s *grpc.Server, srv MsgServer) {
s.RegisterService(&_Msg_serviceDesc, srv)
}
func _Msg_GetMaxAndMinSeq_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(sdkws.GetMaxAndMinSeqReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).GetMaxAndMinSeq(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/GetMaxAndMinSeq",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).GetMaxAndMinSeq(ctx, req.(*sdkws.GetMaxAndMinSeqReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
func _Msg_PullMessageBySeqList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(sdkws.PullMessageBySeqListReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).PullMessageBySeqList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/PullMessageBySeqList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).PullMessageBySeqList(ctx, req.(*sdkws.PullMessageBySeqListReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
func _Msg_SendMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SendMsgReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).SendMsg(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/SendMsg",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).SendMsg(ctx, req.(*SendMsgReq))
}
return interceptor(ctx, in, info, handler)
}
func _Msg_DelMsgList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2 years ago
in := new(DelMsgListReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).DelMsgList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/DelMsgList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgServer).DelMsgList(ctx, req.(*DelMsgListReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
func _Msg_DelSuperGroupMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DelSuperGroupMsgReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).DelSuperGroupMsg(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/DelSuperGroupMsg",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).DelSuperGroupMsg(ctx, req.(*DelSuperGroupMsgReq))
}
return interceptor(ctx, in, info, handler)
}
func _Msg_ClearMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ClearMsgReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).ClearMsg(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/ClearMsg",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).ClearMsg(ctx, req.(*ClearMsgReq))
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _Msg_SetSendMsgStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetSendMsgStatusReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
2 years ago
return srv.(MsgServer).SetSendMsgStatus(ctx, in)
2 years ago
}
info := &grpc.UnaryServerInfo{
Server: srv,
2 years ago
FullMethod: "/msg.msg/SetSendMsgStatus",
2 years ago
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2 years ago
return srv.(MsgServer).SetSendMsgStatus(ctx, req.(*SetSendMsgStatusReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
func _Msg_GetSendMsgStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetSendMsgStatusReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).GetSendMsgStatus(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/GetSendMsgStatus",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).GetSendMsgStatus(ctx, req.(*GetSendMsgStatusReq))
}
return interceptor(ctx, in, info, handler)
}
2 years ago
func _Msg_SetMessageReactionExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetMessageReactionExtensionsReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).SetMessageReactionExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/SetMessageReactionExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).SetMessageReactionExtensions(ctx, req.(*SetMessageReactionExtensionsReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
func _Msg_GetMessageListReactionExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetMessageListReactionExtensionsReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).GetMessageListReactionExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/GetMessageListReactionExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).GetMessageListReactionExtensions(ctx, req.(*GetMessageListReactionExtensionsReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
func _Msg_AddMessageReactionExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ModifyMessageReactionExtensionsReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).AddMessageReactionExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/AddMessageReactionExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).AddMessageReactionExtensions(ctx, req.(*ModifyMessageReactionExtensionsReq))
}
return interceptor(ctx, in, info, handler)
}
func _Msg_DeleteMessageReactionExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteMessageListReactionExtensionsReq)
2 years ago
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MsgServer).DeleteMessageReactionExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/msg.msg/DeleteMessageReactionExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MsgServer).DeleteMessageReactionExtensions(ctx, req.(*DeleteMessageListReactionExtensionsReq))
2 years ago
}
return interceptor(ctx, in, info, handler)
}
2 years ago
var _Msg_serviceDesc = grpc.ServiceDesc{
ServiceName: "msg.msg",
HandlerType: (*MsgServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetMaxAndMinSeq",
Handler: _Msg_GetMaxAndMinSeq_Handler,
},
{
MethodName: "PullMessageBySeqList",
Handler: _Msg_PullMessageBySeqList_Handler,
},
{
MethodName: "SendMsg",
Handler: _Msg_SendMsg_Handler,
},
{
MethodName: "DelMsgList",
Handler: _Msg_DelMsgList_Handler,
},
{
MethodName: "DelSuperGroupMsg",
Handler: _Msg_DelSuperGroupMsg_Handler,
},
{
MethodName: "ClearMsg",
Handler: _Msg_ClearMsg_Handler,
},
{
2 years ago
MethodName: "SetSendMsgStatus",
Handler: _Msg_SetSendMsgStatus_Handler,
2 years ago
},
{
MethodName: "GetSendMsgStatus",
Handler: _Msg_GetSendMsgStatus_Handler,
},
2 years ago
{
MethodName: "SetMessageReactionExtensions",
Handler: _Msg_SetMessageReactionExtensions_Handler,
},
{
MethodName: "GetMessageListReactionExtensions",
Handler: _Msg_GetMessageListReactionExtensions_Handler,
},
{
MethodName: "AddMessageReactionExtensions",
Handler: _Msg_AddMessageReactionExtensions_Handler,
},
{
MethodName: "DeleteMessageReactionExtensions",
Handler: _Msg_DeleteMessageReactionExtensions_Handler,
},
2 years ago
},
Streams: []grpc.StreamDesc{},
Metadata: "msg/msg.proto",
}
2 years ago
2 years ago
func init() { proto.RegisterFile("msg/msg.proto", fileDescriptor_msg_6d33b8473e6e0931) }
2 years ago
2 years ago
var fileDescriptor_msg_6d33b8473e6e0931 = []byte{
// 1604 bytes of a gzipped FileDescriptorProto
2 years ago
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x59, 0xcb, 0x6e, 0xdb, 0x46,
2 years ago
0x17, 0x06, 0x49, 0x4b, 0xb6, 0x8f, 0x7c, 0xcb, 0xd8, 0xbf, 0xa1, 0xf0, 0x37, 0x1a, 0x95, 0x49,
2 years ago
0x6a, 0x05, 0x89, 0x65, 0xc0, 0xbd, 0xa2, 0x29, 0xd0, 0xc6, 0x91, 0xab, 0x18, 0x29, 0x9b, 0x84,
2 years ago
0x72, 0x1b, 0xa4, 0x59, 0xa4, 0x8c, 0x35, 0x66, 0x08, 0x8b, 0x17, 0x73, 0xa8, 0xd8, 0x02, 0xba,
0xe9, 0xa2, 0xdd, 0xf5, 0x1d, 0xba, 0xea, 0xae, 0x0f, 0x91, 0x27, 0xe8, 0x83, 0x74, 0xd3, 0x3e,
0x41, 0x8b, 0x99, 0xa1, 0xe8, 0xe1, 0x4d, 0xa2, 0x15, 0x04, 0xc8, 0xa2, 0x3b, 0x9f, 0x99, 0x33,
0xe7, 0xf2, 0x9d, 0x6f, 0x8e, 0x86, 0xc7, 0xb0, 0xe8, 0x10, 0x6b, 0xdb, 0x21, 0x56, 0xcb, 0x0f,
0xbc, 0xd0, 0x43, 0x8a, 0x43, 0x2c, 0x75, 0xf3, 0x81, 0x8f, 0xdd, 0xad, 0x7d, 0x7d, 0xab, 0x8b,
0x83, 0x97, 0x38, 0xd8, 0xf6, 0x8f, 0xad, 0x6d, 0xb6, 0xbd, 0x4d, 0x7a, 0xc7, 0xa7, 0x64, 0xfb,
0x94, 0x70, 0x6d, 0x75, 0x6b, 0x92, 0x62, 0x60, 0xfa, 0x3e, 0x0e, 0x22, 0x75, 0xcd, 0x83, 0x9a,
0x4e, 0xac, 0xb6, 0x19, 0x9a, 0x07, 0x9e, 0xfe, 0x08, 0xad, 0x41, 0x25, 0xf4, 0x8e, 0xb1, 0x5b,
0x97, 0x1a, 0x52, 0x73, 0xde, 0xe0, 0x02, 0x6a, 0x40, 0xcd, 0xf3, 0x71, 0x60, 0x86, 0xb6, 0xe7,
0xee, 0xb7, 0xeb, 0x32, 0xdb, 0x13, 0x97, 0x50, 0x13, 0x66, 0x1d, 0x6e, 0xa6, 0xae, 0x34, 0xa4,
0x66, 0x6d, 0x67, 0xa9, 0xc5, 0xdc, 0xb5, 0x22, 0xe3, 0xc6, 0x68, 0x5b, 0x7b, 0x22, 0x38, 0x6c,
0xef, 0x8a, 0x07, 0xa5, 0xb1, 0x07, 0x27, 0x07, 0xa1, 0xfd, 0x28, 0xc1, 0xf2, 0xc3, 0x01, 0x79,
0x21, 0x26, 0xd4, 0x80, 0xda, 0x03, 0xe1, 0x14, 0x4f, 0x4b, 0x5c, 0x12, 0x23, 0x90, 0xc7, 0x47,
0xa0, 0xc1, 0x82, 0x3f, 0x20, 0x2f, 0x0e, 0xbc, 0x6f, 0x08, 0x0e, 0xf6, 0xdb, 0x2c, 0xd3, 0x79,
0x23, 0xb1, 0xa6, 0xfd, 0x26, 0x01, 0x3a, 0xf7, 0xef, 0xb9, 0x96, 0xb7, 0x3b, 0xd4, 0x1f, 0xa1,
0x3a, 0xcc, 0xf6, 0x4d, 0x12, 0x76, 0xf1, 0x09, 0x0b, 0x61, 0xc6, 0x18, 0x89, 0xe8, 0x1a, 0x2c,
0x9a, 0x96, 0x15, 0x60, 0x2b, 0x99, 0x58, 0x72, 0x11, 0xed, 0x40, 0xcd, 0xc1, 0x84, 0x98, 0x16,
0xfe, 0xca, 0x26, 0x61, 0x5d, 0x69, 0x28, 0xcd, 0xda, 0xce, 0x4a, 0x8b, 0x92, 0x44, 0xc8, 0xd6,
0x10, 0x95, 0xd0, 0x06, 0xcc, 0x87, 0x81, 0x6d, 0x59, 0x2c, 0xd6, 0x19, 0x66, 0xf5, 0x7c, 0x41,
0xfb, 0x1a, 0x50, 0x07, 0x87, 0xba, 0x79, 0x76, 0xc7, 0xed, 0xe9, 0xb6, 0xdb, 0xc5, 0x27, 0x06,
0x3e, 0x41, 0xeb, 0x50, 0x8d, 0x92, 0xe3, 0x48, 0x45, 0x52, 0x1a, 0x46, 0x39, 0x03, 0xa3, 0x76,
0x0a, 0xab, 0x19, 0x7b, 0xc4, 0xa7, 0x89, 0xef, 0x05, 0xc1, 0x5d, 0xaf, 0x87, 0x99, 0xc5, 0x8a,
0x31, 0x12, 0xa9, 0xab, 0xbd, 0x20, 0xd0, 0x89, 0x15, 0x59, 0x8b, 0x24, 0xba, 0xae, 0x9b, 0x67,
0x14, 0x29, 0x8a, 0xef, 0xa2, 0x11, 0x49, 0x6c, 0x9d, 0xd9, 0x65, 0xb9, 0xd0, 0x75, 0x26, 0x69,
0x1f, 0x01, 0x74, 0xb1, 0xdb, 0xd3, 0x89, 0x45, 0x13, 0x28, 0x4f, 0x44, 0x07, 0x6a, 0xf1, 0x39,
0xe2, 0xd3, 0x0c, 0x09, 0xbb, 0x31, 0x3a, 0xb1, 0x62, 0xbc, 0xc4, 0x25, 0xaa, 0x71, 0xd8, 0xb7,
0xb1, 0x1b, 0x72, 0x8d, 0x0a, 0xd7, 0x10, 0x96, 0x90, 0x0a, 0x73, 0x04, 0xbb, 0xbd, 0x03, 0xdb,
0xc1, 0xf5, 0x6a, 0x43, 0x6a, 0x2a, 0x46, 0x2c, 0x6b, 0xd7, 0xa1, 0x76, 0xb7, 0x8f, 0xcd, 0x20,
0x8a, 0x73, 0x1d, 0xaa, 0x83, 0x04, 0xd0, 0x5c, 0xd2, 0x96, 0x60, 0xe1, 0x5c, 0x8d, 0xf8, 0xda,
0x53, 0x58, 0xee, 0x62, 0x6a, 0x3e, 0x51, 0xa3, 0xbc, 0xa3, 0x14, 0x6a, 0x2b, 0xf0, 0x06, 0x7e,
0x5c, 0x9f, 0x91, 0x48, 0x4f, 0x38, 0x1c, 0xba, 0x08, 0x52, 0x2e, 0x69, 0x08, 0x56, 0x92, 0xc6,
0x89, 0xaf, 0x6d, 0xc1, 0x6a, 0x17, 0x87, 0x11, 0x32, 0xdd, 0xd0, 0x0c, 0x07, 0x24, 0x72, 0x4a,
0x98, 0xc0, 0x6c, 0x57, 0x8c, 0x48, 0xd2, 0xd6, 0x61, 0x2d, 0xab, 0x4e, 0x7c, 0xed, 0x63, 0x46,
0x87, 0x8c, 0x99, 0xd4, 0x25, 0x96, 0xb2, 0x97, 0xf8, 0x7b, 0x58, 0xeb, 0xe4, 0x18, 0xa4, 0xd9,
0xe1, 0x24, 0x91, 0xf0, 0x39, 0x91, 0x70, 0x82, 0x48, 0x38, 0x26, 0x52, 0x14, 0xb2, 0x92, 0x08,
0xb9, 0x03, 0xab, 0x6d, 0xdc, 0xef, 0x0e, 0x7c, 0x1c, 0x74, 0x28, 0x40, 0x99, 0x8a, 0xc8, 0x45,
0xb0, 0x2a, 0x09, 0x58, 0x69, 0xee, 0x59, 0x43, 0xc4, 0xd7, 0x0e, 0x79, 0xee, 0x69, 0x07, 0x13,
0x73, 0x47, 0x2b, 0xa0, 0xd0, 0x22, 0xc9, 0xac, 0x48, 0xf4, 0xcf, 0x31, 0xce, 0x03, 0x8e, 0x53,
0xda, 0xf9, 0x14, 0x38, 0x95, 0xbf, 0x32, 0xf7, 0x58, 0xcf, 0x78, 0x1c, 0xd8, 0x21, 0x6e, 0xdb,
0x47, 0x47, 0xd3, 0xe7, 0xa5, 0x9d, 0x30, 0x88, 0x92, 0x96, 0xde, 0x70, 0xf0, 0x3f, 0x55, 0x40,
0xd3, 0xbd, 0x9e, 0x7d, 0x34, 0xd4, 0x79, 0x93, 0x34, 0xb0, 0x79, 0x48, 0x03, 0xdc, 0x3b, 0x0b,
0xb1, 0x4b, 0x6c, 0xcf, 0x2d, 0xc7, 0x50, 0x76, 0xcb, 0xbd, 0x41, 0x70, 0x88, 0x63, 0xaa, 0xc4,
0x32, 0xdd, 0xf3, 0xfc, 0xc4, 0xcf, 0x43, 0x2c, 0xf3, 0x0e, 0x43, 0xa8, 0xa3, 0x83, 0xa1, 0x8f,
0x59, 0x87, 0xa9, 0x18, 0xe2, 0x12, 0x3a, 0x83, 0xff, 0x05, 0xe9, 0xa0, 0x58, 0xbf, 0xaf, 0xb0,
0x7e, 0xbf, 0xcb, 0xfb, 0xfd, 0xc4, 0x1c, 0x5a, 0x46, 0x9e, 0x91, 0x3d, 0x37, 0x0c, 0x86, 0x46,
0xbe, 0x83, 0x74, 0x6f, 0xab, 0x66, 0x7b, 0xdb, 0x2d, 0x90, 0xf1, 0x59, 0x7d, 0x96, 0x61, 0xbc,
0xd1, 0xb2, 0x3c, 0xcf, 0xea, 0x63, 0xfe, 0x86, 0x78, 0x3e, 0x38, 0x6a, 0x75, 0xc3, 0xc0, 0x76,
0xad, 0x6f, 0xcd, 0xfe, 0x00, 0x1b, 0x32, 0x3e, 0x43, 0x5f, 0xc0, 0x82, 0x19, 0x86, 0xe6, 0xe1,
0x0b, 0xdc, 0xdb, 0x77, 0x8f, 0xbc, 0xfa, 0x5c, 0x89, 0x73, 0x89, 0x13, 0x94, 0x0a, 0x36, 0x61,
0x89, 0xd4, 0xe7, 0x1b, 0x52, 0x73, 0xce, 0x18, 0x89, 0x68, 0x07, 0xd6, 0x6c, 0x42, 0xc3, 0x0f,
0x5c, 0xb3, 0x7f, 0x9e, 0x78, 0x1d, 0x98, 0x5a, 0xee, 0x1e, 0x6a, 0x01, 0x72, 0x88, 0xf5, 0xa5,
0x1d, 0x90, 0x90, 0xe3, 0xc7, 0x7a, 0x74, 0x8d, 0xf5, 0xe8, 0x9c, 0x1d, 0xf5, 0x09, 0xa8, 0xc5,
0x20, 0x52, 0x3e, 0x1f, 0xe3, 0x61, 0xc4, 0x0d, 0xfa, 0x27, 0xba, 0x0e, 0x95, 0x97, 0x34, 0x89,
0xe8, 0x09, 0xb1, 0x1c, 0x91, 0xf0, 0x3e, 0x1e, 0xf2, 0xdc, 0xf8, 0xee, 0xa7, 0xf2, 0x27, 0x92,
0xf6, 0xcf, 0x0c, 0x5c, 0xa1, 0x5d, 0xf7, 0x6d, 0x25, 0xe1, 0x60, 0x3c, 0x09, 0x3f, 0x67, 0x24,
0x9c, 0x90, 0xc0, 0x7f, 0x0c, 0x7c, 0x9b, 0x19, 0xf8, 0xa7, 0x04, 0x8d, 0xf1, 0x05, 0x9c, 0xaa,
0x15, 0xa7, 0x2a, 0xa8, 0x64, 0x2b, 0x98, 0x8f, 0xc1, 0x4c, 0x11, 0x06, 0x62, 0x05, 0x2a, 0xc9,
0x0a, 0xdc, 0x80, 0x6a, 0x80, 0xc9, 0xa0, 0x1f, 0xd6, 0xab, 0x8c, 0x95, 0x97, 0x18, 0x2b, 0xe3,
0x64, 0x31, 0xf1, 0x8d, 0x48, 0x41, 0xfb, 0x55, 0x81, 0xab, 0x9d, 0x38, 0x5b, 0x0a, 0xe1, 0x6b,
0xdc, 0xb9, 0xf8, 0x5e, 0xc9, 0xa9, 0x7b, 0x25, 0xde, 0x47, 0x25, 0x75, 0x1f, 0x27, 0xdf, 0x39,
0x02, 0xeb, 0x4e, 0xb2, 0x1a, 0xf7, 0xf1, 0x50, 0xb8, 0x74, 0xb7, 0x59, 0x7a, 0x25, 0xb2, 0x68,
0xe9, 0x19, 0x33, 0x46, 0x81, 0x69, 0x1a, 0x16, 0x75, 0x3e, 0xf2, 0x44, 0x81, 0x9c, 0x37, 0xc4,
0x25, 0xf5, 0x08, 0x50, 0xd6, 0x5e, 0xba, 0xce, 0x52, 0xd9, 0x3a, 0xcb, 0x45, 0x75, 0xd6, 0x7e,
0x97, 0xe0, 0xda, 0xe4, 0xe4, 0xa6, 0x22, 0x65, 0x17, 0x56, 0x89, 0xed, 0x5a, 0x7d, 0x1c, 0x27,
0xc2, 0x58, 0xc3, 0x3f, 0xa0, 0xde, 0xe5, 0xbd, 0x4c, 0xdc, 0x8f, 0x1d, 0x72, 0x45, 0x23, 0xef,
0xb4, 0xf6, 0x4a, 0x86, 0x8d, 0x71, 0xa7, 0xa6, 0x88, 0x33, 0x28, 0xea, 0xba, 0x3c, 0xd2, 0xcf,
0x26, 0x46, 0xfa, 0xfa, 0x2d, 0x77, 0x26, 0x53, 0xc8, 0x37, 0xd9, 0x84, 0x5e, 0x49, 0x70, 0x75,
0xe2, 0x53, 0x66, 0xaa, 0x92, 0x7f, 0x00, 0x35, 0x32, 0x38, 0x3c, 0xc4, 0x84, 0x08, 0x00, 0x22,
0x06, 0x20, 0xb3, 0x3d, 0xfa, 0xe4, 0x33, 0x44, 0x35, 0xb4, 0x03, 0x70, 0x64, 0xda, 0x7d, 0xdc,
0x63, 0x87, 0x66, 0x0a, 0x0f, 0x09, 0x5a, 0xda, 0xdf, 0x32, 0xbc, 0xd7, 0xc6, 0x7d, 0x1c, 0xe2,
0xb7, 0xba, 0xbb, 0x4c, 0xfe, 0x70, 0x2d, 0xfa, 0x41, 0xab, 0x5e, 0xf8, 0x07, 0x6d, 0xb6, 0xb0,
0x99, 0xef, 0x15, 0x31, 0x7c, 0x8e, 0x61, 0x9d, 0xe1, 0x4a, 0xbe, 0xb6, 0xf6, 0xb3, 0x04, 0x9b,
0xa5, 0x30, 0x9f, 0x8a, 0x3b, 0x17, 0xf8, 0x5d, 0xf1, 0x60, 0x31, 0xc1, 0x0c, 0x74, 0x0b, 0xe6,
0xf1, 0x68, 0x21, 0x1e, 0x66, 0x25, 0x09, 0x74, 0xae, 0x20, 0xc6, 0x26, 0x17, 0xc5, 0xa6, 0x88,
0xb1, 0x69, 0x7f, 0xc8, 0x30, 0x1f, 0x9b, 0x42, 0xcf, 0x8a, 0xe0, 0x94, 0x58, 0xe0, 0x37, 0x92,
0x9e, 0x5f, 0xbf, 0x3b, 0xc8, 0x65, 0xdb, 0xbc, 0x52, 0xc8, 0x00, 0x2d, 0xf5, 0x24, 0xe3, 0x0d,
0x27, 0xf9, 0xe8, 0x5a, 0x62, 0x8f, 0x3c, 0x4e, 0x51, 0x19, 0x9f, 0xa9, 0x4f, 0x2f, 0xd8, 0x81,
0x36, 0x93, 0x1d, 0x28, 0xa7, 0x7e, 0x42, 0x0f, 0x72, 0x60, 0x41, 0xdc, 0x42, 0x37, 0x61, 0xee,
0x38, 0x92, 0xa3, 0x02, 0x66, 0x58, 0x19, 0x2b, 0x4c, 0x51, 0xc0, 0x5f, 0x24, 0x58, 0x15, 0x66,
0x83, 0x14, 0x17, 0x36, 0x1c, 0xcc, 0x8c, 0x00, 0xa5, 0x12, 0x23, 0x40, 0xf9, 0xc2, 0x23, 0x40,
0x25, 0x3d, 0x02, 0xbc, 0x03, 0x8b, 0x6d, 0xdc, 0xd7, 0x89, 0xc5, 0xaf, 0xd0, 0xd8, 0x11, 0x08,
0xc1, 0x27, 0x71, 0x37, 0x5d, 0x34, 0x46, 0xa2, 0xb6, 0x02, 0x4b, 0xa2, 0x09, 0xe2, 0xef, 0xfc,
0x35, 0x0b, 0x8a, 0x43, 0x2c, 0x74, 0x0f, 0x96, 0x53, 0xf3, 0x40, 0x74, 0x39, 0x02, 0x33, 0x3b,
0x77, 0x54, 0xd5, 0xa2, 0x2d, 0xe2, 0xa3, 0xc7, 0xb0, 0xf6, 0x70, 0xd0, 0xef, 0x47, 0xd7, 0x7d,
0x77, 0xd8, 0xe5, 0xbe, 0xd1, 0x3b, 0xd1, 0x99, 0xbc, 0x4d, 0x6a, 0xf3, 0xca, 0xd8, 0x7d, 0x76,
0x61, 0x67, 0xa3, 0x39, 0x13, 0x5a, 0x8e, 0xbe, 0x6a, 0x46, 0x73, 0x44, 0x75, 0x25, 0xb9, 0x40,
0x7c, 0xf4, 0x21, 0xc0, 0x79, 0xaa, 0x88, 0xff, 0x34, 0x24, 0xe0, 0x53, 0x57, 0x33, 0x6b, 0xc4,
0x47, 0x1d, 0x58, 0x49, 0x0f, 0x89, 0x50, 0x7d, 0xa4, 0x98, 0x9e, 0x11, 0xa9, 0x97, 0x0b, 0x76,
0x88, 0x8f, 0xb6, 0x61, 0x6e, 0x34, 0x19, 0x44, 0x3c, 0x3a, 0x61, 0x9e, 0xa8, 0x5e, 0x4a, 0xad,
0x70, 0xcf, 0xe9, 0xd1, 0x5c, 0xe4, 0x39, 0x67, 0xc0, 0x17, 0x79, 0xce, 0x9b, 0xe5, 0x51, 0x43,
0x9d, 0x7c, 0x43, 0x9d, 0x42, 0x43, 0xb9, 0x33, 0xbc, 0x63, 0xd8, 0x18, 0xf7, 0xdd, 0x81, 0xae,
0x95, 0xf9, 0xb6, 0x54, 0xaf, 0x97, 0xd0, 0x22, 0x3e, 0x3a, 0x85, 0xc6, 0xa4, 0x37, 0x25, 0x6a,
0x96, 0x7d, 0x57, 0xab, 0x37, 0x4a, 0x6a, 0x12, 0x1f, 0x9d, 0xc0, 0xc6, 0x9d, 0x5e, 0xaf, 0x38,
0xcb, 0xcd, 0x92, 0x63, 0x1c, 0xb5, 0x59, 0x4e, 0x91, 0xf8, 0xe8, 0x07, 0xb8, 0x92, 0xf8, 0x4d,
0xcc, 0xf1, 0x7a, 0x73, 0xc4, 0xac, 0x12, 0xaf, 0x15, 0xf5, 0x56, 0x79, 0x65, 0xe2, 0xef, 0xfe,
0xff, 0xbb, 0xcb, 0x0f, 0x7c, 0xec, 0x3e, 0xdb, 0xd7, 0x85, 0xff, 0x36, 0x39, 0xc4, 0xba, 0xed,
0x10, 0xeb, 0x79, 0x95, 0x89, 0xef, 0xff, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x24, 0xb5, 0xd1, 0x36,
0xd5, 0x1a, 0x00, 0x00,
2 years ago
}