msb-public
/
Open-IM-Server
mirror of https://github.com/OpenIMSDK/Open-IM-Server
2
0
Code Issues Projects Releases Wiki Activity

proto file

Browse Source
pull/131/head
Gordon 3 years ago
parent 777805fc1a
commit 26640b3b07
1 changed files with 334 additions and 353 deletions
Show Stats Download Patch File Download Diff File

687
pkg/proto/chat/chat.pb.go
Unescape View File

@ -1,13 +1,18 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// source: chat.proto // source: chat/chat.proto
package pbChat package pbChat // import "./chat"
import proto "github.com/golang/protobuf/proto" import proto "github.com/golang/protobuf/proto"
import fmt "fmt" import fmt "fmt"
import math "math" import math "math"
import sdk_ws "Open_IM/pkg/proto/sdk_ws" import sdk_ws "Open_IM/pkg/proto/sdk_ws"
import (
context "golang.org/x/net/context"
grpc "google.golang.org/grpc"
)
// Reference imports to suppress errors if they are not otherwise used. // Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal var _ = proto.Marshal
var _ = fmt.Errorf var _ = fmt.Errorf
@ -19,328 +24,142 @@ var _ = math.Inf
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
type WSToMsgSvrChatMsg struct { type MsgDataToMQ struct {
SendID string `protobuf:"bytes,1,opt,name=SendID" json:"SendID,omitempty"` Token string `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"` OperationID string `protobuf:"bytes,2,opt,name=operationID" json:"operationID,omitempty"`
Content string `protobuf:"bytes,3,opt,name=Content" json:"Content,omitempty"` MsgData *sdk_ws.MsgData `protobuf:"bytes,3,opt,name=msgData" json:"msgData,omitempty"`
SendTime int64 `protobuf:"varint,4,opt,name=SendTime" json:"SendTime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
MsgFrom int32 `protobuf:"varint,5,opt,name=MsgFrom" json:"MsgFrom,omitempty"` XXX_unrecognized []byte `json:"-"`
SenderNickName string `protobuf:"bytes,6,opt,name=SenderNickName" json:"SenderNickName,omitempty"` XXX_sizecache int32 `json:"-"`
SenderFaceURL string `protobuf:"bytes,7,opt,name=SenderFaceURL" json:"SenderFaceURL,omitempty"`
ContentType int32 `protobuf:"varint,8,opt,name=ContentType" json:"ContentType,omitempty"`
SessionType int32 `protobuf:"varint,9,opt,name=SessionType" json:"SessionType,omitempty"`
OperationID string `protobuf:"bytes,10,opt,name=OperationID" json:"OperationID,omitempty"`
MsgID string `protobuf:"bytes,11,opt,name=MsgID" json:"MsgID,omitempty"`
Token string `protobuf:"bytes,12,opt,name=Token" json:"Token,omitempty"`
OfflineInfo string `protobuf:"bytes,13,opt,name=OfflineInfo" json:"OfflineInfo,omitempty"`
Options string `protobuf:"bytes,14,opt,name=Options" json:"Options,omitempty"`
PlatformID int32 `protobuf:"varint,15,opt,name=PlatformID" json:"PlatformID,omitempty"`
ForceList []string `protobuf:"bytes,16,rep,name=ForceList" json:"ForceList,omitempty"`
ClientMsgID string `protobuf:"bytes,17,opt,name=ClientMsgID" json:"ClientMsgID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *WSToMsgSvrChatMsg) Reset() { *m = WSToMsgSvrChatMsg{} }
func (m *WSToMsgSvrChatMsg) String() string { return proto.CompactTextString(m) }
func (*WSToMsgSvrChatMsg) ProtoMessage() {}
func (*WSToMsgSvrChatMsg) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{0}
}
func (m *WSToMsgSvrChatMsg) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_WSToMsgSvrChatMsg.Unmarshal(m, b)
}
func (m *WSToMsgSvrChatMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_WSToMsgSvrChatMsg.Marshal(b, m, deterministic)
}
func (dst *WSToMsgSvrChatMsg) XXX_Merge(src proto.Message) {
xxx_messageInfo_WSToMsgSvrChatMsg.Merge(dst, src)
}
func (m *WSToMsgSvrChatMsg) XXX_Size() int {
return xxx_messageInfo_WSToMsgSvrChatMsg.Size(m)
}
func (m *WSToMsgSvrChatMsg) XXX_DiscardUnknown() {
xxx_messageInfo_WSToMsgSvrChatMsg.DiscardUnknown(m)
}
var xxx_messageInfo_WSToMsgSvrChatMsg proto.InternalMessageInfo
func (m *WSToMsgSvrChatMsg) GetSendID() string {
if m != nil {
return m.SendID
}
return ""
}
func (m *WSToMsgSvrChatMsg) GetRecvID() string {
if m != nil {
return m.RecvID
}
return ""
}
func (m *WSToMsgSvrChatMsg) GetContent() string {
if m != nil {
return m.Content
}
return ""
}
func (m *WSToMsgSvrChatMsg) GetSendTime() int64 {
if m != nil {
return m.SendTime
}
return 0
} }
func (m *WSToMsgSvrChatMsg) GetMsgFrom() int32 { func (m *MsgDataToMQ) Reset() { *m = MsgDataToMQ{} }
if m != nil { func (m *MsgDataToMQ) String() string { return proto.CompactTextString(m) }
return m.MsgFrom func (*MsgDataToMQ) ProtoMessage() {}
} func (*MsgDataToMQ) Descriptor() ([]byte, []int) {
return 0 return fileDescriptor_chat_e46047b47969b559, []int{0}
} }
func (m *MsgDataToMQ) XXX_Unmarshal(b []byte) error {
func (m *WSToMsgSvrChatMsg) GetSenderNickName() string { return xxx_messageInfo_MsgDataToMQ.Unmarshal(m, b)
if m != nil {
return m.SenderNickName
}
return ""
} }
func (m *MsgDataToMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
func (m *WSToMsgSvrChatMsg) GetSenderFaceURL() string { return xxx_messageInfo_MsgDataToMQ.Marshal(b, m, deterministic)
if m != nil {
return m.SenderFaceURL
}
return ""
} }
func (dst *MsgDataToMQ) XXX_Merge(src proto.Message) {
func (m *WSToMsgSvrChatMsg) GetContentType() int32 { xxx_messageInfo_MsgDataToMQ.Merge(dst, src)
if m != nil {
return m.ContentType
}
return 0
} }
func (m *MsgDataToMQ) XXX_Size() int {
func (m *WSToMsgSvrChatMsg) GetSessionType() int32 { return xxx_messageInfo_MsgDataToMQ.Size(m)
if m != nil {
return m.SessionType
}
return 0
} }
func (m *MsgDataToMQ) XXX_DiscardUnknown() {
func (m *WSToMsgSvrChatMsg) GetOperationID() string { xxx_messageInfo_MsgDataToMQ.DiscardUnknown(m)
if m != nil {
return m.OperationID
}
return ""
} }
func (m *WSToMsgSvrChatMsg) GetMsgID() string { var xxx_messageInfo_MsgDataToMQ proto.InternalMessageInfo
if m != nil {
return m.MsgID
}
return ""
}
func (m *WSToMsgSvrChatMsg) GetToken() string { func (m *MsgDataToMQ) GetToken() string {
if m != nil { if m != nil {
return m.Token return m.Token
} }
return "" return ""
} }
func (m *WSToMsgSvrChatMsg) GetOfflineInfo() string { func (m *MsgDataToMQ) GetOperationID() string {
if m != nil { if m != nil {
return m.OfflineInfo return m.OperationID
}
return ""
}
func (m *WSToMsgSvrChatMsg) GetOptions() string {
if m != nil {
return m.Options
} }
return "" return ""
} }
func (m *WSToMsgSvrChatMsg) GetPlatformID() int32 { func (m *MsgDataToMQ) GetMsgData() *sdk_ws.MsgData {
if m != nil { if m != nil {
return m.PlatformID return m.MsgData
}
return 0
}
func (m *WSToMsgSvrChatMsg) GetForceList() []string {
if m != nil {
return m.ForceList
} }
return nil return nil
} }
func (m *WSToMsgSvrChatMsg) GetClientMsgID() string { type MsgDataToDB struct {
if m != nil { MsgData *sdk_ws.MsgData `protobuf:"bytes,1,opt,name=msgData" json:"msgData,omitempty"`
return m.ClientMsgID XXX_NoUnkeyedLiteral struct{} `json:"-"`
} XXX_unrecognized []byte `json:"-"`
return "" XXX_sizecache int32 `json:"-"`
}
type MsgSvrToPushSvrChatMsg struct {
SendID string `protobuf:"bytes,1,opt,name=SendID" json:"SendID,omitempty"`
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"`
Content string `protobuf:"bytes,3,opt,name=Content" json:"Content,omitempty"`
RecvSeq int64 `protobuf:"varint,4,opt,name=RecvSeq" json:"RecvSeq,omitempty"`
SendTime int64 `protobuf:"varint,5,opt,name=SendTime" json:"SendTime,omitempty"`
MsgFrom int32 `protobuf:"varint,6,opt,name=MsgFrom" json:"MsgFrom,omitempty"`
SenderNickName string `protobuf:"bytes,7,opt,name=SenderNickName" json:"SenderNickName,omitempty"`
SenderFaceURL string `protobuf:"bytes,8,opt,name=SenderFaceURL" json:"SenderFaceURL,omitempty"`
ContentType int32 `protobuf:"varint,9,opt,name=ContentType" json:"ContentType,omitempty"`
SessionType int32 `protobuf:"varint,10,opt,name=SessionType" json:"SessionType,omitempty"`
OperationID string `protobuf:"bytes,11,opt,name=OperationID" json:"OperationID,omitempty"`
MsgID string `protobuf:"bytes,12,opt,name=MsgID" json:"MsgID,omitempty"`
OfflineInfo string `protobuf:"bytes,13,opt,name=OfflineInfo" json:"OfflineInfo,omitempty"`
Options string `protobuf:"bytes,14,opt,name=Options" json:"Options,omitempty"`
PlatformID int32 `protobuf:"varint,15,opt,name=PlatformID" json:"PlatformID,omitempty"`
ClientMsgID string `protobuf:"bytes,16,opt,name=ClientMsgID" json:"ClientMsgID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *MsgSvrToPushSvrChatMsg) Reset() { *m = MsgSvrToPushSvrChatMsg{} } func (m *MsgDataToDB) Reset() { *m = MsgDataToDB{} }
func (m *MsgSvrToPushSvrChatMsg) String() string { return proto.CompactTextString(m) } func (m *MsgDataToDB) String() string { return proto.CompactTextString(m) }
func (*MsgSvrToPushSvrChatMsg) ProtoMessage() {} func (*MsgDataToDB) ProtoMessage() {}
func (*MsgSvrToPushSvrChatMsg) Descriptor() ([]byte, []int) { func (*MsgDataToDB) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{1} return fileDescriptor_chat_e46047b47969b559, []int{1}
} }
func (m *MsgSvrToPushSvrChatMsg) XXX_Unmarshal(b []byte) error { func (m *MsgDataToDB) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgSvrToPushSvrChatMsg.Unmarshal(m, b) return xxx_messageInfo_MsgDataToDB.Unmarshal(m, b)
} }
func (m *MsgSvrToPushSvrChatMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { func (m *MsgDataToDB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgSvrToPushSvrChatMsg.Marshal(b, m, deterministic) return xxx_messageInfo_MsgDataToDB.Marshal(b, m, deterministic)
} }
func (dst *MsgSvrToPushSvrChatMsg) XXX_Merge(src proto.Message) { func (dst *MsgDataToDB) XXX_Merge(src proto.Message) {
xxx_messageInfo_MsgSvrToPushSvrChatMsg.Merge(dst, src) xxx_messageInfo_MsgDataToDB.Merge(dst, src)
} }
func (m *MsgSvrToPushSvrChatMsg) XXX_Size() int { func (m *MsgDataToDB) XXX_Size() int {
return xxx_messageInfo_MsgSvrToPushSvrChatMsg.Size(m) return xxx_messageInfo_MsgDataToDB.Size(m)
} }
func (m *MsgSvrToPushSvrChatMsg) XXX_DiscardUnknown() { func (m *MsgDataToDB) XXX_DiscardUnknown() {
xxx_messageInfo_MsgSvrToPushSvrChatMsg.DiscardUnknown(m) xxx_messageInfo_MsgDataToDB.DiscardUnknown(m)
} }
var xxx_messageInfo_MsgSvrToPushSvrChatMsg proto.InternalMessageInfo var xxx_messageInfo_MsgDataToDB proto.InternalMessageInfo
func (m *MsgSvrToPushSvrChatMsg) GetSendID() string { func (m *MsgDataToDB) GetMsgData() *sdk_ws.MsgData {
if m != nil { if m != nil {
return m.SendID return m.MsgData
}
return ""
}
func (m *MsgSvrToPushSvrChatMsg) GetRecvID() string {
if m != nil {
return m.RecvID
} }
return "" return nil
} }
func (m *MsgSvrToPushSvrChatMsg) GetContent() string { type PushMsgDataToMQ struct {
if m != nil { OperationID string `protobuf:"bytes,1,opt,name=OperationID" json:"OperationID,omitempty"`
return m.Content MsgData *sdk_ws.MsgData `protobuf:"bytes,2,opt,name=msgData" json:"msgData,omitempty"`
} XXX_NoUnkeyedLiteral struct{} `json:"-"`
return "" XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *MsgSvrToPushSvrChatMsg) GetRecvSeq() int64 { func (m *PushMsgDataToMQ) Reset() { *m = PushMsgDataToMQ{} }
if m != nil { func (m *PushMsgDataToMQ) String() string { return proto.CompactTextString(m) }
return m.RecvSeq func (*PushMsgDataToMQ) ProtoMessage() {}
} func (*PushMsgDataToMQ) Descriptor() ([]byte, []int) {
return 0 return fileDescriptor_chat_e46047b47969b559, []int{2}
} }
func (m *PushMsgDataToMQ) XXX_Unmarshal(b []byte) error {
func (m *MsgSvrToPushSvrChatMsg) GetSendTime() int64 { return xxx_messageInfo_PushMsgDataToMQ.Unmarshal(m, b)
if m != nil {
return m.SendTime
}
return 0
} }
func (m *PushMsgDataToMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
func (m *MsgSvrToPushSvrChatMsg) GetMsgFrom() int32 { return xxx_messageInfo_PushMsgDataToMQ.Marshal(b, m, deterministic)
if m != nil {
return m.MsgFrom
}
return 0
} }
func (dst *PushMsgDataToMQ) XXX_Merge(src proto.Message) {
func (m *MsgSvrToPushSvrChatMsg) GetSenderNickName() string { xxx_messageInfo_PushMsgDataToMQ.Merge(dst, src)
if m != nil {
return m.SenderNickName
}
return ""
} }
func (m *PushMsgDataToMQ) XXX_Size() int {
func (m *MsgSvrToPushSvrChatMsg) GetSenderFaceURL() string { return xxx_messageInfo_PushMsgDataToMQ.Size(m)
if m != nil {
return m.SenderFaceURL
}
return ""
} }
func (m *PushMsgDataToMQ) XXX_DiscardUnknown() {
func (m *MsgSvrToPushSvrChatMsg) GetContentType() int32 { xxx_messageInfo_PushMsgDataToMQ.DiscardUnknown(m)
if m != nil {
return m.ContentType
}
return 0
} }
func (m *MsgSvrToPushSvrChatMsg) GetSessionType() int32 { var xxx_messageInfo_PushMsgDataToMQ proto.InternalMessageInfo
if m != nil {
return m.SessionType
}
return 0
}
func (m *MsgSvrToPushSvrChatMsg) GetOperationID() string { func (m *PushMsgDataToMQ) GetOperationID() string {
if m != nil { if m != nil {
return m.OperationID return m.OperationID
} }
return "" return ""
} }
func (m *MsgSvrToPushSvrChatMsg) GetMsgID() string { func (m *PushMsgDataToMQ) GetMsgData() *sdk_ws.MsgData {
if m != nil {
return m.MsgID
}
return ""
}
func (m *MsgSvrToPushSvrChatMsg) GetOfflineInfo() string {
if m != nil {
return m.OfflineInfo
}
return ""
}
func (m *MsgSvrToPushSvrChatMsg) GetOptions() string {
if m != nil {
return m.Options
}
return ""
}
func (m *MsgSvrToPushSvrChatMsg) GetPlatformID() int32 {
if m != nil {
return m.PlatformID
}
return 0
}
func (m *MsgSvrToPushSvrChatMsg) GetClientMsgID() string {
if m != nil { if m != nil {
return m.ClientMsgID return m.MsgData
} }
return "" return nil
} }
type PullMessageReq struct { type PullMessageReq struct {
@ -357,7 +176,7 @@ func (m *PullMessageReq) Reset() { *m = PullMessageReq{} }
func (m *PullMessageReq) String() string { return proto.CompactTextString(m) } func (m *PullMessageReq) String() string { return proto.CompactTextString(m) }
func (*PullMessageReq) ProtoMessage() {} func (*PullMessageReq) ProtoMessage() {}
func (*PullMessageReq) Descriptor() ([]byte, []int) { func (*PullMessageReq) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{2} return fileDescriptor_chat_e46047b47969b559, []int{3}
} }
func (m *PullMessageReq) XXX_Unmarshal(b []byte) error { func (m *PullMessageReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PullMessageReq.Unmarshal(m, b) return xxx_messageInfo_PullMessageReq.Unmarshal(m, b)
@ -421,7 +240,7 @@ func (m *PullMessageResp) Reset() { *m = PullMessageResp{} }
func (m *PullMessageResp) String() string { return proto.CompactTextString(m) } func (m *PullMessageResp) String() string { return proto.CompactTextString(m) }
func (*PullMessageResp) ProtoMessage() {} func (*PullMessageResp) ProtoMessage() {}
func (*PullMessageResp) Descriptor() ([]byte, []int) { func (*PullMessageResp) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{3} return fileDescriptor_chat_e46047b47969b559, []int{4}
} }
func (m *PullMessageResp) XXX_Unmarshal(b []byte) error { func (m *PullMessageResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PullMessageResp.Unmarshal(m, b) return xxx_messageInfo_PullMessageResp.Unmarshal(m, b)
@ -496,7 +315,7 @@ func (m *PullMessageBySeqListReq) Reset() { *m = PullMessageBySeqListReq
func (m *PullMessageBySeqListReq) String() string { return proto.CompactTextString(m) } func (m *PullMessageBySeqListReq) String() string { return proto.CompactTextString(m) }
func (*PullMessageBySeqListReq) ProtoMessage() {} func (*PullMessageBySeqListReq) ProtoMessage() {}
func (*PullMessageBySeqListReq) Descriptor() ([]byte, []int) { func (*PullMessageBySeqListReq) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{4} return fileDescriptor_chat_e46047b47969b559, []int{5}
} }
func (m *PullMessageBySeqListReq) XXX_Unmarshal(b []byte) error { func (m *PullMessageBySeqListReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PullMessageBySeqListReq.Unmarshal(m, b) return xxx_messageInfo_PullMessageBySeqListReq.Unmarshal(m, b)
@ -549,7 +368,7 @@ func (m *GetMaxAndMinSeqReq) Reset() { *m = GetMaxAndMinSeqReq{} }
func (m *GetMaxAndMinSeqReq) String() string { return proto.CompactTextString(m) } func (m *GetMaxAndMinSeqReq) String() string { return proto.CompactTextString(m) }
func (*GetMaxAndMinSeqReq) ProtoMessage() {} func (*GetMaxAndMinSeqReq) ProtoMessage() {}
func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int) { func (*GetMaxAndMinSeqReq) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{5} return fileDescriptor_chat_e46047b47969b559, []int{6}
} }
func (m *GetMaxAndMinSeqReq) XXX_Unmarshal(b []byte) error { func (m *GetMaxAndMinSeqReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMaxAndMinSeqReq.Unmarshal(m, b) return xxx_messageInfo_GetMaxAndMinSeqReq.Unmarshal(m, b)
@ -597,7 +416,7 @@ func (m *GetMaxAndMinSeqResp) Reset() { *m = GetMaxAndMinSeqResp{} }
func (m *GetMaxAndMinSeqResp) String() string { return proto.CompactTextString(m) } func (m *GetMaxAndMinSeqResp) String() string { return proto.CompactTextString(m) }
func (*GetMaxAndMinSeqResp) ProtoMessage() {} func (*GetMaxAndMinSeqResp) ProtoMessage() {}
func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int) { func (*GetMaxAndMinSeqResp) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{6} return fileDescriptor_chat_e46047b47969b559, []int{7}
} }
func (m *GetMaxAndMinSeqResp) XXX_Unmarshal(b []byte) error { func (m *GetMaxAndMinSeqResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetMaxAndMinSeqResp.Unmarshal(m, b) return xxx_messageInfo_GetMaxAndMinSeqResp.Unmarshal(m, b)
@ -647,9 +466,9 @@ func (m *GetMaxAndMinSeqResp) GetMinSeq() int64 {
type GatherFormat struct { type GatherFormat struct {
// @inject_tag: json:"id" // @inject_tag: json:"id"
ID string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"` ID string `protobuf:"bytes,1,opt,name=ID" json:"id"`
// @inject_tag: json:"list" // @inject_tag: json:"list"
List []*MsgFormat `protobuf:"bytes,2,rep,name=List" json:"List,omitempty"` List []*MsgFormat `protobuf:"bytes,2,rep,name=List" json:"list"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
@ -659,7 +478,7 @@ func (m *GatherFormat) Reset() { *m = GatherFormat{} }
func (m *GatherFormat) String() string { return proto.CompactTextString(m) } func (m *GatherFormat) String() string { return proto.CompactTextString(m) }
func (*GatherFormat) ProtoMessage() {} func (*GatherFormat) ProtoMessage() {}
func (*GatherFormat) Descriptor() ([]byte, []int) { func (*GatherFormat) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{7} return fileDescriptor_chat_e46047b47969b559, []int{8}
} }
func (m *GatherFormat) XXX_Unmarshal(b []byte) error { func (m *GatherFormat) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GatherFormat.Unmarshal(m, b) return xxx_messageInfo_GatherFormat.Unmarshal(m, b)
@ -695,29 +514,29 @@ func (m *GatherFormat) GetList() []*MsgFormat {
type MsgFormat struct { type MsgFormat struct {
// @inject_tag: json:"sendID" // @inject_tag: json:"sendID"
SendID string `protobuf:"bytes,1,opt,name=SendID" json:"SendID,omitempty"` SendID string `protobuf:"bytes,1,opt,name=SendID" json:"sendID"`
// @inject_tag: json:"recvID" // @inject_tag: json:"recvID"
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"` RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"recvID"`
// @inject_tag: json:"msgFrom" // @inject_tag: json:"msgFrom"
MsgFrom int32 `protobuf:"varint,3,opt,name=MsgFrom" json:"MsgFrom,omitempty"` MsgFrom int32 `protobuf:"varint,3,opt,name=MsgFrom" json:"msgFrom"`
// @inject_tag: json:"contentType" // @inject_tag: json:"contentType"
ContentType int32 `protobuf:"varint,4,opt,name=ContentType" json:"ContentType,omitempty"` ContentType int32 `protobuf:"varint,4,opt,name=ContentType" json:"contentType"`
// @inject_tag: json:"serverMsgID" // @inject_tag: json:"serverMsgID"
ServerMsgID string `protobuf:"bytes,5,opt,name=ServerMsgID" json:"ServerMsgID,omitempty"` ServerMsgID string `protobuf:"bytes,5,opt,name=ServerMsgID" json:"serverMsgID"`
// @inject_tag: json:"content" // @inject_tag: json:"content"
Content string `protobuf:"bytes,6,opt,name=Content" json:"Content,omitempty"` Content string `protobuf:"bytes,6,opt,name=Content" json:"content"`
// @inject_tag: json:"seq" // @inject_tag: json:"seq"
Seq int64 `protobuf:"varint,7,opt,name=Seq" json:"Seq,omitempty"` Seq int64 `protobuf:"varint,7,opt,name=Seq" json:"seq"`
// @inject_tag: json:"sendTime" // @inject_tag: json:"sendTime"
SendTime int64 `protobuf:"varint,8,opt,name=SendTime" json:"SendTime,omitempty"` SendTime int64 `protobuf:"varint,8,opt,name=SendTime" json:"sendTime"`
// @inject_tag: json:"senderPlatformID" // @inject_tag: json:"senderPlatformID"
SenderPlatformID int32 `protobuf:"varint,9,opt,name=SenderPlatformID" json:"SenderPlatformID,omitempty"` SenderPlatformID int32 `protobuf:"varint,9,opt,name=SenderPlatformID" json:"senderPlatformID"`
// @inject_tag: json:"senderNickName" // @inject_tag: json:"senderNickName"
SenderNickName string `protobuf:"bytes,10,opt,name=SenderNickName" json:"SenderNickName,omitempty"` SenderNickName string `protobuf:"bytes,10,opt,name=SenderNickName" json:"senderNickName"`
// @inject_tag: json:"senderFaceUrl" // @inject_tag: json:"senderFaceUrl"
SenderFaceURL string `protobuf:"bytes,11,opt,name=SenderFaceURL" json:"SenderFaceURL,omitempty"` SenderFaceURL string `protobuf:"bytes,11,opt,name=SenderFaceURL" json:"senderFaceUrl"`
// @inject_tag: json:"clientMsgID" // @inject_tag: json:"clientMsgID"
ClientMsgID string `protobuf:"bytes,12,opt,name=ClientMsgID" json:"ClientMsgID,omitempty"` ClientMsgID string `protobuf:"bytes,12,opt,name=ClientMsgID" json:"clientMsgID"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
@ -727,7 +546,7 @@ func (m *MsgFormat) Reset() { *m = MsgFormat{} }
func (m *MsgFormat) String() string { return proto.CompactTextString(m) } func (m *MsgFormat) String() string { return proto.CompactTextString(m) }
func (*MsgFormat) ProtoMessage() {} func (*MsgFormat) ProtoMessage() {}
func (*MsgFormat) Descriptor() ([]byte, []int) { func (*MsgFormat) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{8} return fileDescriptor_chat_e46047b47969b559, []int{9}
} }
func (m *MsgFormat) XXX_Unmarshal(b []byte) error { func (m *MsgFormat) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgFormat.Unmarshal(m, b) return xxx_messageInfo_MsgFormat.Unmarshal(m, b)
@ -844,7 +663,7 @@ func (m *SendMsgReq) Reset() { *m = SendMsgReq{} }
func (m *SendMsgReq) String() string { return proto.CompactTextString(m) } func (m *SendMsgReq) String() string { return proto.CompactTextString(m) }
func (*SendMsgReq) ProtoMessage() {} func (*SendMsgReq) ProtoMessage() {}
func (*SendMsgReq) Descriptor() ([]byte, []int) { func (*SendMsgReq) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{9} return fileDescriptor_chat_e46047b47969b559, []int{10}
} }
func (m *SendMsgReq) XXX_Unmarshal(b []byte) error { func (m *SendMsgReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SendMsgReq.Unmarshal(m, b) return xxx_messageInfo_SendMsgReq.Unmarshal(m, b)
@ -901,7 +720,7 @@ func (m *SendMsgResp) Reset() { *m = SendMsgResp{} }
func (m *SendMsgResp) String() string { return proto.CompactTextString(m) } func (m *SendMsgResp) String() string { return proto.CompactTextString(m) }
func (*SendMsgResp) ProtoMessage() {} func (*SendMsgResp) ProtoMessage() {}
func (*SendMsgResp) Descriptor() ([]byte, []int) { func (*SendMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_chat_955d1f0dcca586dd, []int{10} return fileDescriptor_chat_e46047b47969b559, []int{11}
} }
func (m *SendMsgResp) XXX_Unmarshal(b []byte) error { func (m *SendMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SendMsgResp.Unmarshal(m, b) return xxx_messageInfo_SendMsgResp.Unmarshal(m, b)
@ -964,8 +783,9 @@ func (m *SendMsgResp) GetSendTime() int64 {
} }
func init() { func init() {
proto.RegisterType((*WSToMsgSvrChatMsg)(nil), "pbChat.WSToMsgSvrChatMsg") proto.RegisterType((*MsgDataToMQ)(nil), "pbChat.MsgDataToMQ")
proto.RegisterType((*MsgSvrToPushSvrChatMsg)(nil), "pbChat.MsgSvrToPushSvrChatMsg") proto.RegisterType((*MsgDataToDB)(nil), "pbChat.MsgDataToDB")
proto.RegisterType((*PushMsgDataToMQ)(nil), "pbChat.PushMsgDataToMQ")
proto.RegisterType((*PullMessageReq)(nil), "pbChat.PullMessageReq") proto.RegisterType((*PullMessageReq)(nil), "pbChat.PullMessageReq")
proto.RegisterType((*PullMessageResp)(nil), "pbChat.PullMessageResp") proto.RegisterType((*PullMessageResp)(nil), "pbChat.PullMessageResp")
proto.RegisterType((*PullMessageBySeqListReq)(nil), "pbChat.PullMessageBySeqListReq") proto.RegisterType((*PullMessageBySeqListReq)(nil), "pbChat.PullMessageBySeqListReq")
@ -977,66 +797,227 @@ func init() {
proto.RegisterType((*SendMsgResp)(nil), "pbChat.SendMsgResp") proto.RegisterType((*SendMsgResp)(nil), "pbChat.SendMsgResp")
} }
func init() { proto.RegisterFile("chat.proto", fileDescriptor_chat_955d1f0dcca586dd) } // Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var fileDescriptor_chat_955d1f0dcca586dd = []byte{ var _ grpc.ClientConn
// 927 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x56, 0xcb, 0x6e, 0xe3, 0x36, // This is a compile-time assertion to ensure that this generated file
0x14, 0x85, 0x2d, 0x3f, 0xe2, 0x6b, 0xe7, 0xc5, 0x09, 0x32, 0x84, 0x5b, 0xb4, 0xae, 0x30, 0x2d, // is compatible with the grpc package it is being compiled against.
0x8c, 0x2e, 0x12, 0x20, 0xdd, 0x14, 0x5d, 0x14, 0xe8, 0xc4, 0x49, 0xa0, 0x62, 0x94, 0x04, 0xb2, const _ = grpc.SupportPackageIsVersion4
0x07, 0x5d, 0x06, 0x1a, 0x9b, 0x56, 0x04, 0xdb, 0xa2, 0x4c, 0x32, 0xc9, 0xcc, 0xa6, 0xbf, 0xd0,
0x6d, 0x7f, 0xa8, 0x1f, 0xd3, 0x5f, 0x28, 0x50, 0xa0, 0xb8, 0xa4, 0x14, 0xeb, 0x11, 0x27, 0xc1, // Client API for Chat service
0x14, 0x33, 0xcb, 0x73, 0x78, 0x79, 0x49, 0xdd, 0x73, 0x78, 0x6c, 0x80, 0xf1, 0xb5, 0xaf, 0x0e,
0x62, 0xc1, 0x15, 0x27, 0x8d, 0xf8, 0xdd, 0xf1, 0xb5, 0xaf, 0xba, 0xdf, 0x5c, 0xc4, 0x2c, 0xba, type ChatClient interface {
0x72, 0xdc, 0xc3, 0x78, 0x16, 0x1c, 0xea, 0xa5, 0x43, 0x39, 0x99, 0x5d, 0xdd, 0xc9, 0xc3, 0x3b, GetMaxAndMinSeq(ctx context.Context, in *GetMaxAndMinSeqReq, opts ...grpc.CallOption) (*GetMaxAndMinSeqResp, error)
0x69, 0x4a, 0xed, 0x3f, 0x6a, 0xb0, 0xfb, 0xdb, 0x70, 0xc4, 0x5d, 0x19, 0x0c, 0x6f, 0x05, 0xee, PullMessage(ctx context.Context, in *PullMessageReq, opts ...grpc.CallOption) (*PullMessageResp, error)
0x72, 0x65, 0x40, 0xf6, 0xa1, 0x31, 0x64, 0xd1, 0xc4, 0x19, 0xd0, 0x4a, 0xaf, 0xd2, 0x6f, 0x79, PullMessageBySeqList(ctx context.Context, in *PullMessageBySeqListReq, opts ...grpc.CallOption) (*PullMessageResp, error)
0x09, 0x42, 0xde, 0x63, 0xe3, 0x5b, 0x67, 0x40, 0xab, 0x86, 0x37, 0x88, 0x50, 0x68, 0x1e, 0xf3, SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error)
0x48, 0xb1, 0x48, 0x51, 0x4b, 0x2f, 0xa4, 0x90, 0x74, 0x61, 0x03, 0xf7, 0x8e, 0xc2, 0x05, 0xa3, }
0xb5, 0x5e, 0xa5, 0x6f, 0x79, 0xf7, 0x18, 0x77, 0xb9, 0x32, 0x38, 0x15, 0x7c, 0x41, 0xeb, 0xbd,
0x4a, 0xbf, 0xee, 0xa5, 0x90, 0x7c, 0x07, 0x5b, 0x58, 0xc5, 0xc4, 0x79, 0x38, 0x9e, 0x9d, 0xfb, type chatClient struct {
0x0b, 0x46, 0x1b, 0xba, 0x6d, 0x81, 0x25, 0xaf, 0x60, 0xd3, 0x30, 0xa7, 0xfe, 0x98, 0xbd, 0xf5, cc *grpc.ClientConn
0xde, 0xd0, 0xa6, 0x2e, 0xcb, 0x93, 0xa4, 0x07, 0xed, 0xe4, 0x3a, 0xa3, 0x0f, 0x31, 0xa3, 0x1b, }
0xfa, 0xac, 0x2c, 0x85, 0x15, 0x43, 0x26, 0x65, 0xc8, 0x23, 0x5d, 0xd1, 0x32, 0x15, 0x19, 0x0a,
0x2b, 0x2e, 0x62, 0x26, 0x7c, 0x15, 0xf2, 0xc8, 0x19, 0x50, 0xd0, 0xe7, 0x64, 0x29, 0xb2, 0x07, func NewChatClient(cc *grpc.ClientConn) ChatClient {
0x75, 0x57, 0x06, 0xce, 0x80, 0xb6, 0xf5, 0x9a, 0x01, 0xc8, 0x8e, 0xf8, 0x8c, 0x45, 0xb4, 0x63, return &chatClient{cc}
0x58, 0x0d, 0x74, 0xb7, 0xe9, 0x74, 0x1e, 0x46, 0xcc, 0x89, 0xa6, 0x9c, 0x6e, 0x26, 0xdd, 0x56, }
0x14, 0xce, 0xe6, 0x22, 0xc6, 0xce, 0x92, 0x6e, 0x99, 0x89, 0x26, 0x90, 0x7c, 0x05, 0x70, 0x39,
0xf7, 0xd5, 0x94, 0x8b, 0x85, 0x33, 0xa0, 0xdb, 0xfa, 0xaa, 0x19, 0x86, 0x7c, 0x09, 0xad, 0x53, func (c *chatClient) GetMaxAndMinSeq(ctx context.Context, in *GetMaxAndMinSeqReq, opts ...grpc.CallOption) (*GetMaxAndMinSeqResp, error) {
0x2e, 0xc6, 0xec, 0x4d, 0x28, 0x15, 0xdd, 0xe9, 0x59, 0xfd, 0x96, 0xb7, 0x22, 0xf4, 0x2c, 0xe6, out := new(GetMaxAndMinSeqResp)
0x21, 0x8b, 0x94, 0xb9, 0xeb, 0xae, 0x39, 0x39, 0x43, 0xd9, 0xff, 0x58, 0xb0, 0x6f, 0xdc, 0x30, err := grpc.Invoke(ctx, "/pbChat.Chat/GetMaxAndMinSeq", in, out, c.cc, opts...)
0xe2, 0x97, 0x37, 0xf2, 0xfa, 0x93, 0xd8, 0x82, 0x42, 0x13, 0x6b, 0x86, 0x6c, 0x99, 0xb8, 0x22, if err != nil {
0x85, 0x39, 0xc3, 0xd4, 0xd7, 0x1b, 0xa6, 0xf1, 0x94, 0x61, 0x9a, 0xcf, 0x33, 0xcc, 0xc6, 0x33, return nil, err
0x0c, 0xd3, 0x7a, 0xd2, 0x30, 0xf0, 0xa4, 0x61, 0xda, 0x8f, 0x18, 0xa6, 0x93, 0x35, 0xcc, 0xa7, }
0xb4, 0x46, 0x41, 0xfc, 0x9d, 0xb2, 0xf8, 0xbf, 0xc3, 0xd6, 0xe5, 0xcd, 0x7c, 0xee, 0x32, 0x29, return out, nil
0xfd, 0x80, 0x79, 0x6c, 0x89, 0xda, 0xbe, 0x95, 0x4c, 0xac, 0x34, 0x37, 0xc8, 0xe8, 0xb4, 0x7c, }
0xcd, 0x82, 0x30, 0xd2, 0xaa, 0x6b, 0x9d, 0x0c, 0x36, 0x3e, 0x59, 0x9e, 0x44, 0x13, 0x2d, 0xbb,
0xe5, 0x25, 0xa8, 0x38, 0x93, 0x5a, 0x69, 0x26, 0xf6, 0xdf, 0x15, 0xd8, 0xce, 0x5d, 0x40, 0xc6, func (c *chatClient) PullMessage(ctx context.Context, in *PullMessageReq, opts ...grpc.CallOption) (*PullMessageResp, error) {
0xf8, 0xbd, 0x27, 0x42, 0x1c, 0xf3, 0x09, 0xd3, 0x57, 0xa8, 0x7b, 0x29, 0xc4, 0x73, 0x4e, 0x84, out := new(PullMessageResp)
0x70, 0x65, 0x90, 0xfa, 0xce, 0x20, 0xe4, 0x5d, 0xff, 0x3d, 0x9a, 0x2b, 0x39, 0xdf, 0x20, 0xcd, err := grpc.Invoke(ctx, "/pbChat.Chat/PullMessage", in, out, c.cc, opts...)
0x87, 0xd1, 0xca, 0x74, 0x09, 0x22, 0x3f, 0xc1, 0xe6, 0x30, 0x8c, 0x82, 0x39, 0xc3, 0x6f, 0xc3, if err != nil {
0x76, 0xf5, 0x9e, 0xd5, 0x6f, 0x1f, 0xed, 0x1d, 0x98, 0x1c, 0x3d, 0x38, 0xf3, 0xd5, 0x35, 0x13, return nil, err
0xa7, 0x5c, 0x2c, 0x7c, 0xe5, 0xe5, 0x4b, 0xc9, 0x8f, 0xd0, 0x39, 0x13, 0xfc, 0x26, 0x4e, 0xb7, }
0x36, 0x1e, 0xd9, 0x9a, 0xab, 0xb4, 0x17, 0xf0, 0x32, 0xf3, 0xa9, 0xaf, 0x3f, 0x0c, 0xd9, 0x12, return out, nil
0x9f, 0xe8, 0x63, 0x43, 0x2f, 0x0c, 0xb0, 0x5a, 0x36, 0x15, 0x85, 0xa6, 0x34, 0x7d, 0xa8, 0xd5, }
0xb3, 0xf0, 0x61, 0x25, 0xd0, 0x3e, 0x07, 0x72, 0xc6, 0x94, 0xeb, 0xbf, 0xff, 0x25, 0x9a, 0x98,
0xef, 0xfe, 0x5f, 0x27, 0xd9, 0x77, 0xf0, 0xa2, 0xd4, 0xef, 0x73, 0xa8, 0x65, 0x9f, 0x40, 0x27, func (c *chatClient) PullMessageBySeqList(ctx context.Context, in *PullMessageBySeqListReq, opts ...grpc.CallOption) (*PullMessageResp, error) {
0x3b, 0x55, 0xb2, 0x05, 0xd5, 0xfb, 0xeb, 0x57, 0x9d, 0x01, 0xf9, 0x16, 0x6a, 0xfa, 0xfb, 0xab, out := new(PullMessageResp)
0x5a, 0x89, 0xdd, 0x54, 0x09, 0x8c, 0x0a, 0x23, 0x83, 0x5e, 0xb6, 0xff, 0xad, 0x42, 0xeb, 0x9e, err := grpc.Invoke(ctx, "/pbChat.Chat/PullMessageBySeqList", in, out, c.cc, opts...)
0xfb, 0x98, 0x68, 0x4b, 0xa3, 0xc8, 0xca, 0x47, 0x51, 0x21, 0x3c, 0x6a, 0x6b, 0xc2, 0x43, 0xdc, if err != nil {
0x6a, 0x17, 0x38, 0x03, 0x9d, 0x72, 0x2d, 0x2f, 0x4b, 0x65, 0x83, 0xb3, 0x91, 0x0f, 0xce, 0x1d, return nil, err
0xb0, 0x70, 0x22, 0x4d, 0x3d, 0x11, 0xab, 0x18, 0x98, 0x1b, 0x85, 0xc0, 0xfc, 0x1e, 0x76, 0x4c, }
0xb2, 0x65, 0x62, 0xc1, 0xa4, 0x59, 0x89, 0x7f, 0x20, 0x42, 0xe1, 0x79, 0x11, 0xda, 0x5e, 0x17, return out, nil
0xa1, 0x99, 0xa8, 0xe9, 0x94, 0xa3, 0x46, 0x01, 0xe0, 0x16, 0x57, 0x06, 0xe8, 0xc3, 0x3d, 0xa8, }
0x2b, 0xfd, 0x3b, 0x69, 0xc6, 0x6f, 0x00, 0x76, 0xe1, 0x65, 0x17, 0x66, 0x28, 0x72, 0x00, 0xcd,
0x85, 0x0c, 0x06, 0xbe, 0xf2, 0xb5, 0x0e, 0xf8, 0xf2, 0x38, 0xfe, 0xe9, 0x09, 0x17, 0x57, 0x72, func (c *chatClient) SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgResp, error) {
0x32, 0x43, 0xd1, 0x71, 0xcd, 0x4b, 0x8b, 0xec, 0xbf, 0x2a, 0x38, 0xfc, 0xe4, 0xd8, 0x8f, 0xb2, out := new(SendMsgResp)
0xeb, 0x2b, 0xd8, 0xf4, 0xd8, 0xd2, 0x99, 0xb0, 0x48, 0x85, 0xd3, 0x90, 0x89, 0x44, 0xff, 0x3c, err := grpc.Invoke(ctx, "/pbChat.Chat/SendMsg", in, out, c.cc, opts...)
0x59, 0xd4, 0xb8, 0x56, 0xd6, 0xb8, 0x30, 0xa1, 0x7a, 0x69, 0x42, 0xa8, 0xac, 0x4c, 0x95, 0x6d, if err != nil {
0x18, 0x65, 0x53, 0x7c, 0xf4, 0x67, 0x15, 0x6a, 0x68, 0x6b, 0xf2, 0x2b, 0x6c, 0x17, 0x9e, 0x21, return nil, err
0xe9, 0xde, 0x87, 0x4f, 0xe9, 0xbd, 0x77, 0xbf, 0x58, 0xbb, 0x26, 0x63, 0xf2, 0x33, 0xb4, 0x33, }
0x89, 0x44, 0xf6, 0xd3, 0xda, 0xfc, 0x4f, 0x42, 0xf7, 0xe5, 0x83, 0xbc, 0x8c, 0xc9, 0x25, 0xec, return out, nil
0x3d, 0x94, 0x68, 0xe4, 0xeb, 0x07, 0x36, 0x64, 0xf3, 0x6e, 0x7d, 0xc7, 0x23, 0x68, 0x26, 0x6a, }
0x11, 0x92, 0xd6, 0xac, 0x5c, 0xd3, 0x7d, 0x51, 0xe2, 0x64, 0xfc, 0xae, 0xa1, 0xff, 0xd9, 0xfe,
0xf0, 0x5f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x9c, 0x2f, 0xc4, 0xa9, 0x12, 0x0b, 0x00, 0x00, // Server API for Chat service
type ChatServer interface {
GetMaxAndMinSeq(context.Context, *GetMaxAndMinSeqReq) (*GetMaxAndMinSeqResp, error)
PullMessage(context.Context, *PullMessageReq) (*PullMessageResp, error)
PullMessageBySeqList(context.Context, *PullMessageBySeqListReq) (*PullMessageResp, error)
SendMsg(context.Context, *SendMsgReq) (*SendMsgResp, error)
}
func RegisterChatServer(s *grpc.Server, srv ChatServer) {
s.RegisterService(&_Chat_serviceDesc, srv)
}
func _Chat_GetMaxAndMinSeq_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetMaxAndMinSeqReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ChatServer).GetMaxAndMinSeq(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pbChat.Chat/GetMaxAndMinSeq",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ChatServer).GetMaxAndMinSeq(ctx, req.(*GetMaxAndMinSeqReq))
}
return interceptor(ctx, in, info, handler)
}
func _Chat_PullMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PullMessageReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ChatServer).PullMessage(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pbChat.Chat/PullMessage",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ChatServer).PullMessage(ctx, req.(*PullMessageReq))
}
return interceptor(ctx, in, info, handler)
}
func _Chat_PullMessageBySeqList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PullMessageBySeqListReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ChatServer).PullMessageBySeqList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pbChat.Chat/PullMessageBySeqList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ChatServer).PullMessageBySeqList(ctx, req.(*PullMessageBySeqListReq))
}
return interceptor(ctx, in, info, handler)
}
func _Chat_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.(ChatServer).SendMsg(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pbChat.Chat/SendMsg",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ChatServer).SendMsg(ctx, req.(*SendMsgReq))
}
return interceptor(ctx, in, info, handler)
}
var _Chat_serviceDesc = grpc.ServiceDesc{
ServiceName: "pbChat.Chat",
HandlerType: (*ChatServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetMaxAndMinSeq",
Handler: _Chat_GetMaxAndMinSeq_Handler,
},
{
MethodName: "PullMessage",
Handler: _Chat_PullMessage_Handler,
},
{
MethodName: "PullMessageBySeqList",
Handler: _Chat_PullMessageBySeqList_Handler,
},
{
MethodName: "SendMsg",
Handler: _Chat_SendMsg_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "chat/chat.proto",
}
func init() { proto.RegisterFile("chat/chat.proto", fileDescriptor_chat_e46047b47969b559) }
var fileDescriptor_chat_e46047b47969b559 = []byte{
// 766 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x56, 0xcd, 0x4e, 0xdb, 0x4a,
0x14, 0x56, 0xec, 0x38, 0x81, 0x13, 0x42, 0xb8, 0x03, 0x02, 0x2b, 0x77, 0x71, 0x73, 0x2d, 0xee,
0x15, 0xea, 0x22, 0x91, 0xe8, 0xa6, 0x6a, 0xd5, 0x4a, 0x0d, 0x09, 0x28, 0x15, 0x86, 0xd4, 0x81,
0x4d, 0x37, 0xc8, 0xc4, 0x83, 0x63, 0x25, 0xfe, 0xc9, 0xcc, 0x84, 0x9f, 0x4d, 0x9f, 0xa3, 0x2f,
0xd4, 0x87, 0xe9, 0x43, 0x54, 0xaa, 0x66, 0xc6, 0x0e, 0x93, 0x18, 0x10, 0x6a, 0x25, 0x36, 0x28,
0xdf, 0x37, 0xe7, 0xf7, 0x3b, 0x67, 0xc6, 0x40, 0x6d, 0x38, 0x72, 0x59, 0x8b, 0xff, 0x69, 0x26,
0x24, 0x66, 0x31, 0x2a, 0x25, 0x97, 0x07, 0x23, 0x97, 0xd5, 0xff, 0x3d, 0x4d, 0x70, 0x74, 0xd1,
0xb3, 0x5b, 0xc9, 0xd8, 0x6f, 0x89, 0xa3, 0x16, 0xf5, 0xc6, 0x17, 0x37, 0xb4, 0x75, 0x43, 0xa5,
0xa9, 0x35, 0x83, 0x8a, 0x4d, 0xfd, 0x8e, 0xcb, 0xdc, 0xb3, 0xd8, 0xfe, 0x8c, 0xb6, 0xc0, 0x60,
0xf1, 0x18, 0x47, 0x66, 0xa1, 0x51, 0xd8, 0x5b, 0x75, 0x24, 0x40, 0x0d, 0xa8, 0xc4, 0x09, 0x26,
0x2e, 0x0b, 0xe2, 0xa8, 0xd7, 0x31, 0x35, 0x71, 0xa6, 0x52, 0xa8, 0x09, 0xe5, 0x50, 0x86, 0x31,
0xf5, 0x46, 0x61, 0xaf, 0xb2, 0xbf, 0xd5, 0x8c, 0x79, 0xee, 0x20, 0xbc, 0xa0, 0xde, 0xb8, 0x99,
0xa6, 0x70, 0x32, 0x23, 0xeb, 0xbd, 0x92, 0xb6, 0xd3, 0x56, 0xdd, 0x0b, 0xcf, 0x71, 0x1f, 0x42,
0xad, 0x3f, 0xa3, 0x23, 0xb5, 0xf2, 0x06, 0x54, 0x4e, 0x95, 0x1a, 0x65, 0xfd, 0x2a, 0xa5, 0x26,
0xd1, 0x9e, 0x93, 0xe4, 0x2b, 0xac, 0xf7, 0x67, 0x93, 0x89, 0x8d, 0x29, 0x75, 0x7d, 0xec, 0xe0,
0x29, 0xda, 0x86, 0xd2, 0x39, 0xc5, 0x64, 0x1e, 0x3e, 0x45, 0xa8, 0x0e, 0x2b, 0x03, 0x3c, 0x6d,
0x63, 0x3f, 0x88, 0x44, 0x68, 0xdd, 0x99, 0x63, 0xee, 0x33, 0xc0, 0xd3, 0x6e, 0xe4, 0x09, 0x61,
0x74, 0x27, 0x45, 0xcb, 0xf5, 0x16, 0x73, 0xf5, 0x5a, 0x3f, 0x0a, 0xbc, 0x4b, 0xa5, 0x00, 0x9a,
0x20, 0x13, 0xca, 0x5d, 0x42, 0x0e, 0x62, 0x0f, 0x8b, 0x12, 0x0c, 0x27, 0x83, 0x3c, 0x4f, 0x97,
0x10, 0x9b, 0xfa, 0xe9, 0x78, 0x52, 0xc4, 0x79, 0xdb, 0xbd, 0x1d, 0xe0, 0x69, 0x96, 0x5f, 0x22,
0xc1, 0x07, 0x11, 0xe7, 0x8b, 0x29, 0x2f, 0x10, 0x7a, 0x0b, 0xd5, 0x41, 0x10, 0xf9, 0x13, 0xcc,
0x7b, 0xe3, 0xe1, 0x8c, 0x86, 0x2e, 0xb4, 0x92, 0x3b, 0xd5, 0x3c, 0x72, 0xd9, 0x08, 0x93, 0xc3,
0x98, 0x84, 0x2e, 0x73, 0x16, 0x4d, 0xd1, 0x1b, 0x58, 0x3b, 0x22, 0xf1, 0x2c, 0xc9, 0x5c, 0x4b,
0x4f, 0xb8, 0x2e, 0x58, 0x5a, 0x21, 0xec, 0x28, 0xad, 0xb6, 0xef, 0x06, 0x78, 0x7a, 0x1c, 0x50,
0xf6, 0x94, 0xe8, 0x4b, 0x02, 0x6a, 0xf9, 0x81, 0x9b, 0x50, 0xa6, 0x32, 0x8e, 0xa9, 0x37, 0xf4,
0x3d, 0xdd, 0xc9, 0xa0, 0x75, 0x02, 0xe8, 0x08, 0x33, 0xdb, 0xbd, 0xfd, 0x18, 0x79, 0xb2, 0xef,
0x3f, 0xca, 0x64, 0xdd, 0xc0, 0x66, 0x2e, 0xde, 0x4b, 0x4c, 0xcb, 0xea, 0xc2, 0x9a, 0xaa, 0x2a,
0x5a, 0x07, 0x6d, 0x5e, 0xbe, 0xd6, 0xeb, 0xa0, 0xff, 0xa0, 0x28, 0xfa, 0xd7, 0xc4, 0x24, 0xfe,
0xca, 0x26, 0x61, 0x53, 0x3f, 0x1d, 0x83, 0x38, 0xb6, 0x7e, 0x6a, 0xb0, 0x3a, 0xe7, 0xe4, 0xca,
0x46, 0xde, 0xbd, 0x0e, 0x12, 0x71, 0xde, 0xc1, 0xc3, 0xeb, 0xb9, 0x04, 0x29, 0xe2, 0x6d, 0x72,
0x67, 0x12, 0x87, 0xa2, 0x6a, 0xc3, 0xc9, 0x20, 0x57, 0xee, 0x20, 0x8e, 0x18, 0x8e, 0xd8, 0xd9,
0x5d, 0x82, 0x45, 0xed, 0x86, 0xa3, 0x52, 0xdc, 0x62, 0x80, 0xc9, 0xb5, 0xd8, 0x82, 0x5e, 0xc7,
0x34, 0xa4, 0xb6, 0x0a, 0xc5, 0xa3, 0xa7, 0x0e, 0x66, 0x49, 0x9c, 0x66, 0x10, 0x6d, 0x80, 0xce,
0x15, 0x29, 0x0b, 0x45, 0xf8, 0x4f, 0x79, 0x11, 0x23, 0xef, 0x2c, 0x08, 0xb1, 0xb9, 0x92, 0x5d,
0x44, 0x89, 0xd1, 0x2b, 0xd8, 0xe0, 0xbf, 0x31, 0xe9, 0x4f, 0x5c, 0x76, 0x15, 0x93, 0xb0, 0xd7,
0x31, 0x57, 0x45, 0x41, 0x39, 0x1e, 0xfd, 0x0f, 0xeb, 0x92, 0x3b, 0x09, 0x86, 0xe3, 0x13, 0x37,
0xc4, 0x26, 0x88, 0xd4, 0x4b, 0x2c, 0xda, 0x85, 0xaa, 0x64, 0x0e, 0xdd, 0x21, 0x3e, 0x77, 0x8e,
0xcd, 0x8a, 0x30, 0x5b, 0x24, 0x85, 0x0a, 0x93, 0x00, 0x47, 0x4c, 0xf6, 0xb8, 0x26, 0x7b, 0x54,
0x28, 0x8b, 0x01, 0x70, 0x17, 0x9b, 0xfa, 0x7c, 0x0f, 0x5f, 0xea, 0x11, 0xfe, 0x5e, 0xe0, 0xe2,
0xa7, 0x69, 0x7f, 0x6b, 0x5d, 0x77, 0xa1, 0xea, 0xe0, 0x69, 0xcf, 0xc3, 0x11, 0x0b, 0xae, 0x02,
0x4c, 0xd2, 0xf9, 0x2f, 0x92, 0xcb, 0x33, 0x2e, 0xe6, 0x67, 0xbc, 0xa4, 0x90, 0x91, 0x53, 0x88,
0x4f, 0x96, 0x66, 0x93, 0x2d, 0xc9, 0xc9, 0x66, 0x78, 0xff, 0x9b, 0x06, 0x45, 0xbe, 0xd6, 0xe8,
0x13, 0xd4, 0x96, 0xae, 0x21, 0xaa, 0xcf, 0x1f, 0x9f, 0xdc, 0x7d, 0xaf, 0xff, 0xfd, 0xe8, 0x19,
0x4d, 0xd0, 0x07, 0xa8, 0x28, 0x2f, 0x12, 0xda, 0xce, 0x6c, 0x17, 0x3f, 0x09, 0xf5, 0x9d, 0x07,
0x79, 0x9a, 0xa0, 0x3e, 0x6c, 0x3d, 0xf4, 0xa2, 0xa1, 0x7f, 0x1e, 0x70, 0x50, 0xdf, 0xbb, 0xc7,
0x23, 0xee, 0x43, 0x39, 0x9d, 0x16, 0x42, 0x99, 0xcd, 0xfd, 0xd6, 0xd4, 0x37, 0x73, 0x1c, 0x4d,
0xda, 0xb5, 0x2f, 0xd5, 0xa6, 0xf8, 0xcf, 0xe0, 0x9d, 0x3c, 0xbc, 0x2c, 0x89, 0xcf, 0xfe, 0xeb,
0x5f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x48, 0x7f, 0xf6, 0xd7, 0x34, 0x08, 0x00, 0x00,
} }

Write Preview
Loading…
Cancel
Save