Ai
1 Star 0 Fork 0

nggs/micro

Create your Gitee Account
Explore and code with more than 13.5 million developers,Free private repositories !:)
Sign up
文件
Clone or Download
protos.pb.go 139.90 KB
Copy Edit Raw Blame History
李文建 authored 2020-04-04 21:04 +08:00 . 移植microservice的代码
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208420942104211421242134214421542164217421842194220422142224223422442254226422742284229423042314232423342344235423642374238423942404241424242434244424542464247424842494250425142524253425442554256425742584259426042614262426342644265426642674268426942704271427242734274427542764277427842794280428142824283428442854286428742884289429042914292429342944295429642974298429943004301430243034304430543064307430843094310431143124313431443154316431743184319432043214322432343244325432643274328432943304331433243334334433543364337433843394340434143424343434443454346434743484349435043514352435343544355435643574358435943604361436243634364436543664367436843694370437143724373437443754376437743784379438043814382438343844385438643874388438943904391439243934394439543964397439843994400440144024403440444054406440744084409441044114412441344144415441644174418441944204421442244234424442544264427442844294430443144324433443444354436443744384439444044414442444344444445444644474448444944504451445244534454445544564457445844594460446144624463446444654466446744684469447044714472447344744475447644774478447944804481448244834484448544864487448844894490449144924493449444954496449744984499450045014502450345044505450645074508450945104511451245134514451545164517451845194520452145224523452445254526452745284529453045314532453345344535453645374538453945404541454245434544454545464547454845494550455145524553455445554556455745584559456045614562456345644565456645674568456945704571457245734574457545764577457845794580458145824583458445854586458745884589459045914592459345944595459645974598459946004601460246034604460546064607460846094610461146124613461446154616461746184619462046214622462346244625462646274628462946304631463246334634463546364637463846394640464146424643464446454646464746484649465046514652465346544655465646574658465946604661466246634664466546664667466846694670467146724673467446754676467746784679468046814682468346844685468646874688468946904691469246934694469546964697469846994700470147024703470447054706470747084709471047114712471347144715471647174718471947204721472247234724472547264727472847294730473147324733473447354736473747384739474047414742474347444745474647474748474947504751475247534754475547564757475847594760476147624763476447654766476747684769477047714772477347744775477647774778477947804781478247834784478547864787478847894790479147924793479447954796479747984799480048014802480348044805480648074808480948104811481248134814481548164817481848194820482148224823482448254826482748284829483048314832483348344835483648374838483948404841484248434844484548464847484848494850485148524853485448554856485748584859486048614862486348644865486648674868486948704871487248734874487548764877487848794880488148824883488448854886488748884889489048914892489348944895489648974898489949004901490249034904490549064907490849094910491149124913491449154916491749184919492049214922492349244925492649274928492949304931493249334934493549364937493849394940494149424943494449454946494749484949495049514952495349544955495649574958495949604961496249634964496549664967496849694970497149724973497449754976497749784979498049814982498349844985498649874988498949904991499249934994499549964997499849995000500150025003500450055006500750085009501050115012501350145015501650175018501950205021502250235024502550265027502850295030503150325033503450355036503750385039504050415042504350445045504650475048504950505051505250535054505550565057505850595060506150625063506450655066506750685069507050715072507350745075507650775078507950805081508250835084508550865087508850895090509150925093509450955096509750985099510051015102510351045105510651075108510951105111511251135114511551165117511851195120512151225123512451255126512751285129513051315132513351345135513651375138513951405141514251435144514551465147514851495150515151525153515451555156515751585159516051615162516351645165516651675168516951705171517251735174517551765177517851795180518151825183518451855186518751885189519051915192519351945195519651975198519952005201520252035204520552065207520852095210521152125213521452155216521752185219522052215222522352245225522652275228522952305231523252335234523552365237523852395240524152425243524452455246524752485249525052515252525352545255525652575258525952605261526252635264526552665267526852695270527152725273527452755276527752785279528052815282528352845285528652875288528952905291529252935294529552965297529852995300530153025303530453055306530753085309531053115312531353145315531653175318531953205321532253235324532553265327532853295330533153325333533453355336533753385339534053415342534353445345534653475348534953505351535253535354535553565357535853595360536153625363536453655366536753685369537053715372537353745375537653775378537953805381538253835384538553865387538853895390539153925393539453955396539753985399540054015402540354045405540654075408540954105411541254135414541554165417541854195420542154225423542454255426542754285429543054315432543354345435543654375438543954405441544254435444544554465447544854495450545154525453545454555456545754585459546054615462546354645465546654675468546954705471547254735474547554765477547854795480548154825483548454855486548754885489549054915492549354945495549654975498549955005501550255035504550555065507550855095510551155125513551455155516551755185519552055215522552355245525552655275528552955305531553255335534553555365537553855395540554155425543554455455546554755485549555055515552555355545555555655575558555955605561556255635564556555665567556855695570557155725573557455755576557755785579558055815582558355845585558655875588558955905591559255935594559555965597559855995600560156025603560456055606560756085609561056115612561356145615561656175618561956205621562256235624562556265627562856295630563156325633563456355636563756385639564056415642564356445645564656475648564956505651565256535654565556565657565856595660566156625663566456655666566756685669567056715672567356745675567656775678567956805681568256835684568556865687568856895690569156925693569456955696569756985699570057015702570357045705570657075708570957105711571257135714571557165717571857195720572157225723572457255726572757285729573057315732573357345735573657375738573957405741574257435744574557465747574857495750575157525753575457555756575757585759576057615762576357645765576657675768576957705771577257735774577557765777577857795780578157825783578457855786578757885789579057915792579357945795579657975798579958005801580258035804580558065807580858095810581158125813581458155816581758185819582058215822582358245825582658275828582958305831583258335834583558365837583858395840584158425843584458455846584758485849585058515852585358545855585658575858585958605861586258635864586558665867586858695870587158725873587458755876587758785879588058815882588358845885588658875888588958905891589258935894589558965897589858995900590159025903590459055906590759085909591059115912591359145915591659175918591959205921592259235924592559265927592859295930593159325933593459355936593759385939594059415942594359445945594659475948594959505951595259535954595559565957595859595960596159625963596459655966596759685969597059715972597359745975597659775978597959805981598259835984598559865987598859895990599159925993599459955996599759985999600060016002600360046005600660076008600960106011601260136014601560166017601860196020602160226023602460256026602760286029603060316032603360346035603660376038603960406041604260436044604560466047604860496050605160526053605460556056605760586059606060616062606360646065606660676068606960706071607260736074607560766077607860796080608160826083608460856086608760886089609060916092609360946095609660976098609961006101610261036104610561066107610861096110611161126113611461156116611761186119612061216122612361246125612661276128612961306131613261336134613561366137613861396140614161426143614461456146614761486149615061516152615361546155615661576158615961606161616261636164616561666167616861696170617161726173617461756176617761786179618061816182618361846185618661876188618961906191619261936194619561966197619861996200620162026203620462056206620762086209621062116212621362146215621662176218621962206221622262236224622562266227622862296230623162326233623462356236623762386239624062416242624362446245624662476248624962506251
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: protos.proto
package cluster
import (
bytes "bytes"
fmt "fmt"
actor "github.com/AsynkronIT/protoactor-go/actor"
proto "github.com/gogo/protobuf/proto"
io "io"
math "math"
reflect "reflect"
strconv "strconv"
strings "strings"
)
// 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
type ErrorCode int32
const (
EC_Success ErrorCode = 0
EC_Fail ErrorCode = 1
EC_ServiceGroupNotExist ErrorCode = 2
EC_ServiceInfoNotExist ErrorCode = 3
EC_MarshalInstanceFail ErrorCode = 4
EC_PutInstanceToEtcdFail ErrorCode = 5
EC_ServiceInstanceAlreadyExist ErrorCode = 6
EC_PutPayloadToEtcdFail ErrorCode = 7
)
var ErrorCode_name = map[int32]string{
0: "EC_Success",
1: "EC_Fail",
2: "EC_ServiceGroupNotExist",
3: "EC_ServiceInfoNotExist",
4: "EC_MarshalInstanceFail",
5: "EC_PutInstanceToEtcdFail",
6: "EC_ServiceInstanceAlreadyExist",
7: "EC_PutPayloadToEtcdFail",
}
var ErrorCode_value = map[string]int32{
"EC_Success": 0,
"EC_Fail": 1,
"EC_ServiceGroupNotExist": 2,
"EC_ServiceInfoNotExist": 3,
"EC_MarshalInstanceFail": 4,
"EC_PutInstanceToEtcdFail": 5,
"EC_ServiceInstanceAlreadyExist": 6,
"EC_PutPayloadToEtcdFail": 7,
}
func (ErrorCode) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{0}
}
type Error struct {
Code ErrorCode `protobuf:"varint,1,opt,name=Code,proto3,enum=cluster.ErrorCode" json:"Code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
}
func (m *Error) Reset() { *m = Error{} }
func (*Error) ProtoMessage() {}
func (*Error) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{0}
}
func (m *Error) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Error.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 *Error) XXX_Merge(src proto.Message) {
xxx_messageInfo_Error.Merge(m, src)
}
func (m *Error) XXX_Size() int {
return m.Size()
}
func (m *Error) XXX_DiscardUnknown() {
xxx_messageInfo_Error.DiscardUnknown(m)
}
var xxx_messageInfo_Error proto.InternalMessageInfo
func (m *Error) GetCode() ErrorCode {
if m != nil {
return m.Code
}
return EC_Success
}
func (m *Error) GetMessage() string {
if m != nil {
return m.Message
}
return ""
}
// 请求全局配置
//@response=S2C_GlobalConfig
type C2S_GlobalConfig struct {
}
func (m *C2S_GlobalConfig) Reset() { *m = C2S_GlobalConfig{} }
func (*C2S_GlobalConfig) ProtoMessage() {}
func (*C2S_GlobalConfig) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{1}
}
func (m *C2S_GlobalConfig) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_GlobalConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_GlobalConfig.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_GlobalConfig) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_GlobalConfig.Merge(m, src)
}
func (m *C2S_GlobalConfig) XXX_Size() int {
return m.Size()
}
func (m *C2S_GlobalConfig) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_GlobalConfig.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_GlobalConfig proto.InternalMessageInfo
// 请求全局配置回复
type S2C_GlobalConfig struct {
ConfigData []byte `protobuf:"bytes,1,opt,name=ConfigData,proto3" json:"ConfigData,omitempty"`
}
func (m *S2C_GlobalConfig) Reset() { *m = S2C_GlobalConfig{} }
func (*S2C_GlobalConfig) ProtoMessage() {}
func (*S2C_GlobalConfig) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{2}
}
func (m *S2C_GlobalConfig) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_GlobalConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_GlobalConfig.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_GlobalConfig) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_GlobalConfig.Merge(m, src)
}
func (m *S2C_GlobalConfig) XXX_Size() int {
return m.Size()
}
func (m *S2C_GlobalConfig) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_GlobalConfig.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_GlobalConfig proto.InternalMessageInfo
func (m *S2C_GlobalConfig) GetConfigData() []byte {
if m != nil {
return m.ConfigData
}
return nil
}
// 请求服务全局配置
type C2S_ServiceGlobalConfig struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
}
func (m *C2S_ServiceGlobalConfig) Reset() { *m = C2S_ServiceGlobalConfig{} }
func (*C2S_ServiceGlobalConfig) ProtoMessage() {}
func (*C2S_ServiceGlobalConfig) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{3}
}
func (m *C2S_ServiceGlobalConfig) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_ServiceGlobalConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_ServiceGlobalConfig.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_ServiceGlobalConfig) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_ServiceGlobalConfig.Merge(m, src)
}
func (m *C2S_ServiceGlobalConfig) XXX_Size() int {
return m.Size()
}
func (m *C2S_ServiceGlobalConfig) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_ServiceGlobalConfig.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_ServiceGlobalConfig proto.InternalMessageInfo
func (m *C2S_ServiceGlobalConfig) GetName() string {
if m != nil {
return m.Name
}
return ""
}
// 请求服务全局配置回复
type S2C_ServiceGlobalConfig struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
ConfigData []byte `protobuf:"bytes,2,opt,name=ConfigData,proto3" json:"ConfigData,omitempty"`
}
func (m *S2C_ServiceGlobalConfig) Reset() { *m = S2C_ServiceGlobalConfig{} }
func (*S2C_ServiceGlobalConfig) ProtoMessage() {}
func (*S2C_ServiceGlobalConfig) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{4}
}
func (m *S2C_ServiceGlobalConfig) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_ServiceGlobalConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_ServiceGlobalConfig.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_ServiceGlobalConfig) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_ServiceGlobalConfig.Merge(m, src)
}
func (m *S2C_ServiceGlobalConfig) XXX_Size() int {
return m.Size()
}
func (m *S2C_ServiceGlobalConfig) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_ServiceGlobalConfig.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_ServiceGlobalConfig proto.InternalMessageInfo
func (m *S2C_ServiceGlobalConfig) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
func (m *S2C_ServiceGlobalConfig) GetConfigData() []byte {
if m != nil {
return m.ConfigData
}
return nil
}
type ServiceInstance struct {
PID *actor.PID `protobuf:"bytes,1,opt,name=PID,proto3" json:"PID,omitempty"`
PprofAddr string `protobuf:"bytes,2,opt,name=PprofAddr,proto3" json:"PprofAddr,omitempty"`
Extra []byte `protobuf:"bytes,3,opt,name=Extra,proto3" json:"Extra,omitempty"`
}
func (m *ServiceInstance) Reset() { *m = ServiceInstance{} }
func (*ServiceInstance) ProtoMessage() {}
func (*ServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{5}
}
func (m *ServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *ServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_ServiceInstance.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 *ServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_ServiceInstance.Merge(m, src)
}
func (m *ServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *ServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_ServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_ServiceInstance proto.InternalMessageInfo
func (m *ServiceInstance) GetPID() *actor.PID {
if m != nil {
return m.PID
}
return nil
}
func (m *ServiceInstance) GetPprofAddr() string {
if m != nil {
return m.PprofAddr
}
return ""
}
func (m *ServiceInstance) GetExtra() []byte {
if m != nil {
return m.Extra
}
return nil
}
type ServiceInfo struct {
ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
ConfigData []byte `protobuf:"bytes,2,opt,name=ConfigData,proto3" json:"ConfigData,omitempty"`
Instance *ServiceInstance `protobuf:"bytes,3,opt,name=Instance,proto3" json:"Instance,omitempty"`
Payload int32 `protobuf:"varint,4,opt,name=Payload,proto3" json:"Payload,omitempty"`
}
func (m *ServiceInfo) Reset() { *m = ServiceInfo{} }
func (*ServiceInfo) ProtoMessage() {}
func (*ServiceInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{6}
}
func (m *ServiceInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_ServiceInfo.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 *ServiceInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_ServiceInfo.Merge(m, src)
}
func (m *ServiceInfo) XXX_Size() int {
return m.Size()
}
func (m *ServiceInfo) XXX_DiscardUnknown() {
xxx_messageInfo_ServiceInfo.DiscardUnknown(m)
}
var xxx_messageInfo_ServiceInfo proto.InternalMessageInfo
func (m *ServiceInfo) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
func (m *ServiceInfo) GetConfigData() []byte {
if m != nil {
return m.ConfigData
}
return nil
}
func (m *ServiceInfo) GetInstance() *ServiceInstance {
if m != nil {
return m.Instance
}
return nil
}
func (m *ServiceInfo) GetPayload() int32 {
if m != nil {
return m.Payload
}
return 0
}
// 请求服务信息
type C2S_ServiceInfo struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (m *C2S_ServiceInfo) Reset() { *m = C2S_ServiceInfo{} }
func (*C2S_ServiceInfo) ProtoMessage() {}
func (*C2S_ServiceInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{7}
}
func (m *C2S_ServiceInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_ServiceInfo.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_ServiceInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_ServiceInfo.Merge(m, src)
}
func (m *C2S_ServiceInfo) XXX_Size() int {
return m.Size()
}
func (m *C2S_ServiceInfo) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_ServiceInfo.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_ServiceInfo proto.InternalMessageInfo
func (m *C2S_ServiceInfo) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *C2S_ServiceInfo) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
// 请求服务信息回复
type S2C_ServiceInfo struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
Info *ServiceInfo `protobuf:"bytes,2,opt,name=Info,proto3" json:"Info,omitempty"`
}
func (m *S2C_ServiceInfo) Reset() { *m = S2C_ServiceInfo{} }
func (*S2C_ServiceInfo) ProtoMessage() {}
func (*S2C_ServiceInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{8}
}
func (m *S2C_ServiceInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_ServiceInfo.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_ServiceInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_ServiceInfo.Merge(m, src)
}
func (m *S2C_ServiceInfo) XXX_Size() int {
return m.Size()
}
func (m *S2C_ServiceInfo) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_ServiceInfo.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_ServiceInfo proto.InternalMessageInfo
func (m *S2C_ServiceInfo) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
func (m *S2C_ServiceInfo) GetInfo() *ServiceInfo {
if m != nil {
return m.Info
}
return nil
}
// 请求服务实例
type C2S_ServiceInstance struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (m *C2S_ServiceInstance) Reset() { *m = C2S_ServiceInstance{} }
func (*C2S_ServiceInstance) ProtoMessage() {}
func (*C2S_ServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{9}
}
func (m *C2S_ServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_ServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_ServiceInstance.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_ServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_ServiceInstance.Merge(m, src)
}
func (m *C2S_ServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *C2S_ServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_ServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_ServiceInstance proto.InternalMessageInfo
func (m *C2S_ServiceInstance) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *C2S_ServiceInstance) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
// 请求服务实例回复
type S2C_ServiceInstance struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
Instance *ServiceInstance `protobuf:"bytes,2,opt,name=Instance,proto3" json:"Instance,omitempty"`
}
func (m *S2C_ServiceInstance) Reset() { *m = S2C_ServiceInstance{} }
func (*S2C_ServiceInstance) ProtoMessage() {}
func (*S2C_ServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{10}
}
func (m *S2C_ServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_ServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_ServiceInstance.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_ServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_ServiceInstance.Merge(m, src)
}
func (m *S2C_ServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *S2C_ServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_ServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_ServiceInstance proto.InternalMessageInfo
func (m *S2C_ServiceInstance) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
func (m *S2C_ServiceInstance) GetInstance() *ServiceInstance {
if m != nil {
return m.Instance
}
return nil
}
// 请求上传服务实例
type C2S_PutServiceInstance struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
Instance *ServiceInstance `protobuf:"bytes,3,opt,name=Instance,proto3" json:"Instance,omitempty"`
}
func (m *C2S_PutServiceInstance) Reset() { *m = C2S_PutServiceInstance{} }
func (*C2S_PutServiceInstance) ProtoMessage() {}
func (*C2S_PutServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{11}
}
func (m *C2S_PutServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_PutServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_PutServiceInstance.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_PutServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_PutServiceInstance.Merge(m, src)
}
func (m *C2S_PutServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *C2S_PutServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_PutServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_PutServiceInstance proto.InternalMessageInfo
func (m *C2S_PutServiceInstance) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *C2S_PutServiceInstance) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
func (m *C2S_PutServiceInstance) GetInstance() *ServiceInstance {
if m != nil {
return m.Instance
}
return nil
}
// 请求上传服务实例回复
type S2C_PutServiceInstance struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
}
func (m *S2C_PutServiceInstance) Reset() { *m = S2C_PutServiceInstance{} }
func (*S2C_PutServiceInstance) ProtoMessage() {}
func (*S2C_PutServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{12}
}
func (m *S2C_PutServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_PutServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_PutServiceInstance.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_PutServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_PutServiceInstance.Merge(m, src)
}
func (m *S2C_PutServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *S2C_PutServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_PutServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_PutServiceInstance proto.InternalMessageInfo
func (m *S2C_PutServiceInstance) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
// 请求锁定服务坑位
type C2S_TryLockServicePosition struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
Instance *ServiceInstance `protobuf:"bytes,3,opt,name=Instance,proto3" json:"Instance,omitempty"`
}
func (m *C2S_TryLockServicePosition) Reset() { *m = C2S_TryLockServicePosition{} }
func (*C2S_TryLockServicePosition) ProtoMessage() {}
func (*C2S_TryLockServicePosition) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{13}
}
func (m *C2S_TryLockServicePosition) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_TryLockServicePosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_TryLockServicePosition.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_TryLockServicePosition) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_TryLockServicePosition.Merge(m, src)
}
func (m *C2S_TryLockServicePosition) XXX_Size() int {
return m.Size()
}
func (m *C2S_TryLockServicePosition) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_TryLockServicePosition.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_TryLockServicePosition proto.InternalMessageInfo
func (m *C2S_TryLockServicePosition) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *C2S_TryLockServicePosition) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
func (m *C2S_TryLockServicePosition) GetInstance() *ServiceInstance {
if m != nil {
return m.Instance
}
return nil
}
// 请求锁定服务坑位回复
type S2C_TryLockServicePosition struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
}
func (m *S2C_TryLockServicePosition) Reset() { *m = S2C_TryLockServicePosition{} }
func (*S2C_TryLockServicePosition) ProtoMessage() {}
func (*S2C_TryLockServicePosition) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{14}
}
func (m *S2C_TryLockServicePosition) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_TryLockServicePosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_TryLockServicePosition.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_TryLockServicePosition) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_TryLockServicePosition.Merge(m, src)
}
func (m *S2C_TryLockServicePosition) XXX_Size() int {
return m.Size()
}
func (m *S2C_TryLockServicePosition) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_TryLockServicePosition.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_TryLockServicePosition proto.InternalMessageInfo
func (m *S2C_TryLockServicePosition) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
// 请求服务负载
type C2S_ServicePayload struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (m *C2S_ServicePayload) Reset() { *m = C2S_ServicePayload{} }
func (*C2S_ServicePayload) ProtoMessage() {}
func (*C2S_ServicePayload) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{15}
}
func (m *C2S_ServicePayload) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_ServicePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_ServicePayload.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_ServicePayload) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_ServicePayload.Merge(m, src)
}
func (m *C2S_ServicePayload) XXX_Size() int {
return m.Size()
}
func (m *C2S_ServicePayload) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_ServicePayload.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_ServicePayload proto.InternalMessageInfo
func (m *C2S_ServicePayload) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *C2S_ServicePayload) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
// 请求服务负载回复
type S2C_ServicePayload struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
Payload int32 `protobuf:"varint,2,opt,name=Payload,proto3" json:"Payload,omitempty"`
}
func (m *S2C_ServicePayload) Reset() { *m = S2C_ServicePayload{} }
func (*S2C_ServicePayload) ProtoMessage() {}
func (*S2C_ServicePayload) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{16}
}
func (m *S2C_ServicePayload) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_ServicePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_ServicePayload.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_ServicePayload) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_ServicePayload.Merge(m, src)
}
func (m *S2C_ServicePayload) XXX_Size() int {
return m.Size()
}
func (m *S2C_ServicePayload) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_ServicePayload.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_ServicePayload proto.InternalMessageInfo
func (m *S2C_ServicePayload) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
func (m *S2C_ServicePayload) GetPayload() int32 {
if m != nil {
return m.Payload
}
return 0
}
// 请求上传服务负载
type C2S_PutServicePayload struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
ID int32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
Payload int32 `protobuf:"varint,3,opt,name=Payload,proto3" json:"Payload,omitempty"`
}
func (m *C2S_PutServicePayload) Reset() { *m = C2S_PutServicePayload{} }
func (*C2S_PutServicePayload) ProtoMessage() {}
func (*C2S_PutServicePayload) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{17}
}
func (m *C2S_PutServicePayload) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_PutServicePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_PutServicePayload.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_PutServicePayload) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_PutServicePayload.Merge(m, src)
}
func (m *C2S_PutServicePayload) XXX_Size() int {
return m.Size()
}
func (m *C2S_PutServicePayload) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_PutServicePayload.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_PutServicePayload proto.InternalMessageInfo
func (m *C2S_PutServicePayload) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *C2S_PutServicePayload) GetID() int32 {
if m != nil {
return m.ID
}
return 0
}
func (m *C2S_PutServicePayload) GetPayload() int32 {
if m != nil {
return m.Payload
}
return 0
}
// 请求上传服务负载回复
type S2C_PutServicePayload struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
}
func (m *S2C_PutServicePayload) Reset() { *m = S2C_PutServicePayload{} }
func (*S2C_PutServicePayload) ProtoMessage() {}
func (*S2C_PutServicePayload) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{18}
}
func (m *S2C_PutServicePayload) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_PutServicePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_PutServicePayload.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_PutServicePayload) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_PutServicePayload.Merge(m, src)
}
func (m *S2C_PutServicePayload) XXX_Size() int {
return m.Size()
}
func (m *S2C_PutServicePayload) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_PutServicePayload.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_PutServicePayload proto.InternalMessageInfo
func (m *S2C_PutServicePayload) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
// 请求一组服务所有信息
type C2S_ServiceGroupAllInfo struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
}
func (m *C2S_ServiceGroupAllInfo) Reset() { *m = C2S_ServiceGroupAllInfo{} }
func (*C2S_ServiceGroupAllInfo) ProtoMessage() {}
func (*C2S_ServiceGroupAllInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{19}
}
func (m *C2S_ServiceGroupAllInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_ServiceGroupAllInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_ServiceGroupAllInfo.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_ServiceGroupAllInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_ServiceGroupAllInfo.Merge(m, src)
}
func (m *C2S_ServiceGroupAllInfo) XXX_Size() int {
return m.Size()
}
func (m *C2S_ServiceGroupAllInfo) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_ServiceGroupAllInfo.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_ServiceGroupAllInfo proto.InternalMessageInfo
func (m *C2S_ServiceGroupAllInfo) GetName() string {
if m != nil {
return m.Name
}
return ""
}
// 请求一组服务所有信息回复
type S2C_ServiceGroupAllInfo struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
Infos []*ServiceInfo `protobuf:"bytes,2,rep,name=Infos,proto3" json:"Infos,omitempty"`
}
func (m *S2C_ServiceGroupAllInfo) Reset() { *m = S2C_ServiceGroupAllInfo{} }
func (*S2C_ServiceGroupAllInfo) ProtoMessage() {}
func (*S2C_ServiceGroupAllInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{20}
}
func (m *S2C_ServiceGroupAllInfo) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_ServiceGroupAllInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_ServiceGroupAllInfo.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_ServiceGroupAllInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_ServiceGroupAllInfo.Merge(m, src)
}
func (m *S2C_ServiceGroupAllInfo) XXX_Size() int {
return m.Size()
}
func (m *S2C_ServiceGroupAllInfo) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_ServiceGroupAllInfo.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_ServiceGroupAllInfo proto.InternalMessageInfo
func (m *S2C_ServiceGroupAllInfo) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
func (m *S2C_ServiceGroupAllInfo) GetInfos() []*ServiceInfo {
if m != nil {
return m.Infos
}
return nil
}
// 请求循环选取服务实例
type C2S_RoundRobinPickServiceInstance struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
}
func (m *C2S_RoundRobinPickServiceInstance) Reset() { *m = C2S_RoundRobinPickServiceInstance{} }
func (*C2S_RoundRobinPickServiceInstance) ProtoMessage() {}
func (*C2S_RoundRobinPickServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{21}
}
func (m *C2S_RoundRobinPickServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *C2S_RoundRobinPickServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_C2S_RoundRobinPickServiceInstance.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_RoundRobinPickServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_C2S_RoundRobinPickServiceInstance.Merge(m, src)
}
func (m *C2S_RoundRobinPickServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *C2S_RoundRobinPickServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_C2S_RoundRobinPickServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_C2S_RoundRobinPickServiceInstance proto.InternalMessageInfo
func (m *C2S_RoundRobinPickServiceInstance) GetName() string {
if m != nil {
return m.Name
}
return ""
}
// 请求循环选取服务实例回复
type S2C_RoundRobinPickServiceInstance struct {
Err *Error `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"`
Info *ServiceInfo `protobuf:"bytes,2,opt,name=Info,proto3" json:"Info,omitempty"`
}
func (m *S2C_RoundRobinPickServiceInstance) Reset() { *m = S2C_RoundRobinPickServiceInstance{} }
func (*S2C_RoundRobinPickServiceInstance) ProtoMessage() {}
func (*S2C_RoundRobinPickServiceInstance) Descriptor() ([]byte, []int) {
return fileDescriptor_5da3cbeb884d181c, []int{22}
}
func (m *S2C_RoundRobinPickServiceInstance) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *S2C_RoundRobinPickServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_S2C_RoundRobinPickServiceInstance.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_RoundRobinPickServiceInstance) XXX_Merge(src proto.Message) {
xxx_messageInfo_S2C_RoundRobinPickServiceInstance.Merge(m, src)
}
func (m *S2C_RoundRobinPickServiceInstance) XXX_Size() int {
return m.Size()
}
func (m *S2C_RoundRobinPickServiceInstance) XXX_DiscardUnknown() {
xxx_messageInfo_S2C_RoundRobinPickServiceInstance.DiscardUnknown(m)
}
var xxx_messageInfo_S2C_RoundRobinPickServiceInstance proto.InternalMessageInfo
func (m *S2C_RoundRobinPickServiceInstance) GetErr() *Error {
if m != nil {
return m.Err
}
return nil
}
func (m *S2C_RoundRobinPickServiceInstance) GetInfo() *ServiceInfo {
if m != nil {
return m.Info
}
return nil
}
func init() {
proto.RegisterEnum("cluster.ErrorCode", ErrorCode_name, ErrorCode_value)
proto.RegisterType((*Error)(nil), "cluster.Error")
proto.RegisterType((*C2S_GlobalConfig)(nil), "cluster.C2S_GlobalConfig")
proto.RegisterType((*S2C_GlobalConfig)(nil), "cluster.S2C_GlobalConfig")
proto.RegisterType((*C2S_ServiceGlobalConfig)(nil), "cluster.C2S_ServiceGlobalConfig")
proto.RegisterType((*S2C_ServiceGlobalConfig)(nil), "cluster.S2C_ServiceGlobalConfig")
proto.RegisterType((*ServiceInstance)(nil), "cluster.ServiceInstance")
proto.RegisterType((*ServiceInfo)(nil), "cluster.ServiceInfo")
proto.RegisterType((*C2S_ServiceInfo)(nil), "cluster.C2S_ServiceInfo")
proto.RegisterType((*S2C_ServiceInfo)(nil), "cluster.S2C_ServiceInfo")
proto.RegisterType((*C2S_ServiceInstance)(nil), "cluster.C2S_ServiceInstance")
proto.RegisterType((*S2C_ServiceInstance)(nil), "cluster.S2C_ServiceInstance")
proto.RegisterType((*C2S_PutServiceInstance)(nil), "cluster.C2S_PutServiceInstance")
proto.RegisterType((*S2C_PutServiceInstance)(nil), "cluster.S2C_PutServiceInstance")
proto.RegisterType((*C2S_TryLockServicePosition)(nil), "cluster.C2S_TryLockServicePosition")
proto.RegisterType((*S2C_TryLockServicePosition)(nil), "cluster.S2C_TryLockServicePosition")
proto.RegisterType((*C2S_ServicePayload)(nil), "cluster.C2S_ServicePayload")
proto.RegisterType((*S2C_ServicePayload)(nil), "cluster.S2C_ServicePayload")
proto.RegisterType((*C2S_PutServicePayload)(nil), "cluster.C2S_PutServicePayload")
proto.RegisterType((*S2C_PutServicePayload)(nil), "cluster.S2C_PutServicePayload")
proto.RegisterType((*C2S_ServiceGroupAllInfo)(nil), "cluster.C2S_ServiceGroupAllInfo")
proto.RegisterType((*S2C_ServiceGroupAllInfo)(nil), "cluster.S2C_ServiceGroupAllInfo")
proto.RegisterType((*C2S_RoundRobinPickServiceInstance)(nil), "cluster.C2S_RoundRobinPickServiceInstance")
proto.RegisterType((*S2C_RoundRobinPickServiceInstance)(nil), "cluster.S2C_RoundRobinPickServiceInstance")
}
func init() { proto.RegisterFile("protos.proto", fileDescriptor_5da3cbeb884d181c) }
var fileDescriptor_5da3cbeb884d181c = []byte{
// 757 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x96, 0xcb, 0x6e, 0xda, 0x4c,
0x14, 0xc7, 0xb1, 0x81, 0xf0, 0x71, 0x88, 0x08, 0x9a, 0xdc, 0x2c, 0xbe, 0x68, 0x44, 0x66, 0xf1,
0x29, 0x8a, 0x14, 0x90, 0xf8, 0xd2, 0x4b, 0xba, 0xa8, 0x44, 0xc1, 0xad, 0x90, 0x9a, 0xc8, 0x32,
0xe9, 0xaa, 0xaa, 0xa2, 0xc1, 0x18, 0x62, 0xc5, 0xf1, 0x44, 0x63, 0x13, 0x85, 0x5d, 0x5f, 0xa0,
0x52, 0x1f, 0xa3, 0x8f, 0xd2, 0x65, 0x96, 0x59, 0x74, 0xd1, 0x90, 0x4d, 0x97, 0x79, 0x84, 0x6a,
0x06, 0x43, 0xed, 0xdc, 0xa0, 0x51, 0xbb, 0x8a, 0x67, 0xce, 0x99, 0xff, 0xf9, 0x9d, 0xcb, 0x4c,
0x80, 0xf9, 0x13, 0xce, 0x02, 0xe6, 0x97, 0xe5, 0x1f, 0x94, 0xb1, 0xdc, 0xbe, 0x1f, 0xd8, 0xbc,
0xf8, 0xb4, 0xe7, 0x04, 0x87, 0xfd, 0x76, 0xd9, 0x62, 0xc7, 0x95, 0x9a, 0x3f, 0xf0, 0x8e, 0x38,
0xf3, 0x9a, 0xfb, 0x15, 0xe9, 0x45, 0xad, 0x80, 0xf1, 0xad, 0x1e, 0xab, 0xc8, 0x8f, 0x4a, 0x54,
0x80, 0x34, 0x21, 0xad, 0x73, 0xce, 0x38, 0xfa, 0x0f, 0x52, 0x75, 0xd6, 0xb1, 0x35, 0xa5, 0xa4,
0x6c, 0xe4, 0xab, 0xa8, 0x1c, 0x0a, 0x97, 0xa5, 0x55, 0x58, 0x4c, 0x69, 0x47, 0x1a, 0x64, 0x76,
0x6d, 0xdf, 0xa7, 0x3d, 0x5b, 0x53, 0x4b, 0xca, 0x46, 0xd6, 0x1c, 0x2f, 0x09, 0x82, 0x42, 0xbd,
0xda, 0x3a, 0x78, 0xe3, 0xb2, 0x36, 0x75, 0xeb, 0xcc, 0xeb, 0x3a, 0x3d, 0x52, 0x85, 0x42, 0xab,
0x5a, 0x8f, 0xed, 0x21, 0x0c, 0x30, 0xfa, 0x6a, 0xd0, 0x80, 0xca, 0x78, 0xf3, 0x66, 0x64, 0x87,
0x6c, 0xc1, 0xaa, 0xd0, 0x69, 0xd9, 0xfc, 0xd4, 0xb1, 0xec, 0xd8, 0x51, 0x04, 0xa9, 0x3d, 0x7a,
0x3c, 0x82, 0xcc, 0x9a, 0xf2, 0x9b, 0xbc, 0x87, 0x55, 0x11, 0xe2, 0x2e, 0xf7, 0x12, 0x24, 0x75,
0xce, 0xa5, 0x77, 0xae, 0x9a, 0x8f, 0xa7, 0x64, 0x0a, 0xd3, 0x0d, 0x16, 0xf5, 0x16, 0x8b, 0x05,
0x0b, 0xa1, 0x70, 0xd3, 0xf3, 0x03, 0xea, 0x59, 0x36, 0x5a, 0x83, 0xa4, 0xd1, 0x6c, 0x84, 0xa2,
0x50, 0x96, 0x35, 0x2d, 0x1b, 0xcd, 0x86, 0x29, 0xb6, 0xd1, 0x1a, 0x64, 0x8d, 0x13, 0xce, 0xba,
0xb5, 0x4e, 0x87, 0x87, 0x05, 0xfa, 0xb5, 0x81, 0x96, 0x20, 0xad, 0x9f, 0x05, 0x9c, 0x6a, 0x49,
0x19, 0x69, 0xb4, 0x20, 0x9f, 0x14, 0xc8, 0x4d, 0xa2, 0x74, 0x19, 0xca, 0x83, 0x1a, 0x06, 0x48,
0x9b, 0x6a, 0xb3, 0x31, 0x0d, 0x12, 0x6d, 0xc3, 0x3f, 0x63, 0x3a, 0x29, 0x9c, 0xab, 0x6a, 0x93,
0x5c, 0x6f, 0xd0, 0x9b, 0x13, 0x4f, 0xd1, 0x48, 0x83, 0x0e, 0x5c, 0x46, 0x3b, 0x5a, 0x4a, 0x86,
0x1a, 0x2f, 0xc9, 0x13, 0x58, 0x88, 0x34, 0x40, 0x22, 0xdd, 0x51, 0xf8, 0x10, 0x53, 0x1d, 0x63,
0x92, 0x0f, 0xb0, 0x10, 0x69, 0x84, 0x3c, 0x36, 0xbd, 0x01, 0x1b, 0x90, 0x12, 0x9e, 0x52, 0x26,
0x57, 0x5d, 0xba, 0xcd, 0xdd, 0x65, 0xa6, 0xf4, 0x20, 0x3b, 0xb0, 0x18, 0xa3, 0x0a, 0xd3, 0x98,
0x85, 0xec, 0x18, 0x16, 0x63, 0x64, 0xe1, 0xd1, 0xe9, 0x74, 0xd1, 0xca, 0xaa, 0xb3, 0x56, 0x96,
0x70, 0x58, 0x11, 0xa4, 0x46, 0x3f, 0x78, 0x04, 0xec, 0xe3, 0xba, 0x49, 0x5e, 0xc0, 0x8a, 0x48,
0xf1, 0x8e, 0x98, 0x53, 0xb3, 0x24, 0xa7, 0x50, 0x14, 0xbc, 0xfb, 0x7c, 0xf0, 0x96, 0x59, 0x47,
0xe1, 0x79, 0x83, 0xf9, 0x4e, 0xe0, 0x30, 0xef, 0x2f, 0x32, 0xbf, 0x84, 0xa2, 0x60, 0xbe, 0x27,
0xee, 0x74, 0xee, 0xe7, 0x80, 0x22, 0x13, 0x11, 0x4e, 0xef, 0x4c, 0x03, 0x61, 0x00, 0x8a, 0x0c,
0xc4, 0xf8, 0xe4, 0xf4, 0x79, 0x88, 0xdc, 0x19, 0x35, 0x7e, 0x67, 0xde, 0xc1, 0x72, 0xbc, 0xe7,
0xbf, 0x81, 0x13, 0x95, 0x4d, 0xc6, 0x65, 0x77, 0x60, 0x39, 0xde, 0xd6, 0x99, 0x59, 0x6f, 0x3e,
0xa3, 0x9c, 0xf5, 0x4f, 0x6a, 0xae, 0x7b, 0xdf, 0x6d, 0x26, 0xbd, 0xf8, 0x33, 0x1a, 0x75, 0x9f,
0x5e, 0x97, 0x4d, 0x48, 0x0b, 0x4f, 0x5f, 0x53, 0x4b, 0xc9, 0x7b, 0xaf, 0xf1, 0xc8, 0x85, 0x3c,
0x83, 0x75, 0xc1, 0x65, 0xb2, 0xbe, 0xd7, 0x31, 0x59, 0xdb, 0xf1, 0x0c, 0x67, 0xd2, 0xfc, 0x87,
0x2e, 0x0a, 0x61, 0xb0, 0x2e, 0x08, 0x1f, 0x3e, 0xf8, 0x07, 0x5f, 0x9c, 0xcd, 0x6f, 0x0a, 0x64,
0x27, 0xff, 0xfe, 0x50, 0x1e, 0x40, 0xaf, 0x1f, 0xb4, 0xfa, 0x96, 0x65, 0xfb, 0x7e, 0x21, 0x81,
0x72, 0x90, 0xd1, 0xeb, 0x07, 0xaf, 0xa9, 0xe3, 0x16, 0x14, 0xf4, 0x2f, 0xac, 0xea, 0xf1, 0xe2,
0xed, 0xb1, 0x40, 0x3f, 0x73, 0xfc, 0xa0, 0xa0, 0xa2, 0x22, 0xac, 0xe8, 0xb1, 0x77, 0x71, 0x62,
0x4b, 0x86, 0xb6, 0x5d, 0xca, 0xfd, 0x43, 0xea, 0x8e, 0xb3, 0x90, 0xa2, 0x29, 0xb4, 0x06, 0x9a,
0x2e, 0x7b, 0x3f, 0xde, 0xdf, 0x67, 0x7a, 0x60, 0x75, 0xa4, 0x35, 0x8d, 0x08, 0x60, 0xfd, 0xd6,
0x9b, 0x56, 0x73, 0xb9, 0x4d, 0x3b, 0x83, 0x91, 0xfa, 0x5c, 0x88, 0x65, 0xf4, 0x83, 0x70, 0x6c,
0x22, 0x02, 0x99, 0x57, 0xdb, 0xe7, 0x97, 0x38, 0x71, 0x71, 0x89, 0x13, 0xd7, 0x97, 0x58, 0xf9,
0x38, 0xc4, 0xca, 0x97, 0x21, 0x56, 0xbe, 0x0e, 0xb1, 0x72, 0x3e, 0xc4, 0xca, 0xf7, 0x21, 0x56,
0x7e, 0x0c, 0x71, 0xe2, 0x7a, 0x88, 0x95, 0xcf, 0x57, 0x38, 0x71, 0x7e, 0x85, 0x13, 0x17, 0x57,
0x38, 0xd1, 0x9e, 0x93, 0xbf, 0x1b, 0xfe, 0xff, 0x19, 0x00, 0x00, 0xff, 0xff, 0x25, 0x35, 0x73,
0x34, 0x88, 0x08, 0x00, 0x00,
}
func (x ErrorCode) String() string {
s, ok := ErrorCode_name[int32(x)]
if ok {
return s
}
return strconv.Itoa(int(x))
}
func (this *Error) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*Error)
if !ok {
that2, ok := that.(Error)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Code != that1.Code {
return false
}
if this.Message != that1.Message {
return false
}
return true
}
func (this *C2S_GlobalConfig) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_GlobalConfig)
if !ok {
that2, ok := that.(C2S_GlobalConfig)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
return true
}
func (this *S2C_GlobalConfig) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_GlobalConfig)
if !ok {
that2, ok := that.(S2C_GlobalConfig)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !bytes.Equal(this.ConfigData, that1.ConfigData) {
return false
}
return true
}
func (this *C2S_ServiceGlobalConfig) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_ServiceGlobalConfig)
if !ok {
that2, ok := that.(C2S_ServiceGlobalConfig)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
return true
}
func (this *S2C_ServiceGlobalConfig) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_ServiceGlobalConfig)
if !ok {
that2, ok := that.(S2C_ServiceGlobalConfig)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
if !bytes.Equal(this.ConfigData, that1.ConfigData) {
return false
}
return true
}
func (this *ServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*ServiceInstance)
if !ok {
that2, ok := that.(ServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.PID.Equal(that1.PID) {
return false
}
if this.PprofAddr != that1.PprofAddr {
return false
}
if !bytes.Equal(this.Extra, that1.Extra) {
return false
}
return true
}
func (this *ServiceInfo) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*ServiceInfo)
if !ok {
that2, ok := that.(ServiceInfo)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.ID != that1.ID {
return false
}
if !bytes.Equal(this.ConfigData, that1.ConfigData) {
return false
}
if !this.Instance.Equal(that1.Instance) {
return false
}
if this.Payload != that1.Payload {
return false
}
return true
}
func (this *C2S_ServiceInfo) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_ServiceInfo)
if !ok {
that2, ok := that.(C2S_ServiceInfo)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.ID != that1.ID {
return false
}
return true
}
func (this *S2C_ServiceInfo) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_ServiceInfo)
if !ok {
that2, ok := that.(S2C_ServiceInfo)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
if !this.Info.Equal(that1.Info) {
return false
}
return true
}
func (this *C2S_ServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_ServiceInstance)
if !ok {
that2, ok := that.(C2S_ServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.ID != that1.ID {
return false
}
return true
}
func (this *S2C_ServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_ServiceInstance)
if !ok {
that2, ok := that.(S2C_ServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
if !this.Instance.Equal(that1.Instance) {
return false
}
return true
}
func (this *C2S_PutServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_PutServiceInstance)
if !ok {
that2, ok := that.(C2S_PutServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.ID != that1.ID {
return false
}
if !this.Instance.Equal(that1.Instance) {
return false
}
return true
}
func (this *S2C_PutServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_PutServiceInstance)
if !ok {
that2, ok := that.(S2C_PutServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
return true
}
func (this *C2S_TryLockServicePosition) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_TryLockServicePosition)
if !ok {
that2, ok := that.(C2S_TryLockServicePosition)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.ID != that1.ID {
return false
}
if !this.Instance.Equal(that1.Instance) {
return false
}
return true
}
func (this *S2C_TryLockServicePosition) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_TryLockServicePosition)
if !ok {
that2, ok := that.(S2C_TryLockServicePosition)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
return true
}
func (this *C2S_ServicePayload) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_ServicePayload)
if !ok {
that2, ok := that.(C2S_ServicePayload)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.ID != that1.ID {
return false
}
return true
}
func (this *S2C_ServicePayload) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_ServicePayload)
if !ok {
that2, ok := that.(S2C_ServicePayload)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
if this.Payload != that1.Payload {
return false
}
return true
}
func (this *C2S_PutServicePayload) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_PutServicePayload)
if !ok {
that2, ok := that.(C2S_PutServicePayload)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
if this.ID != that1.ID {
return false
}
if this.Payload != that1.Payload {
return false
}
return true
}
func (this *S2C_PutServicePayload) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_PutServicePayload)
if !ok {
that2, ok := that.(S2C_PutServicePayload)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
return true
}
func (this *C2S_ServiceGroupAllInfo) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_ServiceGroupAllInfo)
if !ok {
that2, ok := that.(C2S_ServiceGroupAllInfo)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
return true
}
func (this *S2C_ServiceGroupAllInfo) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_ServiceGroupAllInfo)
if !ok {
that2, ok := that.(S2C_ServiceGroupAllInfo)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
if len(this.Infos) != len(that1.Infos) {
return false
}
for i := range this.Infos {
if !this.Infos[i].Equal(that1.Infos[i]) {
return false
}
}
return true
}
func (this *C2S_RoundRobinPickServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*C2S_RoundRobinPickServiceInstance)
if !ok {
that2, ok := that.(C2S_RoundRobinPickServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Name != that1.Name {
return false
}
return true
}
func (this *S2C_RoundRobinPickServiceInstance) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*S2C_RoundRobinPickServiceInstance)
if !ok {
that2, ok := that.(S2C_RoundRobinPickServiceInstance)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Err.Equal(that1.Err) {
return false
}
if !this.Info.Equal(that1.Info) {
return false
}
return true
}
func (this *Error) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.Error{")
s = append(s, "Code: "+fmt.Sprintf("%#v", this.Code)+",\n")
s = append(s, "Message: "+fmt.Sprintf("%#v", this.Message)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_GlobalConfig) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 4)
s = append(s, "&cluster.C2S_GlobalConfig{")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_GlobalConfig) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.S2C_GlobalConfig{")
s = append(s, "ConfigData: "+fmt.Sprintf("%#v", this.ConfigData)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_ServiceGlobalConfig) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.C2S_ServiceGlobalConfig{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_ServiceGlobalConfig) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.S2C_ServiceGlobalConfig{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
s = append(s, "ConfigData: "+fmt.Sprintf("%#v", this.ConfigData)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *ServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 7)
s = append(s, "&cluster.ServiceInstance{")
if this.PID != nil {
s = append(s, "PID: "+fmt.Sprintf("%#v", this.PID)+",\n")
}
s = append(s, "PprofAddr: "+fmt.Sprintf("%#v", this.PprofAddr)+",\n")
s = append(s, "Extra: "+fmt.Sprintf("%#v", this.Extra)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *ServiceInfo) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 8)
s = append(s, "&cluster.ServiceInfo{")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
s = append(s, "ConfigData: "+fmt.Sprintf("%#v", this.ConfigData)+",\n")
if this.Instance != nil {
s = append(s, "Instance: "+fmt.Sprintf("%#v", this.Instance)+",\n")
}
s = append(s, "Payload: "+fmt.Sprintf("%#v", this.Payload)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_ServiceInfo) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.C2S_ServiceInfo{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_ServiceInfo) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.S2C_ServiceInfo{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
if this.Info != nil {
s = append(s, "Info: "+fmt.Sprintf("%#v", this.Info)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_ServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.C2S_ServiceInstance{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_ServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.S2C_ServiceInstance{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
if this.Instance != nil {
s = append(s, "Instance: "+fmt.Sprintf("%#v", this.Instance)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_PutServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 7)
s = append(s, "&cluster.C2S_PutServiceInstance{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
if this.Instance != nil {
s = append(s, "Instance: "+fmt.Sprintf("%#v", this.Instance)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_PutServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.S2C_PutServiceInstance{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_TryLockServicePosition) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 7)
s = append(s, "&cluster.C2S_TryLockServicePosition{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
if this.Instance != nil {
s = append(s, "Instance: "+fmt.Sprintf("%#v", this.Instance)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_TryLockServicePosition) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.S2C_TryLockServicePosition{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_ServicePayload) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.C2S_ServicePayload{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_ServicePayload) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.S2C_ServicePayload{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
s = append(s, "Payload: "+fmt.Sprintf("%#v", this.Payload)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_PutServicePayload) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 7)
s = append(s, "&cluster.C2S_PutServicePayload{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "ID: "+fmt.Sprintf("%#v", this.ID)+",\n")
s = append(s, "Payload: "+fmt.Sprintf("%#v", this.Payload)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_PutServicePayload) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.S2C_PutServicePayload{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_ServiceGroupAllInfo) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.C2S_ServiceGroupAllInfo{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_ServiceGroupAllInfo) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.S2C_ServiceGroupAllInfo{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
if this.Infos != nil {
s = append(s, "Infos: "+fmt.Sprintf("%#v", this.Infos)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func (this *C2S_RoundRobinPickServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 5)
s = append(s, "&cluster.C2S_RoundRobinPickServiceInstance{")
s = append(s, "Name: "+fmt.Sprintf("%#v", this.Name)+",\n")
s = append(s, "}")
return strings.Join(s, "")
}
func (this *S2C_RoundRobinPickServiceInstance) GoString() string {
if this == nil {
return "nil"
}
s := make([]string, 0, 6)
s = append(s, "&cluster.S2C_RoundRobinPickServiceInstance{")
if this.Err != nil {
s = append(s, "Err: "+fmt.Sprintf("%#v", this.Err)+",\n")
}
if this.Info != nil {
s = append(s, "Info: "+fmt.Sprintf("%#v", this.Info)+",\n")
}
s = append(s, "}")
return strings.Join(s, "")
}
func valueToGoStringProtos(v interface{}, typ string) string {
rv := reflect.ValueOf(v)
if rv.IsNil() {
return "nil"
}
pv := reflect.Indirect(rv).Interface()
return fmt.Sprintf("func(v %v) *%v { return &v } ( %#v )", typ, typ, pv)
}
func (m *Error) 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 *Error) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Code != 0 {
dAtA[i] = 0x8
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Code))
}
if len(m.Message) > 0 {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Message)))
i += copy(dAtA[i:], m.Message)
}
return i, nil
}
func (m *C2S_GlobalConfig) 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_GlobalConfig) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
return i, nil
}
func (m *S2C_GlobalConfig) 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_GlobalConfig) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.ConfigData) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.ConfigData)))
i += copy(dAtA[i:], m.ConfigData)
}
return i, nil
}
func (m *C2S_ServiceGlobalConfig) 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_ServiceGlobalConfig) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
return i, nil
}
func (m *S2C_ServiceGlobalConfig) 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_ServiceGlobalConfig) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n1, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
}
if len(m.ConfigData) > 0 {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.ConfigData)))
i += copy(dAtA[i:], m.ConfigData)
}
return i, nil
}
func (m *ServiceInstance) 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 *ServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.PID != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.PID.Size()))
n2, err := m.PID.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n2
}
if len(m.PprofAddr) > 0 {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.PprofAddr)))
i += copy(dAtA[i:], m.PprofAddr)
}
if len(m.Extra) > 0 {
dAtA[i] = 0x1a
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Extra)))
i += copy(dAtA[i:], m.Extra)
}
return i, nil
}
func (m *ServiceInfo) 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 *ServiceInfo) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.ID != 0 {
dAtA[i] = 0x8
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
if len(m.ConfigData) > 0 {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.ConfigData)))
i += copy(dAtA[i:], m.ConfigData)
}
if m.Instance != nil {
dAtA[i] = 0x1a
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Instance.Size()))
n3, err := m.Instance.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n3
}
if m.Payload != 0 {
dAtA[i] = 0x20
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Payload))
}
return i, nil
}
func (m *C2S_ServiceInfo) 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_ServiceInfo) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
if m.ID != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
return i, nil
}
func (m *S2C_ServiceInfo) 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_ServiceInfo) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n4, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n4
}
if m.Info != nil {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Info.Size()))
n5, err := m.Info.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n5
}
return i, nil
}
func (m *C2S_ServiceInstance) 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_ServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
if m.ID != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
return i, nil
}
func (m *S2C_ServiceInstance) 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_ServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n6, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n6
}
if m.Instance != nil {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Instance.Size()))
n7, err := m.Instance.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n7
}
return i, nil
}
func (m *C2S_PutServiceInstance) 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_PutServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
if m.ID != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
if m.Instance != nil {
dAtA[i] = 0x1a
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Instance.Size()))
n8, err := m.Instance.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n8
}
return i, nil
}
func (m *S2C_PutServiceInstance) 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_PutServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n9, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n9
}
return i, nil
}
func (m *C2S_TryLockServicePosition) 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_TryLockServicePosition) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
if m.ID != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
if m.Instance != nil {
dAtA[i] = 0x1a
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Instance.Size()))
n10, err := m.Instance.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n10
}
return i, nil
}
func (m *S2C_TryLockServicePosition) 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_TryLockServicePosition) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n11, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n11
}
return i, nil
}
func (m *C2S_ServicePayload) 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_ServicePayload) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
if m.ID != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
return i, nil
}
func (m *S2C_ServicePayload) 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_ServicePayload) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n12, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n12
}
if m.Payload != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Payload))
}
return i, nil
}
func (m *C2S_PutServicePayload) 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_PutServicePayload) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
if m.ID != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintProtos(dAtA, i, uint64(m.ID))
}
if m.Payload != 0 {
dAtA[i] = 0x18
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Payload))
}
return i, nil
}
func (m *S2C_PutServicePayload) 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_PutServicePayload) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n13, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n13
}
return i, nil
}
func (m *C2S_ServiceGroupAllInfo) 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_ServiceGroupAllInfo) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
return i, nil
}
func (m *S2C_ServiceGroupAllInfo) 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_ServiceGroupAllInfo) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n14, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n14
}
if len(m.Infos) > 0 {
for _, msg := range m.Infos {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(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_RoundRobinPickServiceInstance) 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_RoundRobinPickServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Name) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(len(m.Name)))
i += copy(dAtA[i:], m.Name)
}
return i, nil
}
func (m *S2C_RoundRobinPickServiceInstance) 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_RoundRobinPickServiceInstance) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Err != nil {
dAtA[i] = 0xa
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Err.Size()))
n15, err := m.Err.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n15
}
if m.Info != nil {
dAtA[i] = 0x12
i++
i = encodeVarintProtos(dAtA, i, uint64(m.Info.Size()))
n16, err := m.Info.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n16
}
return i, nil
}
func encodeVarintProtos(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 *Error) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Code != 0 {
n += 1 + sovProtos(uint64(m.Code))
}
l = len(m.Message)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_GlobalConfig) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
return n
}
func (m *S2C_GlobalConfig) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.ConfigData)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_ServiceGlobalConfig) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *S2C_ServiceGlobalConfig) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
l = len(m.ConfigData)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *ServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.PID != nil {
l = m.PID.Size()
n += 1 + l + sovProtos(uint64(l))
}
l = len(m.PprofAddr)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
l = len(m.Extra)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *ServiceInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
l = len(m.ConfigData)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.Instance != nil {
l = m.Instance.Size()
n += 1 + l + sovProtos(uint64(l))
}
if m.Payload != 0 {
n += 1 + sovProtos(uint64(m.Payload))
}
return n
}
func (m *C2S_ServiceInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
return n
}
func (m *S2C_ServiceInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
if m.Info != nil {
l = m.Info.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_ServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
return n
}
func (m *S2C_ServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
if m.Instance != nil {
l = m.Instance.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_PutServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
if m.Instance != nil {
l = m.Instance.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *S2C_PutServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_TryLockServicePosition) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
if m.Instance != nil {
l = m.Instance.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *S2C_TryLockServicePosition) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_ServicePayload) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
return n
}
func (m *S2C_ServicePayload) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
if m.Payload != 0 {
n += 1 + sovProtos(uint64(m.Payload))
}
return n
}
func (m *C2S_PutServicePayload) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
if m.ID != 0 {
n += 1 + sovProtos(uint64(m.ID))
}
if m.Payload != 0 {
n += 1 + sovProtos(uint64(m.Payload))
}
return n
}
func (m *S2C_PutServicePayload) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *C2S_ServiceGroupAllInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *S2C_ServiceGroupAllInfo) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
if len(m.Infos) > 0 {
for _, e := range m.Infos {
l = e.Size()
n += 1 + l + sovProtos(uint64(l))
}
}
return n
}
func (m *C2S_RoundRobinPickServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Name)
if l > 0 {
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func (m *S2C_RoundRobinPickServiceInstance) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Err != nil {
l = m.Err.Size()
n += 1 + l + sovProtos(uint64(l))
}
if m.Info != nil {
l = m.Info.Size()
n += 1 + l + sovProtos(uint64(l))
}
return n
}
func sovProtos(x uint64) (n int) {
for {
n++
x >>= 7
if x == 0 {
break
}
}
return n
}
func sozProtos(x uint64) (n int) {
return sovProtos(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (this *Error) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&Error{`,
`Code:` + fmt.Sprintf("%v", this.Code) + `,`,
`Message:` + fmt.Sprintf("%v", this.Message) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_GlobalConfig) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_GlobalConfig{`,
`}`,
}, "")
return s
}
func (this *S2C_GlobalConfig) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_GlobalConfig{`,
`ConfigData:` + fmt.Sprintf("%v", this.ConfigData) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_ServiceGlobalConfig) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_ServiceGlobalConfig{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_ServiceGlobalConfig) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_ServiceGlobalConfig{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`ConfigData:` + fmt.Sprintf("%v", this.ConfigData) + `,`,
`}`,
}, "")
return s
}
func (this *ServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&ServiceInstance{`,
`PID:` + strings.Replace(fmt.Sprintf("%v", this.PID), "PID", "actor.PID", 1) + `,`,
`PprofAddr:` + fmt.Sprintf("%v", this.PprofAddr) + `,`,
`Extra:` + fmt.Sprintf("%v", this.Extra) + `,`,
`}`,
}, "")
return s
}
func (this *ServiceInfo) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&ServiceInfo{`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`ConfigData:` + fmt.Sprintf("%v", this.ConfigData) + `,`,
`Instance:` + strings.Replace(fmt.Sprintf("%v", this.Instance), "ServiceInstance", "ServiceInstance", 1) + `,`,
`Payload:` + fmt.Sprintf("%v", this.Payload) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_ServiceInfo) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_ServiceInfo{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_ServiceInfo) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_ServiceInfo{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`Info:` + strings.Replace(fmt.Sprintf("%v", this.Info), "ServiceInfo", "ServiceInfo", 1) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_ServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_ServiceInstance{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_ServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_ServiceInstance{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`Instance:` + strings.Replace(fmt.Sprintf("%v", this.Instance), "ServiceInstance", "ServiceInstance", 1) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_PutServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_PutServiceInstance{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`Instance:` + strings.Replace(fmt.Sprintf("%v", this.Instance), "ServiceInstance", "ServiceInstance", 1) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_PutServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_PutServiceInstance{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_TryLockServicePosition) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_TryLockServicePosition{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`Instance:` + strings.Replace(fmt.Sprintf("%v", this.Instance), "ServiceInstance", "ServiceInstance", 1) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_TryLockServicePosition) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_TryLockServicePosition{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_ServicePayload) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_ServicePayload{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_ServicePayload) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_ServicePayload{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`Payload:` + fmt.Sprintf("%v", this.Payload) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_PutServicePayload) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_PutServicePayload{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`ID:` + fmt.Sprintf("%v", this.ID) + `,`,
`Payload:` + fmt.Sprintf("%v", this.Payload) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_PutServicePayload) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_PutServicePayload{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_ServiceGroupAllInfo) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_ServiceGroupAllInfo{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_ServiceGroupAllInfo) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_ServiceGroupAllInfo{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`Infos:` + strings.Replace(fmt.Sprintf("%v", this.Infos), "ServiceInfo", "ServiceInfo", 1) + `,`,
`}`,
}, "")
return s
}
func (this *C2S_RoundRobinPickServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&C2S_RoundRobinPickServiceInstance{`,
`Name:` + fmt.Sprintf("%v", this.Name) + `,`,
`}`,
}, "")
return s
}
func (this *S2C_RoundRobinPickServiceInstance) String() string {
if this == nil {
return "nil"
}
s := strings.Join([]string{`&S2C_RoundRobinPickServiceInstance{`,
`Err:` + strings.Replace(fmt.Sprintf("%v", this.Err), "Error", "Error", 1) + `,`,
`Info:` + strings.Replace(fmt.Sprintf("%v", this.Info), "ServiceInfo", "ServiceInfo", 1) + `,`,
`}`,
}, "")
return s
}
func valueToStringProtos(v interface{}) string {
rv := reflect.ValueOf(v)
if rv.IsNil() {
return "nil"
}
pv := reflect.Indirect(rv).Interface()
return fmt.Sprintf("*%v", pv)
}
func (m *Error) 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 ErrIntOverflowProtos
}
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: Error: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: Error: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Code", wireType)
}
m.Code = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Code |= ErrorCode(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Message", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Message = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_GlobalConfig) 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 ErrIntOverflowProtos
}
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_GlobalConfig: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_GlobalConfig: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_GlobalConfig) 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 ErrIntOverflowProtos
}
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_GlobalConfig: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_GlobalConfig: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ConfigData", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ConfigData = append(m.ConfigData[:0], dAtA[iNdEx:postIndex]...)
if m.ConfigData == nil {
m.ConfigData = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_ServiceGlobalConfig) 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 ErrIntOverflowProtos
}
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_ServiceGlobalConfig: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_ServiceGlobalConfig: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_ServiceGlobalConfig) 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 ErrIntOverflowProtos
}
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_ServiceGlobalConfig: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_ServiceGlobalConfig: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ConfigData", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ConfigData = append(m.ConfigData[:0], dAtA[iNdEx:postIndex]...)
if m.ConfigData == nil {
m.ConfigData = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *ServiceInstance) 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 ErrIntOverflowProtos
}
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: ServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: ServiceInstance: 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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
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
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PprofAddr", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PprofAddr = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Extra", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Extra = append(m.Extra[:0], dAtA[iNdEx:postIndex]...)
if m.Extra == nil {
m.Extra = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *ServiceInfo) 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 ErrIntOverflowProtos
}
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: ServiceInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: ServiceInfo: 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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ConfigData", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ConfigData = append(m.ConfigData[:0], dAtA[iNdEx:postIndex]...)
if m.ConfigData == nil {
m.ConfigData = []byte{}
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Instance == nil {
m.Instance = &ServiceInstance{}
}
if err := m.Instance.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
}
m.Payload = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Payload |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_ServiceInfo) 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 ErrIntOverflowProtos
}
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_ServiceInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_ServiceInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_ServiceInfo) 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 ErrIntOverflowProtos
}
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_ServiceInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_ServiceInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Info", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Info == nil {
m.Info = &ServiceInfo{}
}
if err := m.Info.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_ServiceInstance) 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 ErrIntOverflowProtos
}
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_ServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_ServiceInstance: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_ServiceInstance) 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 ErrIntOverflowProtos
}
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_ServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_ServiceInstance: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Instance == nil {
m.Instance = &ServiceInstance{}
}
if err := m.Instance.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_PutServiceInstance) 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 ErrIntOverflowProtos
}
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_PutServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_PutServiceInstance: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Instance == nil {
m.Instance = &ServiceInstance{}
}
if err := m.Instance.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_PutServiceInstance) 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 ErrIntOverflowProtos
}
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_PutServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_PutServiceInstance: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_TryLockServicePosition) 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 ErrIntOverflowProtos
}
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_TryLockServicePosition: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_TryLockServicePosition: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Instance", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Instance == nil {
m.Instance = &ServiceInstance{}
}
if err := m.Instance.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_TryLockServicePosition) 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 ErrIntOverflowProtos
}
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_TryLockServicePosition: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_TryLockServicePosition: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_ServicePayload) 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 ErrIntOverflowProtos
}
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_ServicePayload: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_ServicePayload: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_ServicePayload) 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 ErrIntOverflowProtos
}
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_ServicePayload: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_ServicePayload: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
}
m.Payload = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Payload |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_PutServicePayload) 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 ErrIntOverflowProtos
}
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_PutServicePayload: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_PutServicePayload: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
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 ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ID |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Payload", wireType)
}
m.Payload = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Payload |= int32(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_PutServicePayload) 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 ErrIntOverflowProtos
}
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_PutServicePayload: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_PutServicePayload: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_ServiceGroupAllInfo) 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 ErrIntOverflowProtos
}
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_ServiceGroupAllInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_ServiceGroupAllInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_ServiceGroupAllInfo) 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 ErrIntOverflowProtos
}
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_ServiceGroupAllInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_ServiceGroupAllInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Infos", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Infos = append(m.Infos, &ServiceInfo{})
if err := m.Infos[len(m.Infos)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *C2S_RoundRobinPickServiceInstance) 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 ErrIntOverflowProtos
}
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_RoundRobinPickServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: C2S_RoundRobinPickServiceInstance: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
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 ErrIntOverflowProtos
}
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 ErrInvalidLengthProtos
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Name = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *S2C_RoundRobinPickServiceInstance) 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 ErrIntOverflowProtos
}
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_RoundRobinPickServiceInstance: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: S2C_RoundRobinPickServiceInstance: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Err", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Err == nil {
m.Err = &Error{}
}
if err := m.Err.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Info", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowProtos
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthProtos
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthProtos
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Info == nil {
m.Info = &ServiceInfo{}
}
if err := m.Info.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipProtos(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthProtos
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipProtos(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, ErrIntOverflowProtos
}
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, ErrIntOverflowProtos
}
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, ErrIntOverflowProtos
}
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, ErrInvalidLengthProtos
}
iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthProtos
}
return iNdEx, nil
case 3:
for {
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowProtos
}
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 := skipProtos(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthProtos
}
}
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 (
ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowProtos = 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

Search