1 Star 0 Fork 0

nggs/micro

加入 Gitee
与超过 1400万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
rpc.pb.go 45.31 KB
一键复制 编辑 原始数据 按行查看 历史
李文建 提交于 2020-04-05 00:11 +08:00 . 整合其他模块代码
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: rpc.proto
package rpc
import (
fmt "fmt"
actor "gitee.com/nggs/protoactor-go/actor"
proto "github.com/gogo/protobuf/proto"
io "io"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// 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.GoGoProtoPackageIsVersion2 // please upgrade the proto package
//测试枚举2
type E_Test int32
const (
E_Test_E_Test_ E_Test = 0
//1
E_Test_E_Test_1 E_Test = 1
//2
E_Test_E_Test_2 E_Test = 2
)
var E_Test_name = map[int32]string{
0: "E_Test_",
1: "E_Test_1",
2: "E_Test_2",
}
var E_Test_value = map[string]int32{
"E_Test_": 0,
"E_Test_1": 1,
"E_Test_2": 2,
}
func (x E_Test) String() string {
return proto.EnumName(E_Test_name, int32(x))
}
func (E_Test) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{0}
}
//测试枚举2
//@enable_0=true
type E_Enable0 int32
const (
E_Enable0_E_Enable0_ E_Enable0 = 0
E_Enable0_E_Enable0_1 E_Enable0 = 1
)
var E_Enable0_name = map[int32]string{
0: "E_Enable0_",
1: "E_Enable0_1",
}
var E_Enable0_value = map[string]int32{
"E_Enable0_": 0,
"E_Enable0_1": 1,
}
func (x E_Enable0) String() string {
return proto.EnumName(E_Enable0_name, int32(x))
}
func (E_Enable0) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{1}
}
//消息中的枚举
type EnumTestMsg_E_Test int32
const (
EnumTestMsg__ EnumTestMsg_E_Test = 0
//1
EnumTestMsg__1 EnumTestMsg_E_Test = 1
)
var EnumTestMsg_E_Test_name = map[int32]string{
0: "_",
1: "_1",
}
var EnumTestMsg_E_Test_value = map[string]int32{
"_": 0,
"_1": 1,
}
func (x EnumTestMsg_E_Test) String() string {
return proto.EnumName(EnumTestMsg_E_Test_name, int32(x))
}
func (EnumTestMsg_E_Test) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{0, 0}
}
///消息中的枚举2
//@enable_0
type EnumTestMsg_E_Enable0 int32
const (
EnumTestMsg_E_Enable0_ EnumTestMsg_E_Enable0 = 0
//OK
EnumTestMsg_E_Enable0_OK EnumTestMsg_E_Enable0 = 1
)
var EnumTestMsg_E_Enable0_name = map[int32]string{
0: "E_Enable0_",
1: "E_Enable0_OK",
}
var EnumTestMsg_E_Enable0_value = map[string]int32{
"E_Enable0_": 0,
"E_Enable0_OK": 1,
}
func (x EnumTestMsg_E_Enable0) String() string {
return proto.EnumName(EnumTestMsg_E_Enable0_name, int32(x))
}
func (EnumTestMsg_E_Enable0) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{0, 1}
}
//@can_ignore
type EnumTestMsg struct {
}
func (m *EnumTestMsg) Reset() { *m = EnumTestMsg{} }
func (m *EnumTestMsg) String() string { return proto.CompactTextString(m) }
func (*EnumTestMsg) ProtoMessage() {}
func (*EnumTestMsg) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{0}
}
func (m *EnumTestMsg) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *EnumTestMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_EnumTestMsg.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *EnumTestMsg) XXX_Merge(src proto.Message) {
xxx_messageInfo_EnumTestMsg.Merge(m, src)
}
func (m *EnumTestMsg) XXX_Size() int {
return m.Size()
}
func (m *EnumTestMsg) XXX_DiscardUnknown() {
xxx_messageInfo_EnumTestMsg.DiscardUnknown(m)
}
var xxx_messageInfo_EnumTestMsg proto.InternalMessageInfo
//@msg=1
//@response=S2C_Pong
//@request_timeout=5
type C2S_Ping struct {
PID *actor.PID `protobuf:"bytes,1,opt,name=PID,proto3" json:"PID,omitempty"`
}
func (m *C2S_Ping) Reset() { *m = C2S_Ping{} }
func (m *C2S_Ping) String() string { return proto.CompactTextString(m) }
func (*C2S_Ping) ProtoMessage() {}
func (*C2S_Ping) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{1}
}
func (m *C2S_Ping) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_Ping.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *C2S_Ping) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_Ping.Merge(m, src)
}
func (m *C2S_Ping) XXX_Size() int {
return m.Size()
}
func (m *C2S_Ping) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_Ping.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_Ping proto.InternalMessageInfo
func (m *C2S_Ping) GetPID() *actor.PID {
if m != nil {
return m.PID
}
return nil
}
//@msg=2
type S2C_Pong struct {
PID *actor.PID `protobuf:"bytes,1,opt,name=PID,proto3" json:"PID,omitempty"`
}
func (m *S2C_Pong) Reset() { *m = S2C_Pong{} }
func (m *S2C_Pong) String() string { return proto.CompactTextString(m) }
func (*S2C_Pong) ProtoMessage() {}
func (*S2C_Pong) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{2}
}
func (m *S2C_Pong) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_Pong.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *S2C_Pong) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_Pong.Merge(m, src)
}
func (m *S2C_Pong) XXX_Size() int {
return m.Size()
}
func (m *S2C_Pong) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_Pong.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_Pong proto.InternalMessageInfo
func (m *S2C_Pong) GetPID() *actor.PID {
if m != nil {
return m.PID
}
return nil
}
//收到客户段的数据包
//@msg=7
type C2S_RecvMsgFromClient struct {
Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
}
func (m *C2S_RecvMsgFromClient) Reset() { *m = C2S_RecvMsgFromClient{} }
func (m *C2S_RecvMsgFromClient) String() string { return proto.CompactTextString(m) }
func (*C2S_RecvMsgFromClient) ProtoMessage() {}
func (*C2S_RecvMsgFromClient) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{3}
}
func (m *C2S_RecvMsgFromClient) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_RecvMsgFromClient) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_RecvMsgFromClient.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *C2S_RecvMsgFromClient) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_RecvMsgFromClient.Merge(m, src)
}
func (m *C2S_RecvMsgFromClient) XXX_Size() int {
return m.Size()
}
func (m *C2S_RecvMsgFromClient) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_RecvMsgFromClient.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_RecvMsgFromClient proto.InternalMessageInfo
func (m *C2S_RecvMsgFromClient) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
//发送数据包给客户端
//@msg=8
type C2S_SendMsgToClient struct {
Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
}
func (m *C2S_SendMsgToClient) Reset() { *m = C2S_SendMsgToClient{} }
func (m *C2S_SendMsgToClient) String() string { return proto.CompactTextString(m) }
func (*C2S_SendMsgToClient) ProtoMessage() {}
func (*C2S_SendMsgToClient) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{4}
}
func (m *C2S_SendMsgToClient) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_SendMsgToClient) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_SendMsgToClient.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *C2S_SendMsgToClient) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_SendMsgToClient.Merge(m, src)
}
func (m *C2S_SendMsgToClient) XXX_Size() int {
return m.Size()
}
func (m *C2S_SendMsgToClient) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_SendMsgToClient.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_SendMsgToClient proto.InternalMessageInfo
func (m *C2S_SendMsgToClient) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
type Test struct {
ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
}
func (m *Test) Reset() { *m = Test{} }
func (m *Test) String() string { return proto.CompactTextString(m) }
func (*Test) ProtoMessage() {}
func (*Test) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{5}
}
func (m *Test) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Test) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Test.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *Test) XXX_Merge(src proto.Message) {
xxx_messageInfo_Test.Merge(m, src)
}
func (m *Test) XXX_Size() int {
return m.Size()
}
func (m *Test) XXX_DiscardUnknown() {
xxx_messageInfo_Test.DiscardUnknown(m)
}
var xxx_messageInfo_Test proto.InternalMessageInfo
func (m *Test) GetID() int64 {
if m != nil {
return m.ID
}
return 0
}
func (m *Test) GetName() string {
if m != nil {
return m.Name
}
return ""
}
//广播数据包给客户端
//@msg=9
type C2S_BroadcastMsgToClient struct {
Include []int64 `protobuf:"varint,1,rep,packed,name=Include,proto3" json:"Include,omitempty"`
Exclude []int64 `protobuf:"varint,2,rep,packed,name=Exclude,proto3" json:"Exclude,omitempty"`
Data []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
T *Test `protobuf:"bytes,4,opt,name=T,proto3" json:"T,omitempty"`
Ts []*Test `protobuf:"bytes,5,rep,name=Ts,proto3" json:"Ts,omitempty"`
}
func (m *C2S_BroadcastMsgToClient) Reset() { *m = C2S_BroadcastMsgToClient{} }
func (m *C2S_BroadcastMsgToClient) String() string { return proto.CompactTextString(m) }
func (*C2S_BroadcastMsgToClient) ProtoMessage() {}
func (*C2S_BroadcastMsgToClient) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{6}
}
func (m *C2S_BroadcastMsgToClient) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_BroadcastMsgToClient) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_BroadcastMsgToClient.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *C2S_BroadcastMsgToClient) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_BroadcastMsgToClient.Merge(m, src)
}
func (m *C2S_BroadcastMsgToClient) XXX_Size() int {
return m.Size()
}
func (m *C2S_BroadcastMsgToClient) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_BroadcastMsgToClient.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_BroadcastMsgToClient proto.InternalMessageInfo
func (m *C2S_BroadcastMsgToClient) GetInclude() []int64 {
if m != nil {
return m.Include
}
return nil
}
func (m *C2S_BroadcastMsgToClient) GetExclude() []int64 {
if m != nil {
return m.Exclude
}
return nil
}
func (m *C2S_BroadcastMsgToClient) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
func (m *C2S_BroadcastMsgToClient) GetT() *Test {
if m != nil {
return m.T
}
return nil
}
func (m *C2S_BroadcastMsgToClient) GetTs() []*Test {
if m != nil {
return m.Ts
}
return nil
}
// 测试Response用
//@msg=11
type C2S_Response struct {
}
func (m *C2S_Response) Reset() { *m = C2S_Response{} }
func (m *C2S_Response) String() string { return proto.CompactTextString(m) }
func (*C2S_Response) ProtoMessage() {}
func (*C2S_Response) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{7}
}
func (m *C2S_Response) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_Response.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *C2S_Response) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_Response.Merge(m, src)
}
func (m *C2S_Response) XXX_Size() int {
return m.Size()
}
func (m *C2S_Response) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_Response.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_Response proto.InternalMessageInfo
// 测试Response用
//@msg=12
type S2C_Response struct {
}
func (m *S2C_Response) Reset() { *m = S2C_Response{} }
func (m *S2C_Response) String() string { return proto.CompactTextString(m) }
func (*S2C_Response) ProtoMessage() {}
func (*S2C_Response) Descriptor() ([]byte, []int) {
return fileDescriptor_77a6da22d6a3feb1, []int{8}
}
func (m *S2C_Response) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_Response.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *S2C_Response) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_Response.Merge(m, src)
}
func (m *S2C_Response) XXX_Size() int {
return m.Size()
}
func (m *S2C_Response) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_Response.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_Response proto.InternalMessageInfo
func init() {
proto.RegisterEnum("rpc.E_Test", E_Test_name, E_Test_value)
proto.RegisterEnum("rpc.E_Enable0", E_Enable0_name, E_Enable0_value)
proto.RegisterEnum("rpc.EnumTestMsg_E_Test", EnumTestMsg_E_Test_name, EnumTestMsg_E_Test_value)
proto.RegisterEnum("rpc.EnumTestMsg_E_Enable0", EnumTestMsg_E_Enable0_name, EnumTestMsg_E_Enable0_value)
proto.RegisterType((*EnumTestMsg)(nil), "rpc.EnumTestMsg")
proto.RegisterType((*C2S_Ping)(nil), "rpc.C2S_Ping")
proto.RegisterType((*S2C_Pong)(nil), "rpc.S2C_Pong")
proto.RegisterType((*C2S_RecvMsgFromClient)(nil), "rpc.C2S_RecvMsgFromClient")
proto.RegisterType((*C2S_SendMsgToClient)(nil), "rpc.C2S_SendMsgToClient")
proto.RegisterType((*Test)(nil), "rpc.Test")
proto.RegisterType((*C2S_BroadcastMsgToClient)(nil), "rpc.C2S_BroadcastMsgToClient")
proto.RegisterType((*C2S_Response)(nil), "rpc.C2S_Response")
proto.RegisterType((*S2C_Response)(nil), "rpc.S2C_Response")
}
func init() { proto.RegisterFile("rpc.proto", fileDescriptor_77a6da22d6a3feb1) }
var fileDescriptor_77a6da22d6a3feb1 = []byte{
// 423 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x92, 0xc1, 0x8e, 0xd3, 0x30,
0x10, 0x86, 0x6b, 0xa7, 0xdb, 0xdd, 0x4e, 0xab, 0x12, 0x19, 0xa1, 0x35, 0x08, 0x45, 0x55, 0x4e,
0xa5, 0xb0, 0x29, 0x2d, 0x6f, 0xb0, 0x4d, 0x90, 0x22, 0x54, 0x88, 0xd2, 0x70, 0x8e, 0xb2, 0xa9,
0x65, 0x55, 0x6a, 0xec, 0x28, 0xce, 0x22, 0x1e, 0x83, 0x13, 0xcf, 0xc4, 0x71, 0x8f, 0x1c, 0x51,
0xfb, 0x22, 0xc8, 0x4e, 0x37, 0x85, 0x4b, 0xf7, 0x36, 0x9f, 0xff, 0xdf, 0x93, 0xc9, 0xfc, 0x86,
0x7e, 0x55, 0xe6, 0x5e, 0x59, 0xc9, 0x5a, 0x12, 0xab, 0x2a, 0xf3, 0x57, 0x33, 0xbe, 0xad, 0x19,
0xf3, 0x72, 0x59, 0xcc, 0x04, 0xe7, 0x6a, 0x66, 0xa4, 0x2c, 0xaf, 0x65, 0x75, 0xc3, 0xe5, 0xcc,
0x14, 0xcd, 0x99, 0x6a, 0x6e, 0xb9, 0x5f, 0x61, 0x10, 0x88, 0xfb, 0x22, 0x61, 0xaa, 0x5e, 0x29,
0xee, 0x5e, 0x43, 0x2f, 0x48, 0x35, 0x90, 0x0b, 0x40, 0xa9, 0xdd, 0x21, 0x3d, 0xc0, 0xe9, 0xdc,
0x46, 0xee, 0x0d, 0xf4, 0x83, 0x34, 0x10, 0xd9, 0xdd, 0x8e, 0xbd, 0x27, 0x23, 0x80, 0x16, 0xb4,
0xc9, 0x86, 0xe1, 0x89, 0xbf, 0x7c, 0xb2, 0x91, 0x3b, 0x81, 0xab, 0xe5, 0x62, 0x9d, 0x46, 0x5b,
0xc1, 0xc9, 0x6b, 0xb0, 0xa2, 0xd0, 0xa7, 0x68, 0x8c, 0x26, 0x83, 0x05, 0x78, 0x66, 0x08, 0x2f,
0x0a, 0xfd, 0x58, 0x1f, 0x6b, 0xe7, 0x7a, 0xb1, 0x4c, 0x23, 0xf9, 0xa4, 0xf3, 0x2d, 0xbc, 0xd0,
0x3d, 0x63, 0x96, 0x7f, 0x5b, 0x29, 0xfe, 0xb1, 0x92, 0xc5, 0x72, 0xb7, 0x65, 0xa2, 0x26, 0x04,
0xba, 0x7e, 0x56, 0x67, 0xe6, 0xde, 0x30, 0x36, 0xb5, 0xfb, 0x06, 0x9e, 0x6b, 0xf3, 0x9a, 0x89,
0xcd, 0x4a, 0xf1, 0x44, 0x9e, 0xb1, 0x4e, 0xa1, 0x6b, 0xfe, 0x78, 0x04, 0xf8, 0xf8, 0x71, 0x2b,
0xc6, 0xa1, 0xaf, 0xbd, 0x9f, 0xb3, 0x82, 0x51, 0x3c, 0x46, 0x93, 0x7e, 0x6c, 0x6a, 0xf7, 0x27,
0x02, 0xaa, 0xfb, 0xde, 0x56, 0x32, 0xdb, 0xe4, 0x99, 0x59, 0x5a, 0xdb, 0x9c, 0xc2, 0x65, 0x28,
0xf2, 0xdd, 0xfd, 0x86, 0x51, 0x34, 0xb6, 0x26, 0x56, 0xfc, 0x88, 0x5a, 0x09, 0xbe, 0x37, 0x0a,
0x6e, 0x94, 0x23, 0xb6, 0x03, 0x59, 0xa7, 0x81, 0xc8, 0x35, 0xa0, 0x84, 0x76, 0xcd, 0x12, 0xfa,
0x9e, 0x0e, 0x58, 0x8f, 0x17, 0xa3, 0x84, 0xbc, 0x04, 0x9c, 0x28, 0x7a, 0x31, 0xb6, 0xfe, 0x57,
0x70, 0xa2, 0xdc, 0x11, 0x0c, 0x9b, 0xe5, 0xa8, 0x52, 0x0a, 0xc5, 0x34, 0xeb, 0xb5, 0x3e, 0xf2,
0x74, 0xde, 0x06, 0x3b, 0x80, 0xcb, 0xa6, 0xd2, 0xc9, 0x0d, 0xe1, 0xea, 0x08, 0x73, 0x1b, 0xfd,
0x43, 0x0b, 0x1b, 0x4f, 0xdf, 0x9d, 0x8b, 0xfc, 0x19, 0x0c, 0x4e, 0x3c, 0xb7, 0xd1, 0x2d, 0xfd,
0xb5, 0x77, 0xd0, 0xc3, 0xde, 0x41, 0x7f, 0xf6, 0x0e, 0xfa, 0x71, 0x70, 0x3a, 0x0f, 0x07, 0xa7,
0xf3, 0xfb, 0xe0, 0x74, 0xee, 0x7a, 0xe6, 0xa5, 0x7d, 0xf8, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x0f,
0x40, 0xe2, 0x38, 0xac, 0x02, 0x00, 0x00,
}
func (m *EnumTestMsg) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *EnumTestMsg) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
return i, nil
}
func (m *C2S_Ping) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *C2S_Ping) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.PID != nil {
dAtA[i] = 0xa
i++
i = encodeVarintRpc(dAtA, i, uint64(m.PID.Size()))
n1, err := m.PID.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
}
return i, nil
}
func (m *S2C_Pong) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *S2C_Pong) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.PID != nil {
dAtA[i] = 0xa
i++
i = encodeVarintRpc(dAtA, i, uint64(m.PID.Size()))
n2, err := m.PID.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n2
}
return i, nil
}
func (m *C2S_RecvMsgFromClient) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *C2S_RecvMsgFromClient) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Data) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintRpc(dAtA, i, uint64(len(m.Data)))
i += copy(dAtA[i:], m.Data)
}
return i, nil
}
func (m *C2S_SendMsgToClient) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *C2S_SendMsgToClient) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Data) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintRpc(dAtA, i, uint64(len(m.Data)))
i += copy(dAtA[i:], m.Data)
}
return i, nil
}
func (m *Test) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *Test) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.ID != 0 {
dAtA[i] = 0x8
i++
i = encodeVarintRpc(dAtA, i, uint64(m.ID))
}
if len(m.Name) > 0 {
dAtA[i] = 0x12
i++
i = encodeVarintRpc(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
return i, nil
}
func (m *C2S_BroadcastMsgToClient) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *C2S_BroadcastMsgToClient) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Include) > 0 {
dAtA4 := make([]byte, len(m.Include)*10)
var j3 int
for _, num1 := range m.Include {
num := uint64(num1)
for num >= 1<<7 {
dAtA4[j3] = uint8(uint64(num)&0x7f | 0x80)
num >>= 7
j3++
}
dAtA4[j3] = uint8(num)
j3++
}
dAtA[i] = 0xa
i++
i = encodeVarintRpc(dAtA, i, uint64(j3))
i += copy(dAtA[i:], dAtA4[:j3])
}
if len(m.Exclude) > 0 {
dAtA6 := make([]byte, len(m.Exclude)*10)
var j5 int
for _, num1 := range m.Exclude {
num := uint64(num1)
for num >= 1<<7 {
dAtA6[j5] = uint8(uint64(num)&0x7f | 0x80)
num >>= 7
j5++
}
dAtA6[j5] = uint8(num)
j5++
}
dAtA[i] = 0x12
i++
i = encodeVarintRpc(dAtA, i, uint64(j5))
i += copy(dAtA[i:], dAtA6[:j5])
}
if len(m.Data) > 0 {
dAtA[i] = 0x1a
i++
i = encodeVarintRpc(dAtA, i, uint64(len(m.Data)))
i += copy(dAtA[i:], m.Data)
}
if m.T != nil {
dAtA[i] = 0x22
i++
i = encodeVarintRpc(dAtA, i, uint64(m.T.Size()))
n7, err := m.T.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n7
}
if len(m.Ts) > 0 {
for _, msg := range m.Ts {
dAtA[i] = 0x2a
i++
i = encodeVarintRpc(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
return i, nil
}
func (m *C2S_Response) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *C2S_Response) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
return i, nil
}
func (m *S2C_Response) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *S2C_Response) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
return i, nil
}
func encodeVarintRpc(dAtA []byte, offset int, v uint64) int {
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return offset + 1
}
func (m *EnumTestMsg) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
return n
}
func (m *C2S_Ping) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.PID != nil {
l = m.PID.Size()
n += 1 + l + sovRpc(uint64(l))
}
return n
}
func (m *S2C_Pong) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.PID != nil {
l = m.PID.Size()
n += 1 + l + sovRpc(uint64(l))
}
return n
}
func (m *C2S_RecvMsgFromClient) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Data)
if l > 0 {
n += 1 + l + sovRpc(uint64(l))
}
return n
}
func (m *C2S_SendMsgToClient) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Data)
if l > 0 {
n += 1 + l + sovRpc(uint64(l))
}
return n
}
func (m *Test) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.ID != 0 {
n += 1 + sovRpc(uint64(m.ID))
}
l = len(m.Name)
if l > 0 {
n += 1 + l + sovRpc(uint64(l))
}
return n
}
func (m *C2S_BroadcastMsgToClient) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Include) > 0 {
l = 0
for _, e := range m.Include {
l += sovRpc(uint64(e))
}
n += 1 + sovRpc(uint64(l)) + l
}
if len(m.Exclude) > 0 {
l = 0
for _, e := range m.Exclude {
l += sovRpc(uint64(e))
}
n += 1 + sovRpc(uint64(l)) + l
}
l = len(m.Data)
if l > 0 {
n += 1 + l + sovRpc(uint64(l))
}
if m.T != nil {
l = m.T.Size()
n += 1 + l + sovRpc(uint64(l))
}
if len(m.Ts) > 0 {
for _, e := range m.Ts {
l = e.Size()
n += 1 + l + sovRpc(uint64(l))
}
}
return n
}
func (m *C2S_Response) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
return n
}
func (m *S2C_Response) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
return n
}
func sovRpc(x uint64) (n int) {
for {
n++
x >>= 7
if x == 0 {
break
}
}
return n
}
func sozRpc(x uint64) (n int) {
return sovRpc(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *EnumTestMsg) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: EnumTestMsg: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: EnumTestMsg: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_Ping) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: C2S_Ping: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_Ping: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PID", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.PID == nil {
m.PID = &actor.PID{}
}
if err := m.PID.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_Pong) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: S2C_Pong: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_Pong: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PID", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.PID == nil {
m.PID = &actor.PID{}
}
if err := m.PID.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_RecvMsgFromClient) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: C2S_RecvMsgFromClient: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_RecvMsgFromClient: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Data = append(m.Data[:0], dAtA[iNdEx:postIndex]...)
if m.Data == nil {
m.Data = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_SendMsgToClient) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: C2S_SendMsgToClient: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_SendMsgToClient: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Data = append(m.Data[:0], dAtA[iNdEx:postIndex]...)
if m.Data == nil {
m.Data = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *Test) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: Test: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: Test: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType)
}
m.ID = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_BroadcastMsgToClient) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: C2S_BroadcastMsgToClient: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_BroadcastMsgToClient: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType == 0 {
var v int64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Include = append(m.Include, v)
} else if wireType == 2 {
var packedLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
packedLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if packedLen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + packedLen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
var elementCount int
var count int
for _, integer := range dAtA[iNdEx:postIndex] {
if integer < 128 {
count++
}
}
elementCount = count
if elementCount != 0 && len(m.Include) == 0 {
m.Include = make([]int64, 0, elementCount)
}
for iNdEx < postIndex {
var v int64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Include = append(m.Include, v)
}
} else {
return fmt.Errorf("proto: wrong wireType = %d for field Include", wireType)
}
case 2:
if wireType == 0 {
var v int64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Exclude = append(m.Exclude, v)
} else if wireType == 2 {
var packedLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
packedLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if packedLen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + packedLen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
var elementCount int
var count int
for _, integer := range dAtA[iNdEx:postIndex] {
if integer < 128 {
count++
}
}
elementCount = count
if elementCount != 0 && len(m.Exclude) == 0 {
m.Exclude = make([]int64, 0, elementCount)
}
for iNdEx < postIndex {
var v int64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Exclude = append(m.Exclude, v)
}
} else {
return fmt.Errorf("proto: wrong wireType = %d for field Exclude", wireType)
}
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Data", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Data = append(m.Data[:0], dAtA[iNdEx:postIndex]...)
if m.Data == nil {
m.Data = []byte{}
}
iNdEx = postIndex
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field T", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.T == nil {
m.T = &Test{}
}
if err := m.T.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 5:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Ts", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthRpc
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthRpc
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Ts = append(m.Ts, &Test{})
if err := m.Ts[len(m.Ts)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_Response) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: C2S_Response: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_Response: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_Response) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowRpc
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: S2C_Response: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_Response: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := skipRpc(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthRpc
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipRpc(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpc
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
wireType := int(wire & 0x7)
switch wireType {
case 0:
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpc
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
return iNdEx, nil
case 1:
iNdEx += 8
return iNdEx, nil
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpc
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
length |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if length < 0 {
return 0, ErrInvalidLengthRpc
}
iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthRpc
}
return iNdEx, nil
case 3:
for {
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowRpc
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipRpc(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthRpc
}
}
return iNdEx, nil
case 4:
return iNdEx, nil
case 5:
iNdEx += 4
return iNdEx, nil
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
}
panic("unreachable")
}
var (
ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow")
)
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/nggs/micro.git
git@gitee.com:nggs/micro.git
nggs
micro
micro
bac99dff65eb

搜索帮助