api.pb.go 151 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939494049414942494349444945494649474948494949504951495249534954495549564957495849594960496149624963496449654966496749684969497049714972497349744975497649774978497949804981498249834984498549864987498849894990499149924993499449954996499749984999500050015002500350045005500650075008500950105011501250135014501550165017501850195020502150225023502450255026502750285029503050315032503350345035503650375038503950405041504250435044504550465047504850495050505150525053505450555056505750585059506050615062506350645065506650675068506950705071507250735074507550765077507850795080508150825083508450855086508750885089509050915092509350945095509650975098509951005101510251035104510551065107510851095110511151125113511451155116511751185119512051215122512351245125512651275128512951305131513251335134513551365137513851395140514151425143514451455146514751485149515051515152515351545155515651575158515951605161516251635164516551665167516851695170517151725173517451755176517751785179518051815182518351845185518651875188518951905191519251935194519551965197519851995200520152025203520452055206520752085209521052115212521352145215521652175218521952205221522252235224522552265227522852295230523152325233523452355236523752385239524052415242524352445245524652475248524952505251525252535254525552565257525852595260526152625263526452655266526752685269527052715272527352745275527652775278527952805281528252835284528552865287528852895290529152925293529452955296529752985299530053015302530353045305530653075308530953105311531253135314531553165317531853195320532153225323532453255326532753285329533053315332533353345335533653375338533953405341534253435344534553465347534853495350535153525353535453555356535753585359536053615362536353645365536653675368536953705371537253735374537553765377537853795380538153825383538453855386538753885389539053915392539353945395539653975398539954005401540254035404540554065407540854095410541154125413541454155416541754185419542054215422542354245425542654275428542954305431543254335434543554365437543854395440544154425443544454455446544754485449545054515452545354545455545654575458545954605461546254635464546554665467546854695470547154725473547454755476547754785479548054815482548354845485548654875488548954905491549254935494549554965497549854995500550155025503550455055506550755085509551055115512551355145515551655175518551955205521552255235524552555265527552855295530553155325533553455355536553755385539554055415542554355445545554655475548554955505551555255535554555555565557555855595560556155625563556455655566556755685569557055715572557355745575557655775578557955805581558255835584558555865587558855895590559155925593559455955596559755985599560056015602560356045605560656075608560956105611561256135614561556165617561856195620562156225623562456255626562756285629563056315632563356345635563656375638563956405641564256435644564556465647564856495650565156525653565456555656565756585659566056615662566356645665566656675668566956705671567256735674567556765677567856795680568156825683568456855686568756885689569056915692569356945695569656975698569957005701570257035704570557065707570857095710571157125713571457155716571757185719572057215722572357245725572657275728572957305731573257335734573557365737573857395740574157425743574457455746574757485749575057515752575357545755575657575758575957605761576257635764576557665767576857695770577157725773577457755776577757785779578057815782578357845785578657875788578957905791579257935794579557965797579857995800580158025803580458055806580758085809581058115812581358145815581658175818581958205821582258235824582558265827582858295830583158325833583458355836583758385839584058415842584358445845584658475848584958505851585258535854585558565857585858595860586158625863586458655866586758685869587058715872587358745875587658775878587958805881588258835884588558865887588858895890589158925893589458955896589758985899590059015902590359045905590659075908590959105911591259135914591559165917591859195920592159225923592459255926592759285929593059315932593359345935593659375938593959405941594259435944594559465947594859495950595159525953595459555956595759585959596059615962596359645965596659675968596959705971597259735974597559765977597859795980598159825983598459855986598759885989599059915992599359945995
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: app/service/bbq/topic/api/api.proto
  3. package api
  4. import proto "github.com/gogo/protobuf/proto"
  5. import fmt "fmt"
  6. import math "math"
  7. import _ "github.com/gogo/protobuf/gogoproto"
  8. import empty "github.com/golang/protobuf/ptypes/empty"
  9. import (
  10. context "golang.org/x/net/context"
  11. grpc "google.golang.org/grpc"
  12. )
  13. import encoding_binary "encoding/binary"
  14. import io "io"
  15. // Reference imports to suppress errors if they are not otherwise used.
  16. var _ = proto.Marshal
  17. var _ = fmt.Errorf
  18. var _ = math.Inf
  19. // This is a compile-time assertion to ensure that this generated file
  20. // is compatible with the proto package it is being compiled against.
  21. // A compilation error at this line likely means your copy of the
  22. // proto package needs to be updated.
  23. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
  24. type ListExtensionReq struct {
  25. Svids []int64 `protobuf:"varint,1,rep,packed,name=svids" json:"svids,omitempty"`
  26. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  27. XXX_unrecognized []byte `json:"-"`
  28. XXX_sizecache int32 `json:"-"`
  29. }
  30. func (m *ListExtensionReq) Reset() { *m = ListExtensionReq{} }
  31. func (m *ListExtensionReq) String() string { return proto.CompactTextString(m) }
  32. func (*ListExtensionReq) ProtoMessage() {}
  33. func (*ListExtensionReq) Descriptor() ([]byte, []int) {
  34. return fileDescriptor_api_328ca58160a5beb9, []int{0}
  35. }
  36. func (m *ListExtensionReq) XXX_Unmarshal(b []byte) error {
  37. return m.Unmarshal(b)
  38. }
  39. func (m *ListExtensionReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  40. if deterministic {
  41. return xxx_messageInfo_ListExtensionReq.Marshal(b, m, deterministic)
  42. } else {
  43. b = b[:cap(b)]
  44. n, err := m.MarshalTo(b)
  45. if err != nil {
  46. return nil, err
  47. }
  48. return b[:n], nil
  49. }
  50. }
  51. func (dst *ListExtensionReq) XXX_Merge(src proto.Message) {
  52. xxx_messageInfo_ListExtensionReq.Merge(dst, src)
  53. }
  54. func (m *ListExtensionReq) XXX_Size() int {
  55. return m.Size()
  56. }
  57. func (m *ListExtensionReq) XXX_DiscardUnknown() {
  58. xxx_messageInfo_ListExtensionReq.DiscardUnknown(m)
  59. }
  60. var xxx_messageInfo_ListExtensionReq proto.InternalMessageInfo
  61. type ListExtensionReply struct {
  62. List []*VideoExtension `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
  63. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  64. XXX_unrecognized []byte `json:"-"`
  65. XXX_sizecache int32 `json:"-"`
  66. }
  67. func (m *ListExtensionReply) Reset() { *m = ListExtensionReply{} }
  68. func (m *ListExtensionReply) String() string { return proto.CompactTextString(m) }
  69. func (*ListExtensionReply) ProtoMessage() {}
  70. func (*ListExtensionReply) Descriptor() ([]byte, []int) {
  71. return fileDescriptor_api_328ca58160a5beb9, []int{1}
  72. }
  73. func (m *ListExtensionReply) XXX_Unmarshal(b []byte) error {
  74. return m.Unmarshal(b)
  75. }
  76. func (m *ListExtensionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  77. if deterministic {
  78. return xxx_messageInfo_ListExtensionReply.Marshal(b, m, deterministic)
  79. } else {
  80. b = b[:cap(b)]
  81. n, err := m.MarshalTo(b)
  82. if err != nil {
  83. return nil, err
  84. }
  85. return b[:n], nil
  86. }
  87. }
  88. func (dst *ListExtensionReply) XXX_Merge(src proto.Message) {
  89. xxx_messageInfo_ListExtensionReply.Merge(dst, src)
  90. }
  91. func (m *ListExtensionReply) XXX_Size() int {
  92. return m.Size()
  93. }
  94. func (m *ListExtensionReply) XXX_DiscardUnknown() {
  95. xxx_messageInfo_ListExtensionReply.DiscardUnknown(m)
  96. }
  97. var xxx_messageInfo_ListExtensionReply proto.InternalMessageInfo
  98. type UpdateVideoScoreReq struct {
  99. Svid int64 `protobuf:"varint,1,opt,name=svid,proto3" json:"svid,omitempty"`
  100. Score float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
  101. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  102. XXX_unrecognized []byte `json:"-"`
  103. XXX_sizecache int32 `json:"-"`
  104. }
  105. func (m *UpdateVideoScoreReq) Reset() { *m = UpdateVideoScoreReq{} }
  106. func (m *UpdateVideoScoreReq) String() string { return proto.CompactTextString(m) }
  107. func (*UpdateVideoScoreReq) ProtoMessage() {}
  108. func (*UpdateVideoScoreReq) Descriptor() ([]byte, []int) {
  109. return fileDescriptor_api_328ca58160a5beb9, []int{2}
  110. }
  111. func (m *UpdateVideoScoreReq) XXX_Unmarshal(b []byte) error {
  112. return m.Unmarshal(b)
  113. }
  114. func (m *UpdateVideoScoreReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  115. if deterministic {
  116. return xxx_messageInfo_UpdateVideoScoreReq.Marshal(b, m, deterministic)
  117. } else {
  118. b = b[:cap(b)]
  119. n, err := m.MarshalTo(b)
  120. if err != nil {
  121. return nil, err
  122. }
  123. return b[:n], nil
  124. }
  125. }
  126. func (dst *UpdateVideoScoreReq) XXX_Merge(src proto.Message) {
  127. xxx_messageInfo_UpdateVideoScoreReq.Merge(dst, src)
  128. }
  129. func (m *UpdateVideoScoreReq) XXX_Size() int {
  130. return m.Size()
  131. }
  132. func (m *UpdateVideoScoreReq) XXX_DiscardUnknown() {
  133. xxx_messageInfo_UpdateVideoScoreReq.DiscardUnknown(m)
  134. }
  135. var xxx_messageInfo_UpdateVideoScoreReq proto.InternalMessageInfo
  136. type UpdateVideoStateReq struct {
  137. Svid int64 `protobuf:"varint,1,opt,name=svid,proto3" json:"svid,omitempty"`
  138. State int32 `protobuf:"varint,2,opt,name=state,proto3" json:"state,omitempty"`
  139. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  140. XXX_unrecognized []byte `json:"-"`
  141. XXX_sizecache int32 `json:"-"`
  142. }
  143. func (m *UpdateVideoStateReq) Reset() { *m = UpdateVideoStateReq{} }
  144. func (m *UpdateVideoStateReq) String() string { return proto.CompactTextString(m) }
  145. func (*UpdateVideoStateReq) ProtoMessage() {}
  146. func (*UpdateVideoStateReq) Descriptor() ([]byte, []int) {
  147. return fileDescriptor_api_328ca58160a5beb9, []int{3}
  148. }
  149. func (m *UpdateVideoStateReq) XXX_Unmarshal(b []byte) error {
  150. return m.Unmarshal(b)
  151. }
  152. func (m *UpdateVideoStateReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  153. if deterministic {
  154. return xxx_messageInfo_UpdateVideoStateReq.Marshal(b, m, deterministic)
  155. } else {
  156. b = b[:cap(b)]
  157. n, err := m.MarshalTo(b)
  158. if err != nil {
  159. return nil, err
  160. }
  161. return b[:n], nil
  162. }
  163. }
  164. func (dst *UpdateVideoStateReq) XXX_Merge(src proto.Message) {
  165. xxx_messageInfo_UpdateVideoStateReq.Merge(dst, src)
  166. }
  167. func (m *UpdateVideoStateReq) XXX_Size() int {
  168. return m.Size()
  169. }
  170. func (m *UpdateVideoStateReq) XXX_DiscardUnknown() {
  171. xxx_messageInfo_UpdateVideoStateReq.DiscardUnknown(m)
  172. }
  173. var xxx_messageInfo_UpdateVideoStateReq proto.InternalMessageInfo
  174. type TopicVideosReq struct {
  175. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id"`
  176. CursorPrev string `protobuf:"bytes,2,opt,name=cursor_prev,json=cursorPrev,proto3" json:"cursor_prev,omitempty" form:"cursor_prev"`
  177. CursorNext string `protobuf:"bytes,3,opt,name=cursor_next,json=cursorNext,proto3" json:"cursor_next,omitempty" form:"cursor_next"`
  178. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  179. XXX_unrecognized []byte `json:"-"`
  180. XXX_sizecache int32 `json:"-"`
  181. }
  182. func (m *TopicVideosReq) Reset() { *m = TopicVideosReq{} }
  183. func (m *TopicVideosReq) String() string { return proto.CompactTextString(m) }
  184. func (*TopicVideosReq) ProtoMessage() {}
  185. func (*TopicVideosReq) Descriptor() ([]byte, []int) {
  186. return fileDescriptor_api_328ca58160a5beb9, []int{4}
  187. }
  188. func (m *TopicVideosReq) XXX_Unmarshal(b []byte) error {
  189. return m.Unmarshal(b)
  190. }
  191. func (m *TopicVideosReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  192. if deterministic {
  193. return xxx_messageInfo_TopicVideosReq.Marshal(b, m, deterministic)
  194. } else {
  195. b = b[:cap(b)]
  196. n, err := m.MarshalTo(b)
  197. if err != nil {
  198. return nil, err
  199. }
  200. return b[:n], nil
  201. }
  202. }
  203. func (dst *TopicVideosReq) XXX_Merge(src proto.Message) {
  204. xxx_messageInfo_TopicVideosReq.Merge(dst, src)
  205. }
  206. func (m *TopicVideosReq) XXX_Size() int {
  207. return m.Size()
  208. }
  209. func (m *TopicVideosReq) XXX_DiscardUnknown() {
  210. xxx_messageInfo_TopicVideosReq.DiscardUnknown(m)
  211. }
  212. var xxx_messageInfo_TopicVideosReq proto.InternalMessageInfo
  213. type ListMultiTopicVideosReq struct {
  214. List []*TopicVideosReq `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
  215. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  216. XXX_unrecognized []byte `json:"-"`
  217. XXX_sizecache int32 `json:"-"`
  218. }
  219. func (m *ListMultiTopicVideosReq) Reset() { *m = ListMultiTopicVideosReq{} }
  220. func (m *ListMultiTopicVideosReq) String() string { return proto.CompactTextString(m) }
  221. func (*ListMultiTopicVideosReq) ProtoMessage() {}
  222. func (*ListMultiTopicVideosReq) Descriptor() ([]byte, []int) {
  223. return fileDescriptor_api_328ca58160a5beb9, []int{5}
  224. }
  225. func (m *ListMultiTopicVideosReq) XXX_Unmarshal(b []byte) error {
  226. return m.Unmarshal(b)
  227. }
  228. func (m *ListMultiTopicVideosReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  229. if deterministic {
  230. return xxx_messageInfo_ListMultiTopicVideosReq.Marshal(b, m, deterministic)
  231. } else {
  232. b = b[:cap(b)]
  233. n, err := m.MarshalTo(b)
  234. if err != nil {
  235. return nil, err
  236. }
  237. return b[:n], nil
  238. }
  239. }
  240. func (dst *ListMultiTopicVideosReq) XXX_Merge(src proto.Message) {
  241. xxx_messageInfo_ListMultiTopicVideosReq.Merge(dst, src)
  242. }
  243. func (m *ListMultiTopicVideosReq) XXX_Size() int {
  244. return m.Size()
  245. }
  246. func (m *ListMultiTopicVideosReq) XXX_DiscardUnknown() {
  247. xxx_messageInfo_ListMultiTopicVideosReq.DiscardUnknown(m)
  248. }
  249. var xxx_messageInfo_ListMultiTopicVideosReq proto.InternalMessageInfo
  250. type VideoItem struct {
  251. Svid int64 `protobuf:"varint,1,opt,name=svid,proto3" json:"svid,omitempty"`
  252. CursorValue string `protobuf:"bytes,2,opt,name=cursor_value,json=cursorValue,proto3" json:"cursor_value,omitempty"`
  253. HotType int64 `protobuf:"varint,3,opt,name=hot_type,json=hotType,proto3" json:"hot_type,omitempty"`
  254. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  255. XXX_unrecognized []byte `json:"-"`
  256. XXX_sizecache int32 `json:"-"`
  257. }
  258. func (m *VideoItem) Reset() { *m = VideoItem{} }
  259. func (m *VideoItem) String() string { return proto.CompactTextString(m) }
  260. func (*VideoItem) ProtoMessage() {}
  261. func (*VideoItem) Descriptor() ([]byte, []int) {
  262. return fileDescriptor_api_328ca58160a5beb9, []int{6}
  263. }
  264. func (m *VideoItem) XXX_Unmarshal(b []byte) error {
  265. return m.Unmarshal(b)
  266. }
  267. func (m *VideoItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  268. if deterministic {
  269. return xxx_messageInfo_VideoItem.Marshal(b, m, deterministic)
  270. } else {
  271. b = b[:cap(b)]
  272. n, err := m.MarshalTo(b)
  273. if err != nil {
  274. return nil, err
  275. }
  276. return b[:n], nil
  277. }
  278. }
  279. func (dst *VideoItem) XXX_Merge(src proto.Message) {
  280. xxx_messageInfo_VideoItem.Merge(dst, src)
  281. }
  282. func (m *VideoItem) XXX_Size() int {
  283. return m.Size()
  284. }
  285. func (m *VideoItem) XXX_DiscardUnknown() {
  286. xxx_messageInfo_VideoItem.DiscardUnknown(m)
  287. }
  288. var xxx_messageInfo_VideoItem proto.InternalMessageInfo
  289. type TopicDetail struct {
  290. TopicInfo *TopicInfo `protobuf:"bytes,1,opt,name=topic_info,json=topicInfo" json:"topic_info,omitempty"`
  291. List []*VideoItem `protobuf:"bytes,2,rep,name=list" json:"list,omitempty"`
  292. HasMore bool `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more"`
  293. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  294. XXX_unrecognized []byte `json:"-"`
  295. XXX_sizecache int32 `json:"-"`
  296. }
  297. func (m *TopicDetail) Reset() { *m = TopicDetail{} }
  298. func (m *TopicDetail) String() string { return proto.CompactTextString(m) }
  299. func (*TopicDetail) ProtoMessage() {}
  300. func (*TopicDetail) Descriptor() ([]byte, []int) {
  301. return fileDescriptor_api_328ca58160a5beb9, []int{7}
  302. }
  303. func (m *TopicDetail) XXX_Unmarshal(b []byte) error {
  304. return m.Unmarshal(b)
  305. }
  306. func (m *TopicDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  307. if deterministic {
  308. return xxx_messageInfo_TopicDetail.Marshal(b, m, deterministic)
  309. } else {
  310. b = b[:cap(b)]
  311. n, err := m.MarshalTo(b)
  312. if err != nil {
  313. return nil, err
  314. }
  315. return b[:n], nil
  316. }
  317. }
  318. func (dst *TopicDetail) XXX_Merge(src proto.Message) {
  319. xxx_messageInfo_TopicDetail.Merge(dst, src)
  320. }
  321. func (m *TopicDetail) XXX_Size() int {
  322. return m.Size()
  323. }
  324. func (m *TopicDetail) XXX_DiscardUnknown() {
  325. xxx_messageInfo_TopicDetail.DiscardUnknown(m)
  326. }
  327. var xxx_messageInfo_TopicDetail proto.InternalMessageInfo
  328. type ListDiscoveryTopicReq struct {
  329. Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty" form:"page" validate:"required"`
  330. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  331. XXX_unrecognized []byte `json:"-"`
  332. XXX_sizecache int32 `json:"-"`
  333. }
  334. func (m *ListDiscoveryTopicReq) Reset() { *m = ListDiscoveryTopicReq{} }
  335. func (m *ListDiscoveryTopicReq) String() string { return proto.CompactTextString(m) }
  336. func (*ListDiscoveryTopicReq) ProtoMessage() {}
  337. func (*ListDiscoveryTopicReq) Descriptor() ([]byte, []int) {
  338. return fileDescriptor_api_328ca58160a5beb9, []int{8}
  339. }
  340. func (m *ListDiscoveryTopicReq) XXX_Unmarshal(b []byte) error {
  341. return m.Unmarshal(b)
  342. }
  343. func (m *ListDiscoveryTopicReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  344. if deterministic {
  345. return xxx_messageInfo_ListDiscoveryTopicReq.Marshal(b, m, deterministic)
  346. } else {
  347. b = b[:cap(b)]
  348. n, err := m.MarshalTo(b)
  349. if err != nil {
  350. return nil, err
  351. }
  352. return b[:n], nil
  353. }
  354. }
  355. func (dst *ListDiscoveryTopicReq) XXX_Merge(src proto.Message) {
  356. xxx_messageInfo_ListDiscoveryTopicReq.Merge(dst, src)
  357. }
  358. func (m *ListDiscoveryTopicReq) XXX_Size() int {
  359. return m.Size()
  360. }
  361. func (m *ListDiscoveryTopicReq) XXX_DiscardUnknown() {
  362. xxx_messageInfo_ListDiscoveryTopicReq.DiscardUnknown(m)
  363. }
  364. var xxx_messageInfo_ListDiscoveryTopicReq proto.InternalMessageInfo
  365. type ListDiscoveryTopicReply struct {
  366. List []*TopicDetail `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
  367. HasMore bool `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
  368. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  369. XXX_unrecognized []byte `json:"-"`
  370. XXX_sizecache int32 `json:"-"`
  371. }
  372. func (m *ListDiscoveryTopicReply) Reset() { *m = ListDiscoveryTopicReply{} }
  373. func (m *ListDiscoveryTopicReply) String() string { return proto.CompactTextString(m) }
  374. func (*ListDiscoveryTopicReply) ProtoMessage() {}
  375. func (*ListDiscoveryTopicReply) Descriptor() ([]byte, []int) {
  376. return fileDescriptor_api_328ca58160a5beb9, []int{9}
  377. }
  378. func (m *ListDiscoveryTopicReply) XXX_Unmarshal(b []byte) error {
  379. return m.Unmarshal(b)
  380. }
  381. func (m *ListDiscoveryTopicReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  382. if deterministic {
  383. return xxx_messageInfo_ListDiscoveryTopicReply.Marshal(b, m, deterministic)
  384. } else {
  385. b = b[:cap(b)]
  386. n, err := m.MarshalTo(b)
  387. if err != nil {
  388. return nil, err
  389. }
  390. return b[:n], nil
  391. }
  392. }
  393. func (dst *ListDiscoveryTopicReply) XXX_Merge(src proto.Message) {
  394. xxx_messageInfo_ListDiscoveryTopicReply.Merge(dst, src)
  395. }
  396. func (m *ListDiscoveryTopicReply) XXX_Size() int {
  397. return m.Size()
  398. }
  399. func (m *ListDiscoveryTopicReply) XXX_DiscardUnknown() {
  400. xxx_messageInfo_ListDiscoveryTopicReply.DiscardUnknown(m)
  401. }
  402. var xxx_messageInfo_ListDiscoveryTopicReply proto.InternalMessageInfo
  403. type ListTopicsReq struct {
  404. Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty" form:"page" validate:"required"`
  405. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  406. XXX_unrecognized []byte `json:"-"`
  407. XXX_sizecache int32 `json:"-"`
  408. }
  409. func (m *ListTopicsReq) Reset() { *m = ListTopicsReq{} }
  410. func (m *ListTopicsReq) String() string { return proto.CompactTextString(m) }
  411. func (*ListTopicsReq) ProtoMessage() {}
  412. func (*ListTopicsReq) Descriptor() ([]byte, []int) {
  413. return fileDescriptor_api_328ca58160a5beb9, []int{10}
  414. }
  415. func (m *ListTopicsReq) XXX_Unmarshal(b []byte) error {
  416. return m.Unmarshal(b)
  417. }
  418. func (m *ListTopicsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  419. if deterministic {
  420. return xxx_messageInfo_ListTopicsReq.Marshal(b, m, deterministic)
  421. } else {
  422. b = b[:cap(b)]
  423. n, err := m.MarshalTo(b)
  424. if err != nil {
  425. return nil, err
  426. }
  427. return b[:n], nil
  428. }
  429. }
  430. func (dst *ListTopicsReq) XXX_Merge(src proto.Message) {
  431. xxx_messageInfo_ListTopicsReq.Merge(dst, src)
  432. }
  433. func (m *ListTopicsReq) XXX_Size() int {
  434. return m.Size()
  435. }
  436. func (m *ListTopicsReq) XXX_DiscardUnknown() {
  437. xxx_messageInfo_ListTopicsReq.DiscardUnknown(m)
  438. }
  439. var xxx_messageInfo_ListTopicsReq proto.InternalMessageInfo
  440. type ListTopicsReply struct {
  441. HasMore bool `protobuf:"varint,1,opt,name=has_more,json=hasMore,proto3" json:"has_more"`
  442. List []*TopicInfo `protobuf:"bytes,2,rep,name=list" json:"list,omitempty"`
  443. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  444. XXX_unrecognized []byte `json:"-"`
  445. XXX_sizecache int32 `json:"-"`
  446. }
  447. func (m *ListTopicsReply) Reset() { *m = ListTopicsReply{} }
  448. func (m *ListTopicsReply) String() string { return proto.CompactTextString(m) }
  449. func (*ListTopicsReply) ProtoMessage() {}
  450. func (*ListTopicsReply) Descriptor() ([]byte, []int) {
  451. return fileDescriptor_api_328ca58160a5beb9, []int{11}
  452. }
  453. func (m *ListTopicsReply) XXX_Unmarshal(b []byte) error {
  454. return m.Unmarshal(b)
  455. }
  456. func (m *ListTopicsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  457. if deterministic {
  458. return xxx_messageInfo_ListTopicsReply.Marshal(b, m, deterministic)
  459. } else {
  460. b = b[:cap(b)]
  461. n, err := m.MarshalTo(b)
  462. if err != nil {
  463. return nil, err
  464. }
  465. return b[:n], nil
  466. }
  467. }
  468. func (dst *ListTopicsReply) XXX_Merge(src proto.Message) {
  469. xxx_messageInfo_ListTopicsReply.Merge(dst, src)
  470. }
  471. func (m *ListTopicsReply) XXX_Size() int {
  472. return m.Size()
  473. }
  474. func (m *ListTopicsReply) XXX_DiscardUnknown() {
  475. xxx_messageInfo_ListTopicsReply.DiscardUnknown(m)
  476. }
  477. var xxx_messageInfo_ListTopicsReply proto.InternalMessageInfo
  478. type StickTopicReq struct {
  479. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id" validate:"required"`
  480. Op int64 `protobuf:"varint,2,opt,name=op,proto3" json:"op,omitempty" form:"op"`
  481. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  482. XXX_unrecognized []byte `json:"-"`
  483. XXX_sizecache int32 `json:"-"`
  484. }
  485. func (m *StickTopicReq) Reset() { *m = StickTopicReq{} }
  486. func (m *StickTopicReq) String() string { return proto.CompactTextString(m) }
  487. func (*StickTopicReq) ProtoMessage() {}
  488. func (*StickTopicReq) Descriptor() ([]byte, []int) {
  489. return fileDescriptor_api_328ca58160a5beb9, []int{12}
  490. }
  491. func (m *StickTopicReq) XXX_Unmarshal(b []byte) error {
  492. return m.Unmarshal(b)
  493. }
  494. func (m *StickTopicReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  495. if deterministic {
  496. return xxx_messageInfo_StickTopicReq.Marshal(b, m, deterministic)
  497. } else {
  498. b = b[:cap(b)]
  499. n, err := m.MarshalTo(b)
  500. if err != nil {
  501. return nil, err
  502. }
  503. return b[:n], nil
  504. }
  505. }
  506. func (dst *StickTopicReq) XXX_Merge(src proto.Message) {
  507. xxx_messageInfo_StickTopicReq.Merge(dst, src)
  508. }
  509. func (m *StickTopicReq) XXX_Size() int {
  510. return m.Size()
  511. }
  512. func (m *StickTopicReq) XXX_DiscardUnknown() {
  513. xxx_messageInfo_StickTopicReq.DiscardUnknown(m)
  514. }
  515. var xxx_messageInfo_StickTopicReq proto.InternalMessageInfo
  516. type StickTopicVideoReq struct {
  517. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id" validate:"required"`
  518. Svid int64 `protobuf:"varint,2,opt,name=svid,proto3" json:"svid,omitempty" form:"svid" validate:"required"`
  519. Op int64 `protobuf:"varint,3,opt,name=op,proto3" json:"op,omitempty" form:"op"`
  520. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  521. XXX_unrecognized []byte `json:"-"`
  522. XXX_sizecache int32 `json:"-"`
  523. }
  524. func (m *StickTopicVideoReq) Reset() { *m = StickTopicVideoReq{} }
  525. func (m *StickTopicVideoReq) String() string { return proto.CompactTextString(m) }
  526. func (*StickTopicVideoReq) ProtoMessage() {}
  527. func (*StickTopicVideoReq) Descriptor() ([]byte, []int) {
  528. return fileDescriptor_api_328ca58160a5beb9, []int{13}
  529. }
  530. func (m *StickTopicVideoReq) XXX_Unmarshal(b []byte) error {
  531. return m.Unmarshal(b)
  532. }
  533. func (m *StickTopicVideoReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  534. if deterministic {
  535. return xxx_messageInfo_StickTopicVideoReq.Marshal(b, m, deterministic)
  536. } else {
  537. b = b[:cap(b)]
  538. n, err := m.MarshalTo(b)
  539. if err != nil {
  540. return nil, err
  541. }
  542. return b[:n], nil
  543. }
  544. }
  545. func (dst *StickTopicVideoReq) XXX_Merge(src proto.Message) {
  546. xxx_messageInfo_StickTopicVideoReq.Merge(dst, src)
  547. }
  548. func (m *StickTopicVideoReq) XXX_Size() int {
  549. return m.Size()
  550. }
  551. func (m *StickTopicVideoReq) XXX_DiscardUnknown() {
  552. xxx_messageInfo_StickTopicVideoReq.DiscardUnknown(m)
  553. }
  554. var xxx_messageInfo_StickTopicVideoReq proto.InternalMessageInfo
  555. type SetStickTopicVideoReq struct {
  556. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id" validate:"required"`
  557. Svids []int64 `protobuf:"varint,2,rep,packed,name=svids" json:"svids,omitempty" form:"svids"`
  558. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  559. XXX_unrecognized []byte `json:"-"`
  560. XXX_sizecache int32 `json:"-"`
  561. }
  562. func (m *SetStickTopicVideoReq) Reset() { *m = SetStickTopicVideoReq{} }
  563. func (m *SetStickTopicVideoReq) String() string { return proto.CompactTextString(m) }
  564. func (*SetStickTopicVideoReq) ProtoMessage() {}
  565. func (*SetStickTopicVideoReq) Descriptor() ([]byte, []int) {
  566. return fileDescriptor_api_328ca58160a5beb9, []int{14}
  567. }
  568. func (m *SetStickTopicVideoReq) XXX_Unmarshal(b []byte) error {
  569. return m.Unmarshal(b)
  570. }
  571. func (m *SetStickTopicVideoReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  572. if deterministic {
  573. return xxx_messageInfo_SetStickTopicVideoReq.Marshal(b, m, deterministic)
  574. } else {
  575. b = b[:cap(b)]
  576. n, err := m.MarshalTo(b)
  577. if err != nil {
  578. return nil, err
  579. }
  580. return b[:n], nil
  581. }
  582. }
  583. func (dst *SetStickTopicVideoReq) XXX_Merge(src proto.Message) {
  584. xxx_messageInfo_SetStickTopicVideoReq.Merge(dst, src)
  585. }
  586. func (m *SetStickTopicVideoReq) XXX_Size() int {
  587. return m.Size()
  588. }
  589. func (m *SetStickTopicVideoReq) XXX_DiscardUnknown() {
  590. xxx_messageInfo_SetStickTopicVideoReq.DiscardUnknown(m)
  591. }
  592. var xxx_messageInfo_SetStickTopicVideoReq proto.InternalMessageInfo
  593. // 所有查找走同一个接口
  594. type ListCmsTopicsReq struct {
  595. Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty" form:"page" validate:"required"`
  596. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" form:"name"`
  597. TopicId int64 `protobuf:"varint,3,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id"`
  598. State int32 `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty" form:"state"`
  599. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  600. XXX_unrecognized []byte `json:"-"`
  601. XXX_sizecache int32 `json:"-"`
  602. }
  603. func (m *ListCmsTopicsReq) Reset() { *m = ListCmsTopicsReq{} }
  604. func (m *ListCmsTopicsReq) String() string { return proto.CompactTextString(m) }
  605. func (*ListCmsTopicsReq) ProtoMessage() {}
  606. func (*ListCmsTopicsReq) Descriptor() ([]byte, []int) {
  607. return fileDescriptor_api_328ca58160a5beb9, []int{15}
  608. }
  609. func (m *ListCmsTopicsReq) XXX_Unmarshal(b []byte) error {
  610. return m.Unmarshal(b)
  611. }
  612. func (m *ListCmsTopicsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  613. if deterministic {
  614. return xxx_messageInfo_ListCmsTopicsReq.Marshal(b, m, deterministic)
  615. } else {
  616. b = b[:cap(b)]
  617. n, err := m.MarshalTo(b)
  618. if err != nil {
  619. return nil, err
  620. }
  621. return b[:n], nil
  622. }
  623. }
  624. func (dst *ListCmsTopicsReq) XXX_Merge(src proto.Message) {
  625. xxx_messageInfo_ListCmsTopicsReq.Merge(dst, src)
  626. }
  627. func (m *ListCmsTopicsReq) XXX_Size() int {
  628. return m.Size()
  629. }
  630. func (m *ListCmsTopicsReq) XXX_DiscardUnknown() {
  631. xxx_messageInfo_ListCmsTopicsReq.DiscardUnknown(m)
  632. }
  633. var xxx_messageInfo_ListCmsTopicsReq proto.InternalMessageInfo
  634. type ListCmsTopicsReply struct {
  635. HasMore bool `protobuf:"varint,1,opt,name=has_more,json=hasMore,proto3" json:"has_more"`
  636. List []*TopicInfo `protobuf:"bytes,2,rep,name=list" json:"list,omitempty"`
  637. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  638. XXX_unrecognized []byte `json:"-"`
  639. XXX_sizecache int32 `json:"-"`
  640. }
  641. func (m *ListCmsTopicsReply) Reset() { *m = ListCmsTopicsReply{} }
  642. func (m *ListCmsTopicsReply) String() string { return proto.CompactTextString(m) }
  643. func (*ListCmsTopicsReply) ProtoMessage() {}
  644. func (*ListCmsTopicsReply) Descriptor() ([]byte, []int) {
  645. return fileDescriptor_api_328ca58160a5beb9, []int{16}
  646. }
  647. func (m *ListCmsTopicsReply) XXX_Unmarshal(b []byte) error {
  648. return m.Unmarshal(b)
  649. }
  650. func (m *ListCmsTopicsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  651. if deterministic {
  652. return xxx_messageInfo_ListCmsTopicsReply.Marshal(b, m, deterministic)
  653. } else {
  654. b = b[:cap(b)]
  655. n, err := m.MarshalTo(b)
  656. if err != nil {
  657. return nil, err
  658. }
  659. return b[:n], nil
  660. }
  661. }
  662. func (dst *ListCmsTopicsReply) XXX_Merge(src proto.Message) {
  663. xxx_messageInfo_ListCmsTopicsReply.Merge(dst, src)
  664. }
  665. func (m *ListCmsTopicsReply) XXX_Size() int {
  666. return m.Size()
  667. }
  668. func (m *ListCmsTopicsReply) XXX_DiscardUnknown() {
  669. xxx_messageInfo_ListCmsTopicsReply.DiscardUnknown(m)
  670. }
  671. var xxx_messageInfo_ListCmsTopicsReply proto.InternalMessageInfo
  672. type TopicVideoItem struct {
  673. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
  674. Svid int64 `protobuf:"varint,2,opt,name=svid,proto3" json:"svid,omitempty"`
  675. Score float64 `protobuf:"fixed64,3,opt,name=score,proto3" json:"score,omitempty"`
  676. State int32 `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty"`
  677. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  678. XXX_unrecognized []byte `json:"-"`
  679. XXX_sizecache int32 `json:"-"`
  680. }
  681. func (m *TopicVideoItem) Reset() { *m = TopicVideoItem{} }
  682. func (m *TopicVideoItem) String() string { return proto.CompactTextString(m) }
  683. func (*TopicVideoItem) ProtoMessage() {}
  684. func (*TopicVideoItem) Descriptor() ([]byte, []int) {
  685. return fileDescriptor_api_328ca58160a5beb9, []int{17}
  686. }
  687. func (m *TopicVideoItem) XXX_Unmarshal(b []byte) error {
  688. return m.Unmarshal(b)
  689. }
  690. func (m *TopicVideoItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  691. if deterministic {
  692. return xxx_messageInfo_TopicVideoItem.Marshal(b, m, deterministic)
  693. } else {
  694. b = b[:cap(b)]
  695. n, err := m.MarshalTo(b)
  696. if err != nil {
  697. return nil, err
  698. }
  699. return b[:n], nil
  700. }
  701. }
  702. func (dst *TopicVideoItem) XXX_Merge(src proto.Message) {
  703. xxx_messageInfo_TopicVideoItem.Merge(dst, src)
  704. }
  705. func (m *TopicVideoItem) XXX_Size() int {
  706. return m.Size()
  707. }
  708. func (m *TopicVideoItem) XXX_DiscardUnknown() {
  709. xxx_messageInfo_TopicVideoItem.DiscardUnknown(m)
  710. }
  711. var xxx_messageInfo_TopicVideoItem proto.InternalMessageInfo
  712. type VideoTopicReq struct {
  713. Svid int64 `protobuf:"varint,1,opt,name=svid,proto3" json:"svid,omitempty" form:"svid"`
  714. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  715. XXX_unrecognized []byte `json:"-"`
  716. XXX_sizecache int32 `json:"-"`
  717. }
  718. func (m *VideoTopicReq) Reset() { *m = VideoTopicReq{} }
  719. func (m *VideoTopicReq) String() string { return proto.CompactTextString(m) }
  720. func (*VideoTopicReq) ProtoMessage() {}
  721. func (*VideoTopicReq) Descriptor() ([]byte, []int) {
  722. return fileDescriptor_api_328ca58160a5beb9, []int{18}
  723. }
  724. func (m *VideoTopicReq) XXX_Unmarshal(b []byte) error {
  725. return m.Unmarshal(b)
  726. }
  727. func (m *VideoTopicReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  728. if deterministic {
  729. return xxx_messageInfo_VideoTopicReq.Marshal(b, m, deterministic)
  730. } else {
  731. b = b[:cap(b)]
  732. n, err := m.MarshalTo(b)
  733. if err != nil {
  734. return nil, err
  735. }
  736. return b[:n], nil
  737. }
  738. }
  739. func (dst *VideoTopicReq) XXX_Merge(src proto.Message) {
  740. xxx_messageInfo_VideoTopicReq.Merge(dst, src)
  741. }
  742. func (m *VideoTopicReq) XXX_Size() int {
  743. return m.Size()
  744. }
  745. func (m *VideoTopicReq) XXX_DiscardUnknown() {
  746. xxx_messageInfo_VideoTopicReq.DiscardUnknown(m)
  747. }
  748. var xxx_messageInfo_VideoTopicReq proto.InternalMessageInfo
  749. type VideoTopicReply struct {
  750. List []*TopicVideoItem `protobuf:"bytes,1,rep,name=list" json:"list,omitempty"`
  751. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  752. XXX_unrecognized []byte `json:"-"`
  753. XXX_sizecache int32 `json:"-"`
  754. }
  755. func (m *VideoTopicReply) Reset() { *m = VideoTopicReply{} }
  756. func (m *VideoTopicReply) String() string { return proto.CompactTextString(m) }
  757. func (*VideoTopicReply) ProtoMessage() {}
  758. func (*VideoTopicReply) Descriptor() ([]byte, []int) {
  759. return fileDescriptor_api_328ca58160a5beb9, []int{19}
  760. }
  761. func (m *VideoTopicReply) XXX_Unmarshal(b []byte) error {
  762. return m.Unmarshal(b)
  763. }
  764. func (m *VideoTopicReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  765. if deterministic {
  766. return xxx_messageInfo_VideoTopicReply.Marshal(b, m, deterministic)
  767. } else {
  768. b = b[:cap(b)]
  769. n, err := m.MarshalTo(b)
  770. if err != nil {
  771. return nil, err
  772. }
  773. return b[:n], nil
  774. }
  775. }
  776. func (dst *VideoTopicReply) XXX_Merge(src proto.Message) {
  777. xxx_messageInfo_VideoTopicReply.Merge(dst, src)
  778. }
  779. func (m *VideoTopicReply) XXX_Size() int {
  780. return m.Size()
  781. }
  782. func (m *VideoTopicReply) XXX_DiscardUnknown() {
  783. xxx_messageInfo_VideoTopicReply.DiscardUnknown(m)
  784. }
  785. var xxx_messageInfo_VideoTopicReply proto.InternalMessageInfo
  786. type UpdateTopicStateReq struct {
  787. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id"`
  788. Op int32 `protobuf:"varint,2,opt,name=op,proto3" json:"op,omitempty" form:"op"`
  789. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  790. XXX_unrecognized []byte `json:"-"`
  791. XXX_sizecache int32 `json:"-"`
  792. }
  793. func (m *UpdateTopicStateReq) Reset() { *m = UpdateTopicStateReq{} }
  794. func (m *UpdateTopicStateReq) String() string { return proto.CompactTextString(m) }
  795. func (*UpdateTopicStateReq) ProtoMessage() {}
  796. func (*UpdateTopicStateReq) Descriptor() ([]byte, []int) {
  797. return fileDescriptor_api_328ca58160a5beb9, []int{20}
  798. }
  799. func (m *UpdateTopicStateReq) XXX_Unmarshal(b []byte) error {
  800. return m.Unmarshal(b)
  801. }
  802. func (m *UpdateTopicStateReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  803. if deterministic {
  804. return xxx_messageInfo_UpdateTopicStateReq.Marshal(b, m, deterministic)
  805. } else {
  806. b = b[:cap(b)]
  807. n, err := m.MarshalTo(b)
  808. if err != nil {
  809. return nil, err
  810. }
  811. return b[:n], nil
  812. }
  813. }
  814. func (dst *UpdateTopicStateReq) XXX_Merge(src proto.Message) {
  815. xxx_messageInfo_UpdateTopicStateReq.Merge(dst, src)
  816. }
  817. func (m *UpdateTopicStateReq) XXX_Size() int {
  818. return m.Size()
  819. }
  820. func (m *UpdateTopicStateReq) XXX_DiscardUnknown() {
  821. xxx_messageInfo_UpdateTopicStateReq.DiscardUnknown(m)
  822. }
  823. var xxx_messageInfo_UpdateTopicStateReq proto.InternalMessageInfo
  824. type TopicInfo struct {
  825. TopicId int64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty" form:"topic_id"`
  826. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
  827. Desc string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty" form:"desc"`
  828. Score float64 `protobuf:"fixed64,4,opt,name=score,proto3" json:"score,omitempty"`
  829. State int32 `protobuf:"varint,5,opt,name=state,proto3" json:"state,omitempty" form:"state"`
  830. HotType int32 `protobuf:"varint,6,opt,name=hot_type,json=hotType,proto3" json:"hot_type"`
  831. CoverUrl string `protobuf:"bytes,7,opt,name=cover_url,json=coverUrl,proto3" json:"cover_url,omitempty" form:"cover_url"`
  832. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  833. XXX_unrecognized []byte `json:"-"`
  834. XXX_sizecache int32 `json:"-"`
  835. }
  836. func (m *TopicInfo) Reset() { *m = TopicInfo{} }
  837. func (m *TopicInfo) String() string { return proto.CompactTextString(m) }
  838. func (*TopicInfo) ProtoMessage() {}
  839. func (*TopicInfo) Descriptor() ([]byte, []int) {
  840. return fileDescriptor_api_328ca58160a5beb9, []int{21}
  841. }
  842. func (m *TopicInfo) XXX_Unmarshal(b []byte) error {
  843. return m.Unmarshal(b)
  844. }
  845. func (m *TopicInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  846. if deterministic {
  847. return xxx_messageInfo_TopicInfo.Marshal(b, m, deterministic)
  848. } else {
  849. b = b[:cap(b)]
  850. n, err := m.MarshalTo(b)
  851. if err != nil {
  852. return nil, err
  853. }
  854. return b[:n], nil
  855. }
  856. }
  857. func (dst *TopicInfo) XXX_Merge(src proto.Message) {
  858. xxx_messageInfo_TopicInfo.Merge(dst, src)
  859. }
  860. func (m *TopicInfo) XXX_Size() int {
  861. return m.Size()
  862. }
  863. func (m *TopicInfo) XXX_DiscardUnknown() {
  864. xxx_messageInfo_TopicInfo.DiscardUnknown(m)
  865. }
  866. var xxx_messageInfo_TopicInfo proto.InternalMessageInfo
  867. type TitleExtraItem struct {
  868. Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
  869. Type int64 `protobuf:"varint,2,opt,name=type,proto3" json:"type"`
  870. Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name"`
  871. Start int64 `protobuf:"varint,4,opt,name=start,proto3" json:"start"`
  872. End int64 `protobuf:"varint,5,opt,name=end,proto3" json:"end"`
  873. Scheme string `protobuf:"bytes,6,opt,name=scheme,proto3" json:"scheme"`
  874. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  875. XXX_unrecognized []byte `json:"-"`
  876. XXX_sizecache int32 `json:"-"`
  877. }
  878. func (m *TitleExtraItem) Reset() { *m = TitleExtraItem{} }
  879. func (m *TitleExtraItem) String() string { return proto.CompactTextString(m) }
  880. func (*TitleExtraItem) ProtoMessage() {}
  881. func (*TitleExtraItem) Descriptor() ([]byte, []int) {
  882. return fileDescriptor_api_328ca58160a5beb9, []int{22}
  883. }
  884. func (m *TitleExtraItem) XXX_Unmarshal(b []byte) error {
  885. return m.Unmarshal(b)
  886. }
  887. func (m *TitleExtraItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  888. if deterministic {
  889. return xxx_messageInfo_TitleExtraItem.Marshal(b, m, deterministic)
  890. } else {
  891. b = b[:cap(b)]
  892. n, err := m.MarshalTo(b)
  893. if err != nil {
  894. return nil, err
  895. }
  896. return b[:n], nil
  897. }
  898. }
  899. func (dst *TitleExtraItem) XXX_Merge(src proto.Message) {
  900. xxx_messageInfo_TitleExtraItem.Merge(dst, src)
  901. }
  902. func (m *TitleExtraItem) XXX_Size() int {
  903. return m.Size()
  904. }
  905. func (m *TitleExtraItem) XXX_DiscardUnknown() {
  906. xxx_messageInfo_TitleExtraItem.DiscardUnknown(m)
  907. }
  908. var xxx_messageInfo_TitleExtraItem proto.InternalMessageInfo
  909. // 用于传递给上游的extension,通过序列化赋值给extension
  910. type VideoExtension struct {
  911. Svid int64 `protobuf:"varint,1,opt,name=svid,proto3" json:"svid,omitempty"`
  912. Extension string `protobuf:"bytes,2,opt,name=extension,proto3" json:"extension,omitempty"`
  913. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  914. XXX_unrecognized []byte `json:"-"`
  915. XXX_sizecache int32 `json:"-"`
  916. }
  917. func (m *VideoExtension) Reset() { *m = VideoExtension{} }
  918. func (m *VideoExtension) String() string { return proto.CompactTextString(m) }
  919. func (*VideoExtension) ProtoMessage() {}
  920. func (*VideoExtension) Descriptor() ([]byte, []int) {
  921. return fileDescriptor_api_328ca58160a5beb9, []int{23}
  922. }
  923. func (m *VideoExtension) XXX_Unmarshal(b []byte) error {
  924. return m.Unmarshal(b)
  925. }
  926. func (m *VideoExtension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  927. if deterministic {
  928. return xxx_messageInfo_VideoExtension.Marshal(b, m, deterministic)
  929. } else {
  930. b = b[:cap(b)]
  931. n, err := m.MarshalTo(b)
  932. if err != nil {
  933. return nil, err
  934. }
  935. return b[:n], nil
  936. }
  937. }
  938. func (dst *VideoExtension) XXX_Merge(src proto.Message) {
  939. xxx_messageInfo_VideoExtension.Merge(dst, src)
  940. }
  941. func (m *VideoExtension) XXX_Size() int {
  942. return m.Size()
  943. }
  944. func (m *VideoExtension) XXX_DiscardUnknown() {
  945. xxx_messageInfo_VideoExtension.DiscardUnknown(m)
  946. }
  947. var xxx_messageInfo_VideoExtension proto.InternalMessageInfo
  948. // 结构化的extension,真正的extension
  949. type Extension struct {
  950. TitleExtra []*TitleExtraItem `protobuf:"bytes,1,rep,name=title_extra,json=titleExtra" json:"title_extra,omitempty"`
  951. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  952. XXX_unrecognized []byte `json:"-"`
  953. XXX_sizecache int32 `json:"-"`
  954. }
  955. func (m *Extension) Reset() { *m = Extension{} }
  956. func (m *Extension) String() string { return proto.CompactTextString(m) }
  957. func (*Extension) ProtoMessage() {}
  958. func (*Extension) Descriptor() ([]byte, []int) {
  959. return fileDescriptor_api_328ca58160a5beb9, []int{24}
  960. }
  961. func (m *Extension) XXX_Unmarshal(b []byte) error {
  962. return m.Unmarshal(b)
  963. }
  964. func (m *Extension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  965. if deterministic {
  966. return xxx_messageInfo_Extension.Marshal(b, m, deterministic)
  967. } else {
  968. b = b[:cap(b)]
  969. n, err := m.MarshalTo(b)
  970. if err != nil {
  971. return nil, err
  972. }
  973. return b[:n], nil
  974. }
  975. }
  976. func (dst *Extension) XXX_Merge(src proto.Message) {
  977. xxx_messageInfo_Extension.Merge(dst, src)
  978. }
  979. func (m *Extension) XXX_Size() int {
  980. return m.Size()
  981. }
  982. func (m *Extension) XXX_DiscardUnknown() {
  983. xxx_messageInfo_Extension.DiscardUnknown(m)
  984. }
  985. var xxx_messageInfo_Extension proto.InternalMessageInfo
  986. func init() {
  987. proto.RegisterType((*ListExtensionReq)(nil), "bbq.service.topic.v1.ListExtensionReq")
  988. proto.RegisterType((*ListExtensionReply)(nil), "bbq.service.topic.v1.ListExtensionReply")
  989. proto.RegisterType((*UpdateVideoScoreReq)(nil), "bbq.service.topic.v1.UpdateVideoScoreReq")
  990. proto.RegisterType((*UpdateVideoStateReq)(nil), "bbq.service.topic.v1.UpdateVideoStateReq")
  991. proto.RegisterType((*TopicVideosReq)(nil), "bbq.service.topic.v1.TopicVideosReq")
  992. proto.RegisterType((*ListMultiTopicVideosReq)(nil), "bbq.service.topic.v1.ListMultiTopicVideosReq")
  993. proto.RegisterType((*VideoItem)(nil), "bbq.service.topic.v1.VideoItem")
  994. proto.RegisterType((*TopicDetail)(nil), "bbq.service.topic.v1.TopicDetail")
  995. proto.RegisterType((*ListDiscoveryTopicReq)(nil), "bbq.service.topic.v1.ListDiscoveryTopicReq")
  996. proto.RegisterType((*ListDiscoveryTopicReply)(nil), "bbq.service.topic.v1.ListDiscoveryTopicReply")
  997. proto.RegisterType((*ListTopicsReq)(nil), "bbq.service.topic.v1.ListTopicsReq")
  998. proto.RegisterType((*ListTopicsReply)(nil), "bbq.service.topic.v1.ListTopicsReply")
  999. proto.RegisterType((*StickTopicReq)(nil), "bbq.service.topic.v1.StickTopicReq")
  1000. proto.RegisterType((*StickTopicVideoReq)(nil), "bbq.service.topic.v1.StickTopicVideoReq")
  1001. proto.RegisterType((*SetStickTopicVideoReq)(nil), "bbq.service.topic.v1.SetStickTopicVideoReq")
  1002. proto.RegisterType((*ListCmsTopicsReq)(nil), "bbq.service.topic.v1.ListCmsTopicsReq")
  1003. proto.RegisterType((*ListCmsTopicsReply)(nil), "bbq.service.topic.v1.ListCmsTopicsReply")
  1004. proto.RegisterType((*TopicVideoItem)(nil), "bbq.service.topic.v1.TopicVideoItem")
  1005. proto.RegisterType((*VideoTopicReq)(nil), "bbq.service.topic.v1.VideoTopicReq")
  1006. proto.RegisterType((*VideoTopicReply)(nil), "bbq.service.topic.v1.VideoTopicReply")
  1007. proto.RegisterType((*UpdateTopicStateReq)(nil), "bbq.service.topic.v1.UpdateTopicStateReq")
  1008. proto.RegisterType((*TopicInfo)(nil), "bbq.service.topic.v1.TopicInfo")
  1009. proto.RegisterType((*TitleExtraItem)(nil), "bbq.service.topic.v1.TitleExtraItem")
  1010. proto.RegisterType((*VideoExtension)(nil), "bbq.service.topic.v1.VideoExtension")
  1011. proto.RegisterType((*Extension)(nil), "bbq.service.topic.v1.Extension")
  1012. }
  1013. // Reference imports to suppress errors if they are not otherwise used.
  1014. var _ context.Context
  1015. var _ grpc.ClientConn
  1016. // This is a compile-time assertion to ensure that this generated file
  1017. // is compatible with the grpc package it is being compiled against.
  1018. const _ = grpc.SupportPackageIsVersion4
  1019. // TopicClient is the client API for Topic service.
  1020. //
  1021. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1022. type TopicClient interface {
  1023. // //////////////extension////////////////
  1024. Register(ctx context.Context, in *VideoExtension, opts ...grpc.CallOption) (*empty.Empty, error)
  1025. ListExtension(ctx context.Context, in *ListExtensionReq, opts ...grpc.CallOption) (*ListExtensionReply, error)
  1026. // ////////////////topic///////////////////
  1027. UpdateVideoScore(ctx context.Context, in *UpdateVideoScoreReq, opts ...grpc.CallOption) (*empty.Empty, error)
  1028. UpdateVideoState(ctx context.Context, in *UpdateVideoStateReq, opts ...grpc.CallOption) (*empty.Empty, error)
  1029. // 获取话题下的视频
  1030. ListTopicVideos(ctx context.Context, in *TopicVideosReq, opts ...grpc.CallOption) (*TopicDetail, error)
  1031. // TODO: to deleted. 发现页分成先请求话题,再请求话题下视频
  1032. // 获取发现页下的话题
  1033. ListDiscoveryTopics(ctx context.Context, in *ListDiscoveryTopicReq, opts ...grpc.CallOption) (*ListDiscoveryTopicReply, error)
  1034. // 推荐的话题,不会返回话题内的视频
  1035. ListTopics(ctx context.Context, in *ListTopicsReq, opts ...grpc.CallOption) (*ListTopicsReply, error)
  1036. // /// cms /////
  1037. StickTopic(ctx context.Context, in *StickTopicReq, opts ...grpc.CallOption) (*empty.Empty, error)
  1038. // 置顶、取消置顶话题下的视频(需要cms先去判断该视频是否可以放在话题中)
  1039. StickTopicVideo(ctx context.Context, in *StickTopicVideoReq, opts ...grpc.CallOption) (*empty.Empty, error)
  1040. SetStickTopicVideo(ctx context.Context, in *SetStickTopicVideoReq, opts ...grpc.CallOption) (*empty.Empty, error)
  1041. // 注意:该接口不支持复杂条件,当以下三种同时请求的时候只会按顺序选择一种进行返回:
  1042. // 话题name查找接口,不区分隐藏,返回数组,但是暂时只会完全匹配,
  1043. // 话题隐藏列表接口,按照时间反向排序
  1044. // 话题推荐列表接口,按照热度反向排序,其中第一页会包含置顶话题
  1045. ListCmsTopics(ctx context.Context, in *ListCmsTopicsReq, opts ...grpc.CallOption) (*ListCmsTopicsReply, error)
  1046. // 修改话题简介,topic_id必传传,直接放在http请求里
  1047. UpdateTopicDesc(ctx context.Context, in *TopicInfo, opts ...grpc.CallOption) (*empty.Empty, error)
  1048. UpdateTopicState(ctx context.Context, in *TopicInfo, opts ...grpc.CallOption) (*empty.Empty, error)
  1049. // 根据svid返回topic_id列表
  1050. VideoTopic(ctx context.Context, in *VideoTopicReq, opts ...grpc.CallOption) (*VideoTopicReply, error)
  1051. }
  1052. type topicClient struct {
  1053. cc *grpc.ClientConn
  1054. }
  1055. func NewTopicClient(cc *grpc.ClientConn) TopicClient {
  1056. return &topicClient{cc}
  1057. }
  1058. func (c *topicClient) Register(ctx context.Context, in *VideoExtension, opts ...grpc.CallOption) (*empty.Empty, error) {
  1059. out := new(empty.Empty)
  1060. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/Register", in, out, opts...)
  1061. if err != nil {
  1062. return nil, err
  1063. }
  1064. return out, nil
  1065. }
  1066. func (c *topicClient) ListExtension(ctx context.Context, in *ListExtensionReq, opts ...grpc.CallOption) (*ListExtensionReply, error) {
  1067. out := new(ListExtensionReply)
  1068. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/ListExtension", in, out, opts...)
  1069. if err != nil {
  1070. return nil, err
  1071. }
  1072. return out, nil
  1073. }
  1074. func (c *topicClient) UpdateVideoScore(ctx context.Context, in *UpdateVideoScoreReq, opts ...grpc.CallOption) (*empty.Empty, error) {
  1075. out := new(empty.Empty)
  1076. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/UpdateVideoScore", in, out, opts...)
  1077. if err != nil {
  1078. return nil, err
  1079. }
  1080. return out, nil
  1081. }
  1082. func (c *topicClient) UpdateVideoState(ctx context.Context, in *UpdateVideoStateReq, opts ...grpc.CallOption) (*empty.Empty, error) {
  1083. out := new(empty.Empty)
  1084. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/UpdateVideoState", in, out, opts...)
  1085. if err != nil {
  1086. return nil, err
  1087. }
  1088. return out, nil
  1089. }
  1090. func (c *topicClient) ListTopicVideos(ctx context.Context, in *TopicVideosReq, opts ...grpc.CallOption) (*TopicDetail, error) {
  1091. out := new(TopicDetail)
  1092. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/ListTopicVideos", in, out, opts...)
  1093. if err != nil {
  1094. return nil, err
  1095. }
  1096. return out, nil
  1097. }
  1098. func (c *topicClient) ListDiscoveryTopics(ctx context.Context, in *ListDiscoveryTopicReq, opts ...grpc.CallOption) (*ListDiscoveryTopicReply, error) {
  1099. out := new(ListDiscoveryTopicReply)
  1100. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/ListDiscoveryTopics", in, out, opts...)
  1101. if err != nil {
  1102. return nil, err
  1103. }
  1104. return out, nil
  1105. }
  1106. func (c *topicClient) ListTopics(ctx context.Context, in *ListTopicsReq, opts ...grpc.CallOption) (*ListTopicsReply, error) {
  1107. out := new(ListTopicsReply)
  1108. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/ListTopics", in, out, opts...)
  1109. if err != nil {
  1110. return nil, err
  1111. }
  1112. return out, nil
  1113. }
  1114. func (c *topicClient) StickTopic(ctx context.Context, in *StickTopicReq, opts ...grpc.CallOption) (*empty.Empty, error) {
  1115. out := new(empty.Empty)
  1116. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/StickTopic", in, out, opts...)
  1117. if err != nil {
  1118. return nil, err
  1119. }
  1120. return out, nil
  1121. }
  1122. func (c *topicClient) StickTopicVideo(ctx context.Context, in *StickTopicVideoReq, opts ...grpc.CallOption) (*empty.Empty, error) {
  1123. out := new(empty.Empty)
  1124. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/StickTopicVideo", in, out, opts...)
  1125. if err != nil {
  1126. return nil, err
  1127. }
  1128. return out, nil
  1129. }
  1130. func (c *topicClient) SetStickTopicVideo(ctx context.Context, in *SetStickTopicVideoReq, opts ...grpc.CallOption) (*empty.Empty, error) {
  1131. out := new(empty.Empty)
  1132. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/SetStickTopicVideo", in, out, opts...)
  1133. if err != nil {
  1134. return nil, err
  1135. }
  1136. return out, nil
  1137. }
  1138. func (c *topicClient) ListCmsTopics(ctx context.Context, in *ListCmsTopicsReq, opts ...grpc.CallOption) (*ListCmsTopicsReply, error) {
  1139. out := new(ListCmsTopicsReply)
  1140. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/ListCmsTopics", in, out, opts...)
  1141. if err != nil {
  1142. return nil, err
  1143. }
  1144. return out, nil
  1145. }
  1146. func (c *topicClient) UpdateTopicDesc(ctx context.Context, in *TopicInfo, opts ...grpc.CallOption) (*empty.Empty, error) {
  1147. out := new(empty.Empty)
  1148. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/UpdateTopicDesc", in, out, opts...)
  1149. if err != nil {
  1150. return nil, err
  1151. }
  1152. return out, nil
  1153. }
  1154. func (c *topicClient) UpdateTopicState(ctx context.Context, in *TopicInfo, opts ...grpc.CallOption) (*empty.Empty, error) {
  1155. out := new(empty.Empty)
  1156. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/UpdateTopicState", in, out, opts...)
  1157. if err != nil {
  1158. return nil, err
  1159. }
  1160. return out, nil
  1161. }
  1162. func (c *topicClient) VideoTopic(ctx context.Context, in *VideoTopicReq, opts ...grpc.CallOption) (*VideoTopicReply, error) {
  1163. out := new(VideoTopicReply)
  1164. err := c.cc.Invoke(ctx, "/bbq.service.topic.v1.Topic/VideoTopic", in, out, opts...)
  1165. if err != nil {
  1166. return nil, err
  1167. }
  1168. return out, nil
  1169. }
  1170. // TopicServer is the server API for Topic service.
  1171. type TopicServer interface {
  1172. // //////////////extension////////////////
  1173. Register(context.Context, *VideoExtension) (*empty.Empty, error)
  1174. ListExtension(context.Context, *ListExtensionReq) (*ListExtensionReply, error)
  1175. // ////////////////topic///////////////////
  1176. UpdateVideoScore(context.Context, *UpdateVideoScoreReq) (*empty.Empty, error)
  1177. UpdateVideoState(context.Context, *UpdateVideoStateReq) (*empty.Empty, error)
  1178. // 获取话题下的视频
  1179. ListTopicVideos(context.Context, *TopicVideosReq) (*TopicDetail, error)
  1180. // TODO: to deleted. 发现页分成先请求话题,再请求话题下视频
  1181. // 获取发现页下的话题
  1182. ListDiscoveryTopics(context.Context, *ListDiscoveryTopicReq) (*ListDiscoveryTopicReply, error)
  1183. // 推荐的话题,不会返回话题内的视频
  1184. ListTopics(context.Context, *ListTopicsReq) (*ListTopicsReply, error)
  1185. // /// cms /////
  1186. StickTopic(context.Context, *StickTopicReq) (*empty.Empty, error)
  1187. // 置顶、取消置顶话题下的视频(需要cms先去判断该视频是否可以放在话题中)
  1188. StickTopicVideo(context.Context, *StickTopicVideoReq) (*empty.Empty, error)
  1189. SetStickTopicVideo(context.Context, *SetStickTopicVideoReq) (*empty.Empty, error)
  1190. // 注意:该接口不支持复杂条件,当以下三种同时请求的时候只会按顺序选择一种进行返回:
  1191. // 话题name查找接口,不区分隐藏,返回数组,但是暂时只会完全匹配,
  1192. // 话题隐藏列表接口,按照时间反向排序
  1193. // 话题推荐列表接口,按照热度反向排序,其中第一页会包含置顶话题
  1194. ListCmsTopics(context.Context, *ListCmsTopicsReq) (*ListCmsTopicsReply, error)
  1195. // 修改话题简介,topic_id必传传,直接放在http请求里
  1196. UpdateTopicDesc(context.Context, *TopicInfo) (*empty.Empty, error)
  1197. UpdateTopicState(context.Context, *TopicInfo) (*empty.Empty, error)
  1198. // 根据svid返回topic_id列表
  1199. VideoTopic(context.Context, *VideoTopicReq) (*VideoTopicReply, error)
  1200. }
  1201. func RegisterTopicServer(s *grpc.Server, srv TopicServer) {
  1202. s.RegisterService(&_Topic_serviceDesc, srv)
  1203. }
  1204. func _Topic_Register_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1205. in := new(VideoExtension)
  1206. if err := dec(in); err != nil {
  1207. return nil, err
  1208. }
  1209. if interceptor == nil {
  1210. return srv.(TopicServer).Register(ctx, in)
  1211. }
  1212. info := &grpc.UnaryServerInfo{
  1213. Server: srv,
  1214. FullMethod: "/bbq.service.topic.v1.Topic/Register",
  1215. }
  1216. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1217. return srv.(TopicServer).Register(ctx, req.(*VideoExtension))
  1218. }
  1219. return interceptor(ctx, in, info, handler)
  1220. }
  1221. func _Topic_ListExtension_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1222. in := new(ListExtensionReq)
  1223. if err := dec(in); err != nil {
  1224. return nil, err
  1225. }
  1226. if interceptor == nil {
  1227. return srv.(TopicServer).ListExtension(ctx, in)
  1228. }
  1229. info := &grpc.UnaryServerInfo{
  1230. Server: srv,
  1231. FullMethod: "/bbq.service.topic.v1.Topic/ListExtension",
  1232. }
  1233. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1234. return srv.(TopicServer).ListExtension(ctx, req.(*ListExtensionReq))
  1235. }
  1236. return interceptor(ctx, in, info, handler)
  1237. }
  1238. func _Topic_UpdateVideoScore_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1239. in := new(UpdateVideoScoreReq)
  1240. if err := dec(in); err != nil {
  1241. return nil, err
  1242. }
  1243. if interceptor == nil {
  1244. return srv.(TopicServer).UpdateVideoScore(ctx, in)
  1245. }
  1246. info := &grpc.UnaryServerInfo{
  1247. Server: srv,
  1248. FullMethod: "/bbq.service.topic.v1.Topic/UpdateVideoScore",
  1249. }
  1250. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1251. return srv.(TopicServer).UpdateVideoScore(ctx, req.(*UpdateVideoScoreReq))
  1252. }
  1253. return interceptor(ctx, in, info, handler)
  1254. }
  1255. func _Topic_UpdateVideoState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1256. in := new(UpdateVideoStateReq)
  1257. if err := dec(in); err != nil {
  1258. return nil, err
  1259. }
  1260. if interceptor == nil {
  1261. return srv.(TopicServer).UpdateVideoState(ctx, in)
  1262. }
  1263. info := &grpc.UnaryServerInfo{
  1264. Server: srv,
  1265. FullMethod: "/bbq.service.topic.v1.Topic/UpdateVideoState",
  1266. }
  1267. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1268. return srv.(TopicServer).UpdateVideoState(ctx, req.(*UpdateVideoStateReq))
  1269. }
  1270. return interceptor(ctx, in, info, handler)
  1271. }
  1272. func _Topic_ListTopicVideos_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1273. in := new(TopicVideosReq)
  1274. if err := dec(in); err != nil {
  1275. return nil, err
  1276. }
  1277. if interceptor == nil {
  1278. return srv.(TopicServer).ListTopicVideos(ctx, in)
  1279. }
  1280. info := &grpc.UnaryServerInfo{
  1281. Server: srv,
  1282. FullMethod: "/bbq.service.topic.v1.Topic/ListTopicVideos",
  1283. }
  1284. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1285. return srv.(TopicServer).ListTopicVideos(ctx, req.(*TopicVideosReq))
  1286. }
  1287. return interceptor(ctx, in, info, handler)
  1288. }
  1289. func _Topic_ListDiscoveryTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1290. in := new(ListDiscoveryTopicReq)
  1291. if err := dec(in); err != nil {
  1292. return nil, err
  1293. }
  1294. if interceptor == nil {
  1295. return srv.(TopicServer).ListDiscoveryTopics(ctx, in)
  1296. }
  1297. info := &grpc.UnaryServerInfo{
  1298. Server: srv,
  1299. FullMethod: "/bbq.service.topic.v1.Topic/ListDiscoveryTopics",
  1300. }
  1301. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1302. return srv.(TopicServer).ListDiscoveryTopics(ctx, req.(*ListDiscoveryTopicReq))
  1303. }
  1304. return interceptor(ctx, in, info, handler)
  1305. }
  1306. func _Topic_ListTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1307. in := new(ListTopicsReq)
  1308. if err := dec(in); err != nil {
  1309. return nil, err
  1310. }
  1311. if interceptor == nil {
  1312. return srv.(TopicServer).ListTopics(ctx, in)
  1313. }
  1314. info := &grpc.UnaryServerInfo{
  1315. Server: srv,
  1316. FullMethod: "/bbq.service.topic.v1.Topic/ListTopics",
  1317. }
  1318. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1319. return srv.(TopicServer).ListTopics(ctx, req.(*ListTopicsReq))
  1320. }
  1321. return interceptor(ctx, in, info, handler)
  1322. }
  1323. func _Topic_StickTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1324. in := new(StickTopicReq)
  1325. if err := dec(in); err != nil {
  1326. return nil, err
  1327. }
  1328. if interceptor == nil {
  1329. return srv.(TopicServer).StickTopic(ctx, in)
  1330. }
  1331. info := &grpc.UnaryServerInfo{
  1332. Server: srv,
  1333. FullMethod: "/bbq.service.topic.v1.Topic/StickTopic",
  1334. }
  1335. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1336. return srv.(TopicServer).StickTopic(ctx, req.(*StickTopicReq))
  1337. }
  1338. return interceptor(ctx, in, info, handler)
  1339. }
  1340. func _Topic_StickTopicVideo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1341. in := new(StickTopicVideoReq)
  1342. if err := dec(in); err != nil {
  1343. return nil, err
  1344. }
  1345. if interceptor == nil {
  1346. return srv.(TopicServer).StickTopicVideo(ctx, in)
  1347. }
  1348. info := &grpc.UnaryServerInfo{
  1349. Server: srv,
  1350. FullMethod: "/bbq.service.topic.v1.Topic/StickTopicVideo",
  1351. }
  1352. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1353. return srv.(TopicServer).StickTopicVideo(ctx, req.(*StickTopicVideoReq))
  1354. }
  1355. return interceptor(ctx, in, info, handler)
  1356. }
  1357. func _Topic_SetStickTopicVideo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1358. in := new(SetStickTopicVideoReq)
  1359. if err := dec(in); err != nil {
  1360. return nil, err
  1361. }
  1362. if interceptor == nil {
  1363. return srv.(TopicServer).SetStickTopicVideo(ctx, in)
  1364. }
  1365. info := &grpc.UnaryServerInfo{
  1366. Server: srv,
  1367. FullMethod: "/bbq.service.topic.v1.Topic/SetStickTopicVideo",
  1368. }
  1369. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1370. return srv.(TopicServer).SetStickTopicVideo(ctx, req.(*SetStickTopicVideoReq))
  1371. }
  1372. return interceptor(ctx, in, info, handler)
  1373. }
  1374. func _Topic_ListCmsTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1375. in := new(ListCmsTopicsReq)
  1376. if err := dec(in); err != nil {
  1377. return nil, err
  1378. }
  1379. if interceptor == nil {
  1380. return srv.(TopicServer).ListCmsTopics(ctx, in)
  1381. }
  1382. info := &grpc.UnaryServerInfo{
  1383. Server: srv,
  1384. FullMethod: "/bbq.service.topic.v1.Topic/ListCmsTopics",
  1385. }
  1386. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1387. return srv.(TopicServer).ListCmsTopics(ctx, req.(*ListCmsTopicsReq))
  1388. }
  1389. return interceptor(ctx, in, info, handler)
  1390. }
  1391. func _Topic_UpdateTopicDesc_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1392. in := new(TopicInfo)
  1393. if err := dec(in); err != nil {
  1394. return nil, err
  1395. }
  1396. if interceptor == nil {
  1397. return srv.(TopicServer).UpdateTopicDesc(ctx, in)
  1398. }
  1399. info := &grpc.UnaryServerInfo{
  1400. Server: srv,
  1401. FullMethod: "/bbq.service.topic.v1.Topic/UpdateTopicDesc",
  1402. }
  1403. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1404. return srv.(TopicServer).UpdateTopicDesc(ctx, req.(*TopicInfo))
  1405. }
  1406. return interceptor(ctx, in, info, handler)
  1407. }
  1408. func _Topic_UpdateTopicState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1409. in := new(TopicInfo)
  1410. if err := dec(in); err != nil {
  1411. return nil, err
  1412. }
  1413. if interceptor == nil {
  1414. return srv.(TopicServer).UpdateTopicState(ctx, in)
  1415. }
  1416. info := &grpc.UnaryServerInfo{
  1417. Server: srv,
  1418. FullMethod: "/bbq.service.topic.v1.Topic/UpdateTopicState",
  1419. }
  1420. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1421. return srv.(TopicServer).UpdateTopicState(ctx, req.(*TopicInfo))
  1422. }
  1423. return interceptor(ctx, in, info, handler)
  1424. }
  1425. func _Topic_VideoTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1426. in := new(VideoTopicReq)
  1427. if err := dec(in); err != nil {
  1428. return nil, err
  1429. }
  1430. if interceptor == nil {
  1431. return srv.(TopicServer).VideoTopic(ctx, in)
  1432. }
  1433. info := &grpc.UnaryServerInfo{
  1434. Server: srv,
  1435. FullMethod: "/bbq.service.topic.v1.Topic/VideoTopic",
  1436. }
  1437. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1438. return srv.(TopicServer).VideoTopic(ctx, req.(*VideoTopicReq))
  1439. }
  1440. return interceptor(ctx, in, info, handler)
  1441. }
  1442. var _Topic_serviceDesc = grpc.ServiceDesc{
  1443. ServiceName: "bbq.service.topic.v1.Topic",
  1444. HandlerType: (*TopicServer)(nil),
  1445. Methods: []grpc.MethodDesc{
  1446. {
  1447. MethodName: "Register",
  1448. Handler: _Topic_Register_Handler,
  1449. },
  1450. {
  1451. MethodName: "ListExtension",
  1452. Handler: _Topic_ListExtension_Handler,
  1453. },
  1454. {
  1455. MethodName: "UpdateVideoScore",
  1456. Handler: _Topic_UpdateVideoScore_Handler,
  1457. },
  1458. {
  1459. MethodName: "UpdateVideoState",
  1460. Handler: _Topic_UpdateVideoState_Handler,
  1461. },
  1462. {
  1463. MethodName: "ListTopicVideos",
  1464. Handler: _Topic_ListTopicVideos_Handler,
  1465. },
  1466. {
  1467. MethodName: "ListDiscoveryTopics",
  1468. Handler: _Topic_ListDiscoveryTopics_Handler,
  1469. },
  1470. {
  1471. MethodName: "ListTopics",
  1472. Handler: _Topic_ListTopics_Handler,
  1473. },
  1474. {
  1475. MethodName: "StickTopic",
  1476. Handler: _Topic_StickTopic_Handler,
  1477. },
  1478. {
  1479. MethodName: "StickTopicVideo",
  1480. Handler: _Topic_StickTopicVideo_Handler,
  1481. },
  1482. {
  1483. MethodName: "SetStickTopicVideo",
  1484. Handler: _Topic_SetStickTopicVideo_Handler,
  1485. },
  1486. {
  1487. MethodName: "ListCmsTopics",
  1488. Handler: _Topic_ListCmsTopics_Handler,
  1489. },
  1490. {
  1491. MethodName: "UpdateTopicDesc",
  1492. Handler: _Topic_UpdateTopicDesc_Handler,
  1493. },
  1494. {
  1495. MethodName: "UpdateTopicState",
  1496. Handler: _Topic_UpdateTopicState_Handler,
  1497. },
  1498. {
  1499. MethodName: "VideoTopic",
  1500. Handler: _Topic_VideoTopic_Handler,
  1501. },
  1502. },
  1503. Streams: []grpc.StreamDesc{},
  1504. Metadata: "app/service/bbq/topic/api/api.proto",
  1505. }
  1506. func (m *ListExtensionReq) Marshal() (dAtA []byte, err error) {
  1507. size := m.Size()
  1508. dAtA = make([]byte, size)
  1509. n, err := m.MarshalTo(dAtA)
  1510. if err != nil {
  1511. return nil, err
  1512. }
  1513. return dAtA[:n], nil
  1514. }
  1515. func (m *ListExtensionReq) MarshalTo(dAtA []byte) (int, error) {
  1516. var i int
  1517. _ = i
  1518. var l int
  1519. _ = l
  1520. if len(m.Svids) > 0 {
  1521. dAtA2 := make([]byte, len(m.Svids)*10)
  1522. var j1 int
  1523. for _, num1 := range m.Svids {
  1524. num := uint64(num1)
  1525. for num >= 1<<7 {
  1526. dAtA2[j1] = uint8(uint64(num)&0x7f | 0x80)
  1527. num >>= 7
  1528. j1++
  1529. }
  1530. dAtA2[j1] = uint8(num)
  1531. j1++
  1532. }
  1533. dAtA[i] = 0xa
  1534. i++
  1535. i = encodeVarintApi(dAtA, i, uint64(j1))
  1536. i += copy(dAtA[i:], dAtA2[:j1])
  1537. }
  1538. if m.XXX_unrecognized != nil {
  1539. i += copy(dAtA[i:], m.XXX_unrecognized)
  1540. }
  1541. return i, nil
  1542. }
  1543. func (m *ListExtensionReply) Marshal() (dAtA []byte, err error) {
  1544. size := m.Size()
  1545. dAtA = make([]byte, size)
  1546. n, err := m.MarshalTo(dAtA)
  1547. if err != nil {
  1548. return nil, err
  1549. }
  1550. return dAtA[:n], nil
  1551. }
  1552. func (m *ListExtensionReply) MarshalTo(dAtA []byte) (int, error) {
  1553. var i int
  1554. _ = i
  1555. var l int
  1556. _ = l
  1557. if len(m.List) > 0 {
  1558. for _, msg := range m.List {
  1559. dAtA[i] = 0xa
  1560. i++
  1561. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  1562. n, err := msg.MarshalTo(dAtA[i:])
  1563. if err != nil {
  1564. return 0, err
  1565. }
  1566. i += n
  1567. }
  1568. }
  1569. if m.XXX_unrecognized != nil {
  1570. i += copy(dAtA[i:], m.XXX_unrecognized)
  1571. }
  1572. return i, nil
  1573. }
  1574. func (m *UpdateVideoScoreReq) Marshal() (dAtA []byte, err error) {
  1575. size := m.Size()
  1576. dAtA = make([]byte, size)
  1577. n, err := m.MarshalTo(dAtA)
  1578. if err != nil {
  1579. return nil, err
  1580. }
  1581. return dAtA[:n], nil
  1582. }
  1583. func (m *UpdateVideoScoreReq) MarshalTo(dAtA []byte) (int, error) {
  1584. var i int
  1585. _ = i
  1586. var l int
  1587. _ = l
  1588. if m.Svid != 0 {
  1589. dAtA[i] = 0x8
  1590. i++
  1591. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  1592. }
  1593. if m.Score != 0 {
  1594. dAtA[i] = 0x11
  1595. i++
  1596. encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.Score))))
  1597. i += 8
  1598. }
  1599. if m.XXX_unrecognized != nil {
  1600. i += copy(dAtA[i:], m.XXX_unrecognized)
  1601. }
  1602. return i, nil
  1603. }
  1604. func (m *UpdateVideoStateReq) Marshal() (dAtA []byte, err error) {
  1605. size := m.Size()
  1606. dAtA = make([]byte, size)
  1607. n, err := m.MarshalTo(dAtA)
  1608. if err != nil {
  1609. return nil, err
  1610. }
  1611. return dAtA[:n], nil
  1612. }
  1613. func (m *UpdateVideoStateReq) MarshalTo(dAtA []byte) (int, error) {
  1614. var i int
  1615. _ = i
  1616. var l int
  1617. _ = l
  1618. if m.Svid != 0 {
  1619. dAtA[i] = 0x8
  1620. i++
  1621. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  1622. }
  1623. if m.State != 0 {
  1624. dAtA[i] = 0x10
  1625. i++
  1626. i = encodeVarintApi(dAtA, i, uint64(m.State))
  1627. }
  1628. if m.XXX_unrecognized != nil {
  1629. i += copy(dAtA[i:], m.XXX_unrecognized)
  1630. }
  1631. return i, nil
  1632. }
  1633. func (m *TopicVideosReq) Marshal() (dAtA []byte, err error) {
  1634. size := m.Size()
  1635. dAtA = make([]byte, size)
  1636. n, err := m.MarshalTo(dAtA)
  1637. if err != nil {
  1638. return nil, err
  1639. }
  1640. return dAtA[:n], nil
  1641. }
  1642. func (m *TopicVideosReq) MarshalTo(dAtA []byte) (int, error) {
  1643. var i int
  1644. _ = i
  1645. var l int
  1646. _ = l
  1647. if m.TopicId != 0 {
  1648. dAtA[i] = 0x8
  1649. i++
  1650. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  1651. }
  1652. if len(m.CursorPrev) > 0 {
  1653. dAtA[i] = 0x12
  1654. i++
  1655. i = encodeVarintApi(dAtA, i, uint64(len(m.CursorPrev)))
  1656. i += copy(dAtA[i:], m.CursorPrev)
  1657. }
  1658. if len(m.CursorNext) > 0 {
  1659. dAtA[i] = 0x1a
  1660. i++
  1661. i = encodeVarintApi(dAtA, i, uint64(len(m.CursorNext)))
  1662. i += copy(dAtA[i:], m.CursorNext)
  1663. }
  1664. if m.XXX_unrecognized != nil {
  1665. i += copy(dAtA[i:], m.XXX_unrecognized)
  1666. }
  1667. return i, nil
  1668. }
  1669. func (m *ListMultiTopicVideosReq) Marshal() (dAtA []byte, err error) {
  1670. size := m.Size()
  1671. dAtA = make([]byte, size)
  1672. n, err := m.MarshalTo(dAtA)
  1673. if err != nil {
  1674. return nil, err
  1675. }
  1676. return dAtA[:n], nil
  1677. }
  1678. func (m *ListMultiTopicVideosReq) MarshalTo(dAtA []byte) (int, error) {
  1679. var i int
  1680. _ = i
  1681. var l int
  1682. _ = l
  1683. if len(m.List) > 0 {
  1684. for _, msg := range m.List {
  1685. dAtA[i] = 0xa
  1686. i++
  1687. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  1688. n, err := msg.MarshalTo(dAtA[i:])
  1689. if err != nil {
  1690. return 0, err
  1691. }
  1692. i += n
  1693. }
  1694. }
  1695. if m.XXX_unrecognized != nil {
  1696. i += copy(dAtA[i:], m.XXX_unrecognized)
  1697. }
  1698. return i, nil
  1699. }
  1700. func (m *VideoItem) Marshal() (dAtA []byte, err error) {
  1701. size := m.Size()
  1702. dAtA = make([]byte, size)
  1703. n, err := m.MarshalTo(dAtA)
  1704. if err != nil {
  1705. return nil, err
  1706. }
  1707. return dAtA[:n], nil
  1708. }
  1709. func (m *VideoItem) MarshalTo(dAtA []byte) (int, error) {
  1710. var i int
  1711. _ = i
  1712. var l int
  1713. _ = l
  1714. if m.Svid != 0 {
  1715. dAtA[i] = 0x8
  1716. i++
  1717. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  1718. }
  1719. if len(m.CursorValue) > 0 {
  1720. dAtA[i] = 0x12
  1721. i++
  1722. i = encodeVarintApi(dAtA, i, uint64(len(m.CursorValue)))
  1723. i += copy(dAtA[i:], m.CursorValue)
  1724. }
  1725. if m.HotType != 0 {
  1726. dAtA[i] = 0x18
  1727. i++
  1728. i = encodeVarintApi(dAtA, i, uint64(m.HotType))
  1729. }
  1730. if m.XXX_unrecognized != nil {
  1731. i += copy(dAtA[i:], m.XXX_unrecognized)
  1732. }
  1733. return i, nil
  1734. }
  1735. func (m *TopicDetail) Marshal() (dAtA []byte, err error) {
  1736. size := m.Size()
  1737. dAtA = make([]byte, size)
  1738. n, err := m.MarshalTo(dAtA)
  1739. if err != nil {
  1740. return nil, err
  1741. }
  1742. return dAtA[:n], nil
  1743. }
  1744. func (m *TopicDetail) MarshalTo(dAtA []byte) (int, error) {
  1745. var i int
  1746. _ = i
  1747. var l int
  1748. _ = l
  1749. if m.TopicInfo != nil {
  1750. dAtA[i] = 0xa
  1751. i++
  1752. i = encodeVarintApi(dAtA, i, uint64(m.TopicInfo.Size()))
  1753. n3, err := m.TopicInfo.MarshalTo(dAtA[i:])
  1754. if err != nil {
  1755. return 0, err
  1756. }
  1757. i += n3
  1758. }
  1759. if len(m.List) > 0 {
  1760. for _, msg := range m.List {
  1761. dAtA[i] = 0x12
  1762. i++
  1763. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  1764. n, err := msg.MarshalTo(dAtA[i:])
  1765. if err != nil {
  1766. return 0, err
  1767. }
  1768. i += n
  1769. }
  1770. }
  1771. if m.HasMore {
  1772. dAtA[i] = 0x18
  1773. i++
  1774. if m.HasMore {
  1775. dAtA[i] = 1
  1776. } else {
  1777. dAtA[i] = 0
  1778. }
  1779. i++
  1780. }
  1781. if m.XXX_unrecognized != nil {
  1782. i += copy(dAtA[i:], m.XXX_unrecognized)
  1783. }
  1784. return i, nil
  1785. }
  1786. func (m *ListDiscoveryTopicReq) Marshal() (dAtA []byte, err error) {
  1787. size := m.Size()
  1788. dAtA = make([]byte, size)
  1789. n, err := m.MarshalTo(dAtA)
  1790. if err != nil {
  1791. return nil, err
  1792. }
  1793. return dAtA[:n], nil
  1794. }
  1795. func (m *ListDiscoveryTopicReq) MarshalTo(dAtA []byte) (int, error) {
  1796. var i int
  1797. _ = i
  1798. var l int
  1799. _ = l
  1800. if m.Page != 0 {
  1801. dAtA[i] = 0x8
  1802. i++
  1803. i = encodeVarintApi(dAtA, i, uint64(m.Page))
  1804. }
  1805. if m.XXX_unrecognized != nil {
  1806. i += copy(dAtA[i:], m.XXX_unrecognized)
  1807. }
  1808. return i, nil
  1809. }
  1810. func (m *ListDiscoveryTopicReply) Marshal() (dAtA []byte, err error) {
  1811. size := m.Size()
  1812. dAtA = make([]byte, size)
  1813. n, err := m.MarshalTo(dAtA)
  1814. if err != nil {
  1815. return nil, err
  1816. }
  1817. return dAtA[:n], nil
  1818. }
  1819. func (m *ListDiscoveryTopicReply) MarshalTo(dAtA []byte) (int, error) {
  1820. var i int
  1821. _ = i
  1822. var l int
  1823. _ = l
  1824. if len(m.List) > 0 {
  1825. for _, msg := range m.List {
  1826. dAtA[i] = 0xa
  1827. i++
  1828. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  1829. n, err := msg.MarshalTo(dAtA[i:])
  1830. if err != nil {
  1831. return 0, err
  1832. }
  1833. i += n
  1834. }
  1835. }
  1836. if m.HasMore {
  1837. dAtA[i] = 0x10
  1838. i++
  1839. if m.HasMore {
  1840. dAtA[i] = 1
  1841. } else {
  1842. dAtA[i] = 0
  1843. }
  1844. i++
  1845. }
  1846. if m.XXX_unrecognized != nil {
  1847. i += copy(dAtA[i:], m.XXX_unrecognized)
  1848. }
  1849. return i, nil
  1850. }
  1851. func (m *ListTopicsReq) Marshal() (dAtA []byte, err error) {
  1852. size := m.Size()
  1853. dAtA = make([]byte, size)
  1854. n, err := m.MarshalTo(dAtA)
  1855. if err != nil {
  1856. return nil, err
  1857. }
  1858. return dAtA[:n], nil
  1859. }
  1860. func (m *ListTopicsReq) MarshalTo(dAtA []byte) (int, error) {
  1861. var i int
  1862. _ = i
  1863. var l int
  1864. _ = l
  1865. if m.Page != 0 {
  1866. dAtA[i] = 0x8
  1867. i++
  1868. i = encodeVarintApi(dAtA, i, uint64(m.Page))
  1869. }
  1870. if m.XXX_unrecognized != nil {
  1871. i += copy(dAtA[i:], m.XXX_unrecognized)
  1872. }
  1873. return i, nil
  1874. }
  1875. func (m *ListTopicsReply) Marshal() (dAtA []byte, err error) {
  1876. size := m.Size()
  1877. dAtA = make([]byte, size)
  1878. n, err := m.MarshalTo(dAtA)
  1879. if err != nil {
  1880. return nil, err
  1881. }
  1882. return dAtA[:n], nil
  1883. }
  1884. func (m *ListTopicsReply) MarshalTo(dAtA []byte) (int, error) {
  1885. var i int
  1886. _ = i
  1887. var l int
  1888. _ = l
  1889. if m.HasMore {
  1890. dAtA[i] = 0x8
  1891. i++
  1892. if m.HasMore {
  1893. dAtA[i] = 1
  1894. } else {
  1895. dAtA[i] = 0
  1896. }
  1897. i++
  1898. }
  1899. if len(m.List) > 0 {
  1900. for _, msg := range m.List {
  1901. dAtA[i] = 0x12
  1902. i++
  1903. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  1904. n, err := msg.MarshalTo(dAtA[i:])
  1905. if err != nil {
  1906. return 0, err
  1907. }
  1908. i += n
  1909. }
  1910. }
  1911. if m.XXX_unrecognized != nil {
  1912. i += copy(dAtA[i:], m.XXX_unrecognized)
  1913. }
  1914. return i, nil
  1915. }
  1916. func (m *StickTopicReq) Marshal() (dAtA []byte, err error) {
  1917. size := m.Size()
  1918. dAtA = make([]byte, size)
  1919. n, err := m.MarshalTo(dAtA)
  1920. if err != nil {
  1921. return nil, err
  1922. }
  1923. return dAtA[:n], nil
  1924. }
  1925. func (m *StickTopicReq) MarshalTo(dAtA []byte) (int, error) {
  1926. var i int
  1927. _ = i
  1928. var l int
  1929. _ = l
  1930. if m.TopicId != 0 {
  1931. dAtA[i] = 0x8
  1932. i++
  1933. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  1934. }
  1935. if m.Op != 0 {
  1936. dAtA[i] = 0x10
  1937. i++
  1938. i = encodeVarintApi(dAtA, i, uint64(m.Op))
  1939. }
  1940. if m.XXX_unrecognized != nil {
  1941. i += copy(dAtA[i:], m.XXX_unrecognized)
  1942. }
  1943. return i, nil
  1944. }
  1945. func (m *StickTopicVideoReq) Marshal() (dAtA []byte, err error) {
  1946. size := m.Size()
  1947. dAtA = make([]byte, size)
  1948. n, err := m.MarshalTo(dAtA)
  1949. if err != nil {
  1950. return nil, err
  1951. }
  1952. return dAtA[:n], nil
  1953. }
  1954. func (m *StickTopicVideoReq) MarshalTo(dAtA []byte) (int, error) {
  1955. var i int
  1956. _ = i
  1957. var l int
  1958. _ = l
  1959. if m.TopicId != 0 {
  1960. dAtA[i] = 0x8
  1961. i++
  1962. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  1963. }
  1964. if m.Svid != 0 {
  1965. dAtA[i] = 0x10
  1966. i++
  1967. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  1968. }
  1969. if m.Op != 0 {
  1970. dAtA[i] = 0x18
  1971. i++
  1972. i = encodeVarintApi(dAtA, i, uint64(m.Op))
  1973. }
  1974. if m.XXX_unrecognized != nil {
  1975. i += copy(dAtA[i:], m.XXX_unrecognized)
  1976. }
  1977. return i, nil
  1978. }
  1979. func (m *SetStickTopicVideoReq) Marshal() (dAtA []byte, err error) {
  1980. size := m.Size()
  1981. dAtA = make([]byte, size)
  1982. n, err := m.MarshalTo(dAtA)
  1983. if err != nil {
  1984. return nil, err
  1985. }
  1986. return dAtA[:n], nil
  1987. }
  1988. func (m *SetStickTopicVideoReq) MarshalTo(dAtA []byte) (int, error) {
  1989. var i int
  1990. _ = i
  1991. var l int
  1992. _ = l
  1993. if m.TopicId != 0 {
  1994. dAtA[i] = 0x8
  1995. i++
  1996. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  1997. }
  1998. if len(m.Svids) > 0 {
  1999. dAtA5 := make([]byte, len(m.Svids)*10)
  2000. var j4 int
  2001. for _, num1 := range m.Svids {
  2002. num := uint64(num1)
  2003. for num >= 1<<7 {
  2004. dAtA5[j4] = uint8(uint64(num)&0x7f | 0x80)
  2005. num >>= 7
  2006. j4++
  2007. }
  2008. dAtA5[j4] = uint8(num)
  2009. j4++
  2010. }
  2011. dAtA[i] = 0x12
  2012. i++
  2013. i = encodeVarintApi(dAtA, i, uint64(j4))
  2014. i += copy(dAtA[i:], dAtA5[:j4])
  2015. }
  2016. if m.XXX_unrecognized != nil {
  2017. i += copy(dAtA[i:], m.XXX_unrecognized)
  2018. }
  2019. return i, nil
  2020. }
  2021. func (m *ListCmsTopicsReq) Marshal() (dAtA []byte, err error) {
  2022. size := m.Size()
  2023. dAtA = make([]byte, size)
  2024. n, err := m.MarshalTo(dAtA)
  2025. if err != nil {
  2026. return nil, err
  2027. }
  2028. return dAtA[:n], nil
  2029. }
  2030. func (m *ListCmsTopicsReq) MarshalTo(dAtA []byte) (int, error) {
  2031. var i int
  2032. _ = i
  2033. var l int
  2034. _ = l
  2035. if m.Page != 0 {
  2036. dAtA[i] = 0x8
  2037. i++
  2038. i = encodeVarintApi(dAtA, i, uint64(m.Page))
  2039. }
  2040. if len(m.Name) > 0 {
  2041. dAtA[i] = 0x12
  2042. i++
  2043. i = encodeVarintApi(dAtA, i, uint64(len(m.Name)))
  2044. i += copy(dAtA[i:], m.Name)
  2045. }
  2046. if m.TopicId != 0 {
  2047. dAtA[i] = 0x18
  2048. i++
  2049. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  2050. }
  2051. if m.State != 0 {
  2052. dAtA[i] = 0x20
  2053. i++
  2054. i = encodeVarintApi(dAtA, i, uint64(m.State))
  2055. }
  2056. if m.XXX_unrecognized != nil {
  2057. i += copy(dAtA[i:], m.XXX_unrecognized)
  2058. }
  2059. return i, nil
  2060. }
  2061. func (m *ListCmsTopicsReply) Marshal() (dAtA []byte, err error) {
  2062. size := m.Size()
  2063. dAtA = make([]byte, size)
  2064. n, err := m.MarshalTo(dAtA)
  2065. if err != nil {
  2066. return nil, err
  2067. }
  2068. return dAtA[:n], nil
  2069. }
  2070. func (m *ListCmsTopicsReply) MarshalTo(dAtA []byte) (int, error) {
  2071. var i int
  2072. _ = i
  2073. var l int
  2074. _ = l
  2075. if m.HasMore {
  2076. dAtA[i] = 0x8
  2077. i++
  2078. if m.HasMore {
  2079. dAtA[i] = 1
  2080. } else {
  2081. dAtA[i] = 0
  2082. }
  2083. i++
  2084. }
  2085. if len(m.List) > 0 {
  2086. for _, msg := range m.List {
  2087. dAtA[i] = 0x12
  2088. i++
  2089. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  2090. n, err := msg.MarshalTo(dAtA[i:])
  2091. if err != nil {
  2092. return 0, err
  2093. }
  2094. i += n
  2095. }
  2096. }
  2097. if m.XXX_unrecognized != nil {
  2098. i += copy(dAtA[i:], m.XXX_unrecognized)
  2099. }
  2100. return i, nil
  2101. }
  2102. func (m *TopicVideoItem) Marshal() (dAtA []byte, err error) {
  2103. size := m.Size()
  2104. dAtA = make([]byte, size)
  2105. n, err := m.MarshalTo(dAtA)
  2106. if err != nil {
  2107. return nil, err
  2108. }
  2109. return dAtA[:n], nil
  2110. }
  2111. func (m *TopicVideoItem) MarshalTo(dAtA []byte) (int, error) {
  2112. var i int
  2113. _ = i
  2114. var l int
  2115. _ = l
  2116. if m.TopicId != 0 {
  2117. dAtA[i] = 0x8
  2118. i++
  2119. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  2120. }
  2121. if m.Svid != 0 {
  2122. dAtA[i] = 0x10
  2123. i++
  2124. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  2125. }
  2126. if m.Score != 0 {
  2127. dAtA[i] = 0x19
  2128. i++
  2129. encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.Score))))
  2130. i += 8
  2131. }
  2132. if m.State != 0 {
  2133. dAtA[i] = 0x20
  2134. i++
  2135. i = encodeVarintApi(dAtA, i, uint64(m.State))
  2136. }
  2137. if m.XXX_unrecognized != nil {
  2138. i += copy(dAtA[i:], m.XXX_unrecognized)
  2139. }
  2140. return i, nil
  2141. }
  2142. func (m *VideoTopicReq) Marshal() (dAtA []byte, err error) {
  2143. size := m.Size()
  2144. dAtA = make([]byte, size)
  2145. n, err := m.MarshalTo(dAtA)
  2146. if err != nil {
  2147. return nil, err
  2148. }
  2149. return dAtA[:n], nil
  2150. }
  2151. func (m *VideoTopicReq) MarshalTo(dAtA []byte) (int, error) {
  2152. var i int
  2153. _ = i
  2154. var l int
  2155. _ = l
  2156. if m.Svid != 0 {
  2157. dAtA[i] = 0x8
  2158. i++
  2159. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  2160. }
  2161. if m.XXX_unrecognized != nil {
  2162. i += copy(dAtA[i:], m.XXX_unrecognized)
  2163. }
  2164. return i, nil
  2165. }
  2166. func (m *VideoTopicReply) Marshal() (dAtA []byte, err error) {
  2167. size := m.Size()
  2168. dAtA = make([]byte, size)
  2169. n, err := m.MarshalTo(dAtA)
  2170. if err != nil {
  2171. return nil, err
  2172. }
  2173. return dAtA[:n], nil
  2174. }
  2175. func (m *VideoTopicReply) MarshalTo(dAtA []byte) (int, error) {
  2176. var i int
  2177. _ = i
  2178. var l int
  2179. _ = l
  2180. if len(m.List) > 0 {
  2181. for _, msg := range m.List {
  2182. dAtA[i] = 0xa
  2183. i++
  2184. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  2185. n, err := msg.MarshalTo(dAtA[i:])
  2186. if err != nil {
  2187. return 0, err
  2188. }
  2189. i += n
  2190. }
  2191. }
  2192. if m.XXX_unrecognized != nil {
  2193. i += copy(dAtA[i:], m.XXX_unrecognized)
  2194. }
  2195. return i, nil
  2196. }
  2197. func (m *UpdateTopicStateReq) Marshal() (dAtA []byte, err error) {
  2198. size := m.Size()
  2199. dAtA = make([]byte, size)
  2200. n, err := m.MarshalTo(dAtA)
  2201. if err != nil {
  2202. return nil, err
  2203. }
  2204. return dAtA[:n], nil
  2205. }
  2206. func (m *UpdateTopicStateReq) MarshalTo(dAtA []byte) (int, error) {
  2207. var i int
  2208. _ = i
  2209. var l int
  2210. _ = l
  2211. if m.TopicId != 0 {
  2212. dAtA[i] = 0x8
  2213. i++
  2214. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  2215. }
  2216. if m.Op != 0 {
  2217. dAtA[i] = 0x10
  2218. i++
  2219. i = encodeVarintApi(dAtA, i, uint64(m.Op))
  2220. }
  2221. if m.XXX_unrecognized != nil {
  2222. i += copy(dAtA[i:], m.XXX_unrecognized)
  2223. }
  2224. return i, nil
  2225. }
  2226. func (m *TopicInfo) Marshal() (dAtA []byte, err error) {
  2227. size := m.Size()
  2228. dAtA = make([]byte, size)
  2229. n, err := m.MarshalTo(dAtA)
  2230. if err != nil {
  2231. return nil, err
  2232. }
  2233. return dAtA[:n], nil
  2234. }
  2235. func (m *TopicInfo) MarshalTo(dAtA []byte) (int, error) {
  2236. var i int
  2237. _ = i
  2238. var l int
  2239. _ = l
  2240. if m.TopicId != 0 {
  2241. dAtA[i] = 0x8
  2242. i++
  2243. i = encodeVarintApi(dAtA, i, uint64(m.TopicId))
  2244. }
  2245. if len(m.Name) > 0 {
  2246. dAtA[i] = 0x12
  2247. i++
  2248. i = encodeVarintApi(dAtA, i, uint64(len(m.Name)))
  2249. i += copy(dAtA[i:], m.Name)
  2250. }
  2251. if len(m.Desc) > 0 {
  2252. dAtA[i] = 0x1a
  2253. i++
  2254. i = encodeVarintApi(dAtA, i, uint64(len(m.Desc)))
  2255. i += copy(dAtA[i:], m.Desc)
  2256. }
  2257. if m.Score != 0 {
  2258. dAtA[i] = 0x21
  2259. i++
  2260. encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.Score))))
  2261. i += 8
  2262. }
  2263. if m.State != 0 {
  2264. dAtA[i] = 0x28
  2265. i++
  2266. i = encodeVarintApi(dAtA, i, uint64(m.State))
  2267. }
  2268. if m.HotType != 0 {
  2269. dAtA[i] = 0x30
  2270. i++
  2271. i = encodeVarintApi(dAtA, i, uint64(m.HotType))
  2272. }
  2273. if len(m.CoverUrl) > 0 {
  2274. dAtA[i] = 0x3a
  2275. i++
  2276. i = encodeVarintApi(dAtA, i, uint64(len(m.CoverUrl)))
  2277. i += copy(dAtA[i:], m.CoverUrl)
  2278. }
  2279. if m.XXX_unrecognized != nil {
  2280. i += copy(dAtA[i:], m.XXX_unrecognized)
  2281. }
  2282. return i, nil
  2283. }
  2284. func (m *TitleExtraItem) Marshal() (dAtA []byte, err error) {
  2285. size := m.Size()
  2286. dAtA = make([]byte, size)
  2287. n, err := m.MarshalTo(dAtA)
  2288. if err != nil {
  2289. return nil, err
  2290. }
  2291. return dAtA[:n], nil
  2292. }
  2293. func (m *TitleExtraItem) MarshalTo(dAtA []byte) (int, error) {
  2294. var i int
  2295. _ = i
  2296. var l int
  2297. _ = l
  2298. if m.Id != 0 {
  2299. dAtA[i] = 0x8
  2300. i++
  2301. i = encodeVarintApi(dAtA, i, uint64(m.Id))
  2302. }
  2303. if m.Type != 0 {
  2304. dAtA[i] = 0x10
  2305. i++
  2306. i = encodeVarintApi(dAtA, i, uint64(m.Type))
  2307. }
  2308. if len(m.Name) > 0 {
  2309. dAtA[i] = 0x1a
  2310. i++
  2311. i = encodeVarintApi(dAtA, i, uint64(len(m.Name)))
  2312. i += copy(dAtA[i:], m.Name)
  2313. }
  2314. if m.Start != 0 {
  2315. dAtA[i] = 0x20
  2316. i++
  2317. i = encodeVarintApi(dAtA, i, uint64(m.Start))
  2318. }
  2319. if m.End != 0 {
  2320. dAtA[i] = 0x28
  2321. i++
  2322. i = encodeVarintApi(dAtA, i, uint64(m.End))
  2323. }
  2324. if len(m.Scheme) > 0 {
  2325. dAtA[i] = 0x32
  2326. i++
  2327. i = encodeVarintApi(dAtA, i, uint64(len(m.Scheme)))
  2328. i += copy(dAtA[i:], m.Scheme)
  2329. }
  2330. if m.XXX_unrecognized != nil {
  2331. i += copy(dAtA[i:], m.XXX_unrecognized)
  2332. }
  2333. return i, nil
  2334. }
  2335. func (m *VideoExtension) Marshal() (dAtA []byte, err error) {
  2336. size := m.Size()
  2337. dAtA = make([]byte, size)
  2338. n, err := m.MarshalTo(dAtA)
  2339. if err != nil {
  2340. return nil, err
  2341. }
  2342. return dAtA[:n], nil
  2343. }
  2344. func (m *VideoExtension) MarshalTo(dAtA []byte) (int, error) {
  2345. var i int
  2346. _ = i
  2347. var l int
  2348. _ = l
  2349. if m.Svid != 0 {
  2350. dAtA[i] = 0x8
  2351. i++
  2352. i = encodeVarintApi(dAtA, i, uint64(m.Svid))
  2353. }
  2354. if len(m.Extension) > 0 {
  2355. dAtA[i] = 0x12
  2356. i++
  2357. i = encodeVarintApi(dAtA, i, uint64(len(m.Extension)))
  2358. i += copy(dAtA[i:], m.Extension)
  2359. }
  2360. if m.XXX_unrecognized != nil {
  2361. i += copy(dAtA[i:], m.XXX_unrecognized)
  2362. }
  2363. return i, nil
  2364. }
  2365. func (m *Extension) Marshal() (dAtA []byte, err error) {
  2366. size := m.Size()
  2367. dAtA = make([]byte, size)
  2368. n, err := m.MarshalTo(dAtA)
  2369. if err != nil {
  2370. return nil, err
  2371. }
  2372. return dAtA[:n], nil
  2373. }
  2374. func (m *Extension) MarshalTo(dAtA []byte) (int, error) {
  2375. var i int
  2376. _ = i
  2377. var l int
  2378. _ = l
  2379. if len(m.TitleExtra) > 0 {
  2380. for _, msg := range m.TitleExtra {
  2381. dAtA[i] = 0xa
  2382. i++
  2383. i = encodeVarintApi(dAtA, i, uint64(msg.Size()))
  2384. n, err := msg.MarshalTo(dAtA[i:])
  2385. if err != nil {
  2386. return 0, err
  2387. }
  2388. i += n
  2389. }
  2390. }
  2391. if m.XXX_unrecognized != nil {
  2392. i += copy(dAtA[i:], m.XXX_unrecognized)
  2393. }
  2394. return i, nil
  2395. }
  2396. func encodeVarintApi(dAtA []byte, offset int, v uint64) int {
  2397. for v >= 1<<7 {
  2398. dAtA[offset] = uint8(v&0x7f | 0x80)
  2399. v >>= 7
  2400. offset++
  2401. }
  2402. dAtA[offset] = uint8(v)
  2403. return offset + 1
  2404. }
  2405. func (m *ListExtensionReq) Size() (n int) {
  2406. if m == nil {
  2407. return 0
  2408. }
  2409. var l int
  2410. _ = l
  2411. if len(m.Svids) > 0 {
  2412. l = 0
  2413. for _, e := range m.Svids {
  2414. l += sovApi(uint64(e))
  2415. }
  2416. n += 1 + sovApi(uint64(l)) + l
  2417. }
  2418. if m.XXX_unrecognized != nil {
  2419. n += len(m.XXX_unrecognized)
  2420. }
  2421. return n
  2422. }
  2423. func (m *ListExtensionReply) Size() (n int) {
  2424. if m == nil {
  2425. return 0
  2426. }
  2427. var l int
  2428. _ = l
  2429. if len(m.List) > 0 {
  2430. for _, e := range m.List {
  2431. l = e.Size()
  2432. n += 1 + l + sovApi(uint64(l))
  2433. }
  2434. }
  2435. if m.XXX_unrecognized != nil {
  2436. n += len(m.XXX_unrecognized)
  2437. }
  2438. return n
  2439. }
  2440. func (m *UpdateVideoScoreReq) Size() (n int) {
  2441. if m == nil {
  2442. return 0
  2443. }
  2444. var l int
  2445. _ = l
  2446. if m.Svid != 0 {
  2447. n += 1 + sovApi(uint64(m.Svid))
  2448. }
  2449. if m.Score != 0 {
  2450. n += 9
  2451. }
  2452. if m.XXX_unrecognized != nil {
  2453. n += len(m.XXX_unrecognized)
  2454. }
  2455. return n
  2456. }
  2457. func (m *UpdateVideoStateReq) Size() (n int) {
  2458. if m == nil {
  2459. return 0
  2460. }
  2461. var l int
  2462. _ = l
  2463. if m.Svid != 0 {
  2464. n += 1 + sovApi(uint64(m.Svid))
  2465. }
  2466. if m.State != 0 {
  2467. n += 1 + sovApi(uint64(m.State))
  2468. }
  2469. if m.XXX_unrecognized != nil {
  2470. n += len(m.XXX_unrecognized)
  2471. }
  2472. return n
  2473. }
  2474. func (m *TopicVideosReq) Size() (n int) {
  2475. if m == nil {
  2476. return 0
  2477. }
  2478. var l int
  2479. _ = l
  2480. if m.TopicId != 0 {
  2481. n += 1 + sovApi(uint64(m.TopicId))
  2482. }
  2483. l = len(m.CursorPrev)
  2484. if l > 0 {
  2485. n += 1 + l + sovApi(uint64(l))
  2486. }
  2487. l = len(m.CursorNext)
  2488. if l > 0 {
  2489. n += 1 + l + sovApi(uint64(l))
  2490. }
  2491. if m.XXX_unrecognized != nil {
  2492. n += len(m.XXX_unrecognized)
  2493. }
  2494. return n
  2495. }
  2496. func (m *ListMultiTopicVideosReq) Size() (n int) {
  2497. if m == nil {
  2498. return 0
  2499. }
  2500. var l int
  2501. _ = l
  2502. if len(m.List) > 0 {
  2503. for _, e := range m.List {
  2504. l = e.Size()
  2505. n += 1 + l + sovApi(uint64(l))
  2506. }
  2507. }
  2508. if m.XXX_unrecognized != nil {
  2509. n += len(m.XXX_unrecognized)
  2510. }
  2511. return n
  2512. }
  2513. func (m *VideoItem) Size() (n int) {
  2514. if m == nil {
  2515. return 0
  2516. }
  2517. var l int
  2518. _ = l
  2519. if m.Svid != 0 {
  2520. n += 1 + sovApi(uint64(m.Svid))
  2521. }
  2522. l = len(m.CursorValue)
  2523. if l > 0 {
  2524. n += 1 + l + sovApi(uint64(l))
  2525. }
  2526. if m.HotType != 0 {
  2527. n += 1 + sovApi(uint64(m.HotType))
  2528. }
  2529. if m.XXX_unrecognized != nil {
  2530. n += len(m.XXX_unrecognized)
  2531. }
  2532. return n
  2533. }
  2534. func (m *TopicDetail) Size() (n int) {
  2535. if m == nil {
  2536. return 0
  2537. }
  2538. var l int
  2539. _ = l
  2540. if m.TopicInfo != nil {
  2541. l = m.TopicInfo.Size()
  2542. n += 1 + l + sovApi(uint64(l))
  2543. }
  2544. if len(m.List) > 0 {
  2545. for _, e := range m.List {
  2546. l = e.Size()
  2547. n += 1 + l + sovApi(uint64(l))
  2548. }
  2549. }
  2550. if m.HasMore {
  2551. n += 2
  2552. }
  2553. if m.XXX_unrecognized != nil {
  2554. n += len(m.XXX_unrecognized)
  2555. }
  2556. return n
  2557. }
  2558. func (m *ListDiscoveryTopicReq) Size() (n int) {
  2559. if m == nil {
  2560. return 0
  2561. }
  2562. var l int
  2563. _ = l
  2564. if m.Page != 0 {
  2565. n += 1 + sovApi(uint64(m.Page))
  2566. }
  2567. if m.XXX_unrecognized != nil {
  2568. n += len(m.XXX_unrecognized)
  2569. }
  2570. return n
  2571. }
  2572. func (m *ListDiscoveryTopicReply) Size() (n int) {
  2573. if m == nil {
  2574. return 0
  2575. }
  2576. var l int
  2577. _ = l
  2578. if len(m.List) > 0 {
  2579. for _, e := range m.List {
  2580. l = e.Size()
  2581. n += 1 + l + sovApi(uint64(l))
  2582. }
  2583. }
  2584. if m.HasMore {
  2585. n += 2
  2586. }
  2587. if m.XXX_unrecognized != nil {
  2588. n += len(m.XXX_unrecognized)
  2589. }
  2590. return n
  2591. }
  2592. func (m *ListTopicsReq) Size() (n int) {
  2593. if m == nil {
  2594. return 0
  2595. }
  2596. var l int
  2597. _ = l
  2598. if m.Page != 0 {
  2599. n += 1 + sovApi(uint64(m.Page))
  2600. }
  2601. if m.XXX_unrecognized != nil {
  2602. n += len(m.XXX_unrecognized)
  2603. }
  2604. return n
  2605. }
  2606. func (m *ListTopicsReply) Size() (n int) {
  2607. if m == nil {
  2608. return 0
  2609. }
  2610. var l int
  2611. _ = l
  2612. if m.HasMore {
  2613. n += 2
  2614. }
  2615. if len(m.List) > 0 {
  2616. for _, e := range m.List {
  2617. l = e.Size()
  2618. n += 1 + l + sovApi(uint64(l))
  2619. }
  2620. }
  2621. if m.XXX_unrecognized != nil {
  2622. n += len(m.XXX_unrecognized)
  2623. }
  2624. return n
  2625. }
  2626. func (m *StickTopicReq) Size() (n int) {
  2627. if m == nil {
  2628. return 0
  2629. }
  2630. var l int
  2631. _ = l
  2632. if m.TopicId != 0 {
  2633. n += 1 + sovApi(uint64(m.TopicId))
  2634. }
  2635. if m.Op != 0 {
  2636. n += 1 + sovApi(uint64(m.Op))
  2637. }
  2638. if m.XXX_unrecognized != nil {
  2639. n += len(m.XXX_unrecognized)
  2640. }
  2641. return n
  2642. }
  2643. func (m *StickTopicVideoReq) Size() (n int) {
  2644. if m == nil {
  2645. return 0
  2646. }
  2647. var l int
  2648. _ = l
  2649. if m.TopicId != 0 {
  2650. n += 1 + sovApi(uint64(m.TopicId))
  2651. }
  2652. if m.Svid != 0 {
  2653. n += 1 + sovApi(uint64(m.Svid))
  2654. }
  2655. if m.Op != 0 {
  2656. n += 1 + sovApi(uint64(m.Op))
  2657. }
  2658. if m.XXX_unrecognized != nil {
  2659. n += len(m.XXX_unrecognized)
  2660. }
  2661. return n
  2662. }
  2663. func (m *SetStickTopicVideoReq) Size() (n int) {
  2664. if m == nil {
  2665. return 0
  2666. }
  2667. var l int
  2668. _ = l
  2669. if m.TopicId != 0 {
  2670. n += 1 + sovApi(uint64(m.TopicId))
  2671. }
  2672. if len(m.Svids) > 0 {
  2673. l = 0
  2674. for _, e := range m.Svids {
  2675. l += sovApi(uint64(e))
  2676. }
  2677. n += 1 + sovApi(uint64(l)) + l
  2678. }
  2679. if m.XXX_unrecognized != nil {
  2680. n += len(m.XXX_unrecognized)
  2681. }
  2682. return n
  2683. }
  2684. func (m *ListCmsTopicsReq) Size() (n int) {
  2685. if m == nil {
  2686. return 0
  2687. }
  2688. var l int
  2689. _ = l
  2690. if m.Page != 0 {
  2691. n += 1 + sovApi(uint64(m.Page))
  2692. }
  2693. l = len(m.Name)
  2694. if l > 0 {
  2695. n += 1 + l + sovApi(uint64(l))
  2696. }
  2697. if m.TopicId != 0 {
  2698. n += 1 + sovApi(uint64(m.TopicId))
  2699. }
  2700. if m.State != 0 {
  2701. n += 1 + sovApi(uint64(m.State))
  2702. }
  2703. if m.XXX_unrecognized != nil {
  2704. n += len(m.XXX_unrecognized)
  2705. }
  2706. return n
  2707. }
  2708. func (m *ListCmsTopicsReply) Size() (n int) {
  2709. if m == nil {
  2710. return 0
  2711. }
  2712. var l int
  2713. _ = l
  2714. if m.HasMore {
  2715. n += 2
  2716. }
  2717. if len(m.List) > 0 {
  2718. for _, e := range m.List {
  2719. l = e.Size()
  2720. n += 1 + l + sovApi(uint64(l))
  2721. }
  2722. }
  2723. if m.XXX_unrecognized != nil {
  2724. n += len(m.XXX_unrecognized)
  2725. }
  2726. return n
  2727. }
  2728. func (m *TopicVideoItem) Size() (n int) {
  2729. if m == nil {
  2730. return 0
  2731. }
  2732. var l int
  2733. _ = l
  2734. if m.TopicId != 0 {
  2735. n += 1 + sovApi(uint64(m.TopicId))
  2736. }
  2737. if m.Svid != 0 {
  2738. n += 1 + sovApi(uint64(m.Svid))
  2739. }
  2740. if m.Score != 0 {
  2741. n += 9
  2742. }
  2743. if m.State != 0 {
  2744. n += 1 + sovApi(uint64(m.State))
  2745. }
  2746. if m.XXX_unrecognized != nil {
  2747. n += len(m.XXX_unrecognized)
  2748. }
  2749. return n
  2750. }
  2751. func (m *VideoTopicReq) Size() (n int) {
  2752. if m == nil {
  2753. return 0
  2754. }
  2755. var l int
  2756. _ = l
  2757. if m.Svid != 0 {
  2758. n += 1 + sovApi(uint64(m.Svid))
  2759. }
  2760. if m.XXX_unrecognized != nil {
  2761. n += len(m.XXX_unrecognized)
  2762. }
  2763. return n
  2764. }
  2765. func (m *VideoTopicReply) Size() (n int) {
  2766. if m == nil {
  2767. return 0
  2768. }
  2769. var l int
  2770. _ = l
  2771. if len(m.List) > 0 {
  2772. for _, e := range m.List {
  2773. l = e.Size()
  2774. n += 1 + l + sovApi(uint64(l))
  2775. }
  2776. }
  2777. if m.XXX_unrecognized != nil {
  2778. n += len(m.XXX_unrecognized)
  2779. }
  2780. return n
  2781. }
  2782. func (m *UpdateTopicStateReq) Size() (n int) {
  2783. if m == nil {
  2784. return 0
  2785. }
  2786. var l int
  2787. _ = l
  2788. if m.TopicId != 0 {
  2789. n += 1 + sovApi(uint64(m.TopicId))
  2790. }
  2791. if m.Op != 0 {
  2792. n += 1 + sovApi(uint64(m.Op))
  2793. }
  2794. if m.XXX_unrecognized != nil {
  2795. n += len(m.XXX_unrecognized)
  2796. }
  2797. return n
  2798. }
  2799. func (m *TopicInfo) Size() (n int) {
  2800. if m == nil {
  2801. return 0
  2802. }
  2803. var l int
  2804. _ = l
  2805. if m.TopicId != 0 {
  2806. n += 1 + sovApi(uint64(m.TopicId))
  2807. }
  2808. l = len(m.Name)
  2809. if l > 0 {
  2810. n += 1 + l + sovApi(uint64(l))
  2811. }
  2812. l = len(m.Desc)
  2813. if l > 0 {
  2814. n += 1 + l + sovApi(uint64(l))
  2815. }
  2816. if m.Score != 0 {
  2817. n += 9
  2818. }
  2819. if m.State != 0 {
  2820. n += 1 + sovApi(uint64(m.State))
  2821. }
  2822. if m.HotType != 0 {
  2823. n += 1 + sovApi(uint64(m.HotType))
  2824. }
  2825. l = len(m.CoverUrl)
  2826. if l > 0 {
  2827. n += 1 + l + sovApi(uint64(l))
  2828. }
  2829. if m.XXX_unrecognized != nil {
  2830. n += len(m.XXX_unrecognized)
  2831. }
  2832. return n
  2833. }
  2834. func (m *TitleExtraItem) Size() (n int) {
  2835. if m == nil {
  2836. return 0
  2837. }
  2838. var l int
  2839. _ = l
  2840. if m.Id != 0 {
  2841. n += 1 + sovApi(uint64(m.Id))
  2842. }
  2843. if m.Type != 0 {
  2844. n += 1 + sovApi(uint64(m.Type))
  2845. }
  2846. l = len(m.Name)
  2847. if l > 0 {
  2848. n += 1 + l + sovApi(uint64(l))
  2849. }
  2850. if m.Start != 0 {
  2851. n += 1 + sovApi(uint64(m.Start))
  2852. }
  2853. if m.End != 0 {
  2854. n += 1 + sovApi(uint64(m.End))
  2855. }
  2856. l = len(m.Scheme)
  2857. if l > 0 {
  2858. n += 1 + l + sovApi(uint64(l))
  2859. }
  2860. if m.XXX_unrecognized != nil {
  2861. n += len(m.XXX_unrecognized)
  2862. }
  2863. return n
  2864. }
  2865. func (m *VideoExtension) Size() (n int) {
  2866. if m == nil {
  2867. return 0
  2868. }
  2869. var l int
  2870. _ = l
  2871. if m.Svid != 0 {
  2872. n += 1 + sovApi(uint64(m.Svid))
  2873. }
  2874. l = len(m.Extension)
  2875. if l > 0 {
  2876. n += 1 + l + sovApi(uint64(l))
  2877. }
  2878. if m.XXX_unrecognized != nil {
  2879. n += len(m.XXX_unrecognized)
  2880. }
  2881. return n
  2882. }
  2883. func (m *Extension) Size() (n int) {
  2884. if m == nil {
  2885. return 0
  2886. }
  2887. var l int
  2888. _ = l
  2889. if len(m.TitleExtra) > 0 {
  2890. for _, e := range m.TitleExtra {
  2891. l = e.Size()
  2892. n += 1 + l + sovApi(uint64(l))
  2893. }
  2894. }
  2895. if m.XXX_unrecognized != nil {
  2896. n += len(m.XXX_unrecognized)
  2897. }
  2898. return n
  2899. }
  2900. func sovApi(x uint64) (n int) {
  2901. for {
  2902. n++
  2903. x >>= 7
  2904. if x == 0 {
  2905. break
  2906. }
  2907. }
  2908. return n
  2909. }
  2910. func sozApi(x uint64) (n int) {
  2911. return sovApi(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  2912. }
  2913. func (m *ListExtensionReq) Unmarshal(dAtA []byte) error {
  2914. l := len(dAtA)
  2915. iNdEx := 0
  2916. for iNdEx < l {
  2917. preIndex := iNdEx
  2918. var wire uint64
  2919. for shift := uint(0); ; shift += 7 {
  2920. if shift >= 64 {
  2921. return ErrIntOverflowApi
  2922. }
  2923. if iNdEx >= l {
  2924. return io.ErrUnexpectedEOF
  2925. }
  2926. b := dAtA[iNdEx]
  2927. iNdEx++
  2928. wire |= (uint64(b) & 0x7F) << shift
  2929. if b < 0x80 {
  2930. break
  2931. }
  2932. }
  2933. fieldNum := int32(wire >> 3)
  2934. wireType := int(wire & 0x7)
  2935. if wireType == 4 {
  2936. return fmt.Errorf("proto: ListExtensionReq: wiretype end group for non-group")
  2937. }
  2938. if fieldNum <= 0 {
  2939. return fmt.Errorf("proto: ListExtensionReq: illegal tag %d (wire type %d)", fieldNum, wire)
  2940. }
  2941. switch fieldNum {
  2942. case 1:
  2943. if wireType == 0 {
  2944. var v int64
  2945. for shift := uint(0); ; shift += 7 {
  2946. if shift >= 64 {
  2947. return ErrIntOverflowApi
  2948. }
  2949. if iNdEx >= l {
  2950. return io.ErrUnexpectedEOF
  2951. }
  2952. b := dAtA[iNdEx]
  2953. iNdEx++
  2954. v |= (int64(b) & 0x7F) << shift
  2955. if b < 0x80 {
  2956. break
  2957. }
  2958. }
  2959. m.Svids = append(m.Svids, v)
  2960. } else if wireType == 2 {
  2961. var packedLen int
  2962. for shift := uint(0); ; shift += 7 {
  2963. if shift >= 64 {
  2964. return ErrIntOverflowApi
  2965. }
  2966. if iNdEx >= l {
  2967. return io.ErrUnexpectedEOF
  2968. }
  2969. b := dAtA[iNdEx]
  2970. iNdEx++
  2971. packedLen |= (int(b) & 0x7F) << shift
  2972. if b < 0x80 {
  2973. break
  2974. }
  2975. }
  2976. if packedLen < 0 {
  2977. return ErrInvalidLengthApi
  2978. }
  2979. postIndex := iNdEx + packedLen
  2980. if postIndex > l {
  2981. return io.ErrUnexpectedEOF
  2982. }
  2983. var elementCount int
  2984. var count int
  2985. for _, integer := range dAtA {
  2986. if integer < 128 {
  2987. count++
  2988. }
  2989. }
  2990. elementCount = count
  2991. if elementCount != 0 && len(m.Svids) == 0 {
  2992. m.Svids = make([]int64, 0, elementCount)
  2993. }
  2994. for iNdEx < postIndex {
  2995. var v int64
  2996. for shift := uint(0); ; shift += 7 {
  2997. if shift >= 64 {
  2998. return ErrIntOverflowApi
  2999. }
  3000. if iNdEx >= l {
  3001. return io.ErrUnexpectedEOF
  3002. }
  3003. b := dAtA[iNdEx]
  3004. iNdEx++
  3005. v |= (int64(b) & 0x7F) << shift
  3006. if b < 0x80 {
  3007. break
  3008. }
  3009. }
  3010. m.Svids = append(m.Svids, v)
  3011. }
  3012. } else {
  3013. return fmt.Errorf("proto: wrong wireType = %d for field Svids", wireType)
  3014. }
  3015. default:
  3016. iNdEx = preIndex
  3017. skippy, err := skipApi(dAtA[iNdEx:])
  3018. if err != nil {
  3019. return err
  3020. }
  3021. if skippy < 0 {
  3022. return ErrInvalidLengthApi
  3023. }
  3024. if (iNdEx + skippy) > l {
  3025. return io.ErrUnexpectedEOF
  3026. }
  3027. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3028. iNdEx += skippy
  3029. }
  3030. }
  3031. if iNdEx > l {
  3032. return io.ErrUnexpectedEOF
  3033. }
  3034. return nil
  3035. }
  3036. func (m *ListExtensionReply) Unmarshal(dAtA []byte) error {
  3037. l := len(dAtA)
  3038. iNdEx := 0
  3039. for iNdEx < l {
  3040. preIndex := iNdEx
  3041. var wire uint64
  3042. for shift := uint(0); ; shift += 7 {
  3043. if shift >= 64 {
  3044. return ErrIntOverflowApi
  3045. }
  3046. if iNdEx >= l {
  3047. return io.ErrUnexpectedEOF
  3048. }
  3049. b := dAtA[iNdEx]
  3050. iNdEx++
  3051. wire |= (uint64(b) & 0x7F) << shift
  3052. if b < 0x80 {
  3053. break
  3054. }
  3055. }
  3056. fieldNum := int32(wire >> 3)
  3057. wireType := int(wire & 0x7)
  3058. if wireType == 4 {
  3059. return fmt.Errorf("proto: ListExtensionReply: wiretype end group for non-group")
  3060. }
  3061. if fieldNum <= 0 {
  3062. return fmt.Errorf("proto: ListExtensionReply: illegal tag %d (wire type %d)", fieldNum, wire)
  3063. }
  3064. switch fieldNum {
  3065. case 1:
  3066. if wireType != 2 {
  3067. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  3068. }
  3069. var msglen int
  3070. for shift := uint(0); ; shift += 7 {
  3071. if shift >= 64 {
  3072. return ErrIntOverflowApi
  3073. }
  3074. if iNdEx >= l {
  3075. return io.ErrUnexpectedEOF
  3076. }
  3077. b := dAtA[iNdEx]
  3078. iNdEx++
  3079. msglen |= (int(b) & 0x7F) << shift
  3080. if b < 0x80 {
  3081. break
  3082. }
  3083. }
  3084. if msglen < 0 {
  3085. return ErrInvalidLengthApi
  3086. }
  3087. postIndex := iNdEx + msglen
  3088. if postIndex > l {
  3089. return io.ErrUnexpectedEOF
  3090. }
  3091. m.List = append(m.List, &VideoExtension{})
  3092. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3093. return err
  3094. }
  3095. iNdEx = postIndex
  3096. default:
  3097. iNdEx = preIndex
  3098. skippy, err := skipApi(dAtA[iNdEx:])
  3099. if err != nil {
  3100. return err
  3101. }
  3102. if skippy < 0 {
  3103. return ErrInvalidLengthApi
  3104. }
  3105. if (iNdEx + skippy) > l {
  3106. return io.ErrUnexpectedEOF
  3107. }
  3108. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3109. iNdEx += skippy
  3110. }
  3111. }
  3112. if iNdEx > l {
  3113. return io.ErrUnexpectedEOF
  3114. }
  3115. return nil
  3116. }
  3117. func (m *UpdateVideoScoreReq) Unmarshal(dAtA []byte) error {
  3118. l := len(dAtA)
  3119. iNdEx := 0
  3120. for iNdEx < l {
  3121. preIndex := iNdEx
  3122. var wire uint64
  3123. for shift := uint(0); ; shift += 7 {
  3124. if shift >= 64 {
  3125. return ErrIntOverflowApi
  3126. }
  3127. if iNdEx >= l {
  3128. return io.ErrUnexpectedEOF
  3129. }
  3130. b := dAtA[iNdEx]
  3131. iNdEx++
  3132. wire |= (uint64(b) & 0x7F) << shift
  3133. if b < 0x80 {
  3134. break
  3135. }
  3136. }
  3137. fieldNum := int32(wire >> 3)
  3138. wireType := int(wire & 0x7)
  3139. if wireType == 4 {
  3140. return fmt.Errorf("proto: UpdateVideoScoreReq: wiretype end group for non-group")
  3141. }
  3142. if fieldNum <= 0 {
  3143. return fmt.Errorf("proto: UpdateVideoScoreReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3144. }
  3145. switch fieldNum {
  3146. case 1:
  3147. if wireType != 0 {
  3148. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  3149. }
  3150. m.Svid = 0
  3151. for shift := uint(0); ; shift += 7 {
  3152. if shift >= 64 {
  3153. return ErrIntOverflowApi
  3154. }
  3155. if iNdEx >= l {
  3156. return io.ErrUnexpectedEOF
  3157. }
  3158. b := dAtA[iNdEx]
  3159. iNdEx++
  3160. m.Svid |= (int64(b) & 0x7F) << shift
  3161. if b < 0x80 {
  3162. break
  3163. }
  3164. }
  3165. case 2:
  3166. if wireType != 1 {
  3167. return fmt.Errorf("proto: wrong wireType = %d for field Score", wireType)
  3168. }
  3169. var v uint64
  3170. if (iNdEx + 8) > l {
  3171. return io.ErrUnexpectedEOF
  3172. }
  3173. v = uint64(encoding_binary.LittleEndian.Uint64(dAtA[iNdEx:]))
  3174. iNdEx += 8
  3175. m.Score = float64(math.Float64frombits(v))
  3176. default:
  3177. iNdEx = preIndex
  3178. skippy, err := skipApi(dAtA[iNdEx:])
  3179. if err != nil {
  3180. return err
  3181. }
  3182. if skippy < 0 {
  3183. return ErrInvalidLengthApi
  3184. }
  3185. if (iNdEx + skippy) > l {
  3186. return io.ErrUnexpectedEOF
  3187. }
  3188. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3189. iNdEx += skippy
  3190. }
  3191. }
  3192. if iNdEx > l {
  3193. return io.ErrUnexpectedEOF
  3194. }
  3195. return nil
  3196. }
  3197. func (m *UpdateVideoStateReq) Unmarshal(dAtA []byte) error {
  3198. l := len(dAtA)
  3199. iNdEx := 0
  3200. for iNdEx < l {
  3201. preIndex := iNdEx
  3202. var wire uint64
  3203. for shift := uint(0); ; shift += 7 {
  3204. if shift >= 64 {
  3205. return ErrIntOverflowApi
  3206. }
  3207. if iNdEx >= l {
  3208. return io.ErrUnexpectedEOF
  3209. }
  3210. b := dAtA[iNdEx]
  3211. iNdEx++
  3212. wire |= (uint64(b) & 0x7F) << shift
  3213. if b < 0x80 {
  3214. break
  3215. }
  3216. }
  3217. fieldNum := int32(wire >> 3)
  3218. wireType := int(wire & 0x7)
  3219. if wireType == 4 {
  3220. return fmt.Errorf("proto: UpdateVideoStateReq: wiretype end group for non-group")
  3221. }
  3222. if fieldNum <= 0 {
  3223. return fmt.Errorf("proto: UpdateVideoStateReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3224. }
  3225. switch fieldNum {
  3226. case 1:
  3227. if wireType != 0 {
  3228. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  3229. }
  3230. m.Svid = 0
  3231. for shift := uint(0); ; shift += 7 {
  3232. if shift >= 64 {
  3233. return ErrIntOverflowApi
  3234. }
  3235. if iNdEx >= l {
  3236. return io.ErrUnexpectedEOF
  3237. }
  3238. b := dAtA[iNdEx]
  3239. iNdEx++
  3240. m.Svid |= (int64(b) & 0x7F) << shift
  3241. if b < 0x80 {
  3242. break
  3243. }
  3244. }
  3245. case 2:
  3246. if wireType != 0 {
  3247. return fmt.Errorf("proto: wrong wireType = %d for field State", wireType)
  3248. }
  3249. m.State = 0
  3250. for shift := uint(0); ; shift += 7 {
  3251. if shift >= 64 {
  3252. return ErrIntOverflowApi
  3253. }
  3254. if iNdEx >= l {
  3255. return io.ErrUnexpectedEOF
  3256. }
  3257. b := dAtA[iNdEx]
  3258. iNdEx++
  3259. m.State |= (int32(b) & 0x7F) << shift
  3260. if b < 0x80 {
  3261. break
  3262. }
  3263. }
  3264. default:
  3265. iNdEx = preIndex
  3266. skippy, err := skipApi(dAtA[iNdEx:])
  3267. if err != nil {
  3268. return err
  3269. }
  3270. if skippy < 0 {
  3271. return ErrInvalidLengthApi
  3272. }
  3273. if (iNdEx + skippy) > l {
  3274. return io.ErrUnexpectedEOF
  3275. }
  3276. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3277. iNdEx += skippy
  3278. }
  3279. }
  3280. if iNdEx > l {
  3281. return io.ErrUnexpectedEOF
  3282. }
  3283. return nil
  3284. }
  3285. func (m *TopicVideosReq) Unmarshal(dAtA []byte) error {
  3286. l := len(dAtA)
  3287. iNdEx := 0
  3288. for iNdEx < l {
  3289. preIndex := iNdEx
  3290. var wire uint64
  3291. for shift := uint(0); ; shift += 7 {
  3292. if shift >= 64 {
  3293. return ErrIntOverflowApi
  3294. }
  3295. if iNdEx >= l {
  3296. return io.ErrUnexpectedEOF
  3297. }
  3298. b := dAtA[iNdEx]
  3299. iNdEx++
  3300. wire |= (uint64(b) & 0x7F) << shift
  3301. if b < 0x80 {
  3302. break
  3303. }
  3304. }
  3305. fieldNum := int32(wire >> 3)
  3306. wireType := int(wire & 0x7)
  3307. if wireType == 4 {
  3308. return fmt.Errorf("proto: TopicVideosReq: wiretype end group for non-group")
  3309. }
  3310. if fieldNum <= 0 {
  3311. return fmt.Errorf("proto: TopicVideosReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3312. }
  3313. switch fieldNum {
  3314. case 1:
  3315. if wireType != 0 {
  3316. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  3317. }
  3318. m.TopicId = 0
  3319. for shift := uint(0); ; shift += 7 {
  3320. if shift >= 64 {
  3321. return ErrIntOverflowApi
  3322. }
  3323. if iNdEx >= l {
  3324. return io.ErrUnexpectedEOF
  3325. }
  3326. b := dAtA[iNdEx]
  3327. iNdEx++
  3328. m.TopicId |= (int64(b) & 0x7F) << shift
  3329. if b < 0x80 {
  3330. break
  3331. }
  3332. }
  3333. case 2:
  3334. if wireType != 2 {
  3335. return fmt.Errorf("proto: wrong wireType = %d for field CursorPrev", wireType)
  3336. }
  3337. var stringLen uint64
  3338. for shift := uint(0); ; shift += 7 {
  3339. if shift >= 64 {
  3340. return ErrIntOverflowApi
  3341. }
  3342. if iNdEx >= l {
  3343. return io.ErrUnexpectedEOF
  3344. }
  3345. b := dAtA[iNdEx]
  3346. iNdEx++
  3347. stringLen |= (uint64(b) & 0x7F) << shift
  3348. if b < 0x80 {
  3349. break
  3350. }
  3351. }
  3352. intStringLen := int(stringLen)
  3353. if intStringLen < 0 {
  3354. return ErrInvalidLengthApi
  3355. }
  3356. postIndex := iNdEx + intStringLen
  3357. if postIndex > l {
  3358. return io.ErrUnexpectedEOF
  3359. }
  3360. m.CursorPrev = string(dAtA[iNdEx:postIndex])
  3361. iNdEx = postIndex
  3362. case 3:
  3363. if wireType != 2 {
  3364. return fmt.Errorf("proto: wrong wireType = %d for field CursorNext", wireType)
  3365. }
  3366. var stringLen uint64
  3367. for shift := uint(0); ; shift += 7 {
  3368. if shift >= 64 {
  3369. return ErrIntOverflowApi
  3370. }
  3371. if iNdEx >= l {
  3372. return io.ErrUnexpectedEOF
  3373. }
  3374. b := dAtA[iNdEx]
  3375. iNdEx++
  3376. stringLen |= (uint64(b) & 0x7F) << shift
  3377. if b < 0x80 {
  3378. break
  3379. }
  3380. }
  3381. intStringLen := int(stringLen)
  3382. if intStringLen < 0 {
  3383. return ErrInvalidLengthApi
  3384. }
  3385. postIndex := iNdEx + intStringLen
  3386. if postIndex > l {
  3387. return io.ErrUnexpectedEOF
  3388. }
  3389. m.CursorNext = string(dAtA[iNdEx:postIndex])
  3390. iNdEx = postIndex
  3391. default:
  3392. iNdEx = preIndex
  3393. skippy, err := skipApi(dAtA[iNdEx:])
  3394. if err != nil {
  3395. return err
  3396. }
  3397. if skippy < 0 {
  3398. return ErrInvalidLengthApi
  3399. }
  3400. if (iNdEx + skippy) > l {
  3401. return io.ErrUnexpectedEOF
  3402. }
  3403. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3404. iNdEx += skippy
  3405. }
  3406. }
  3407. if iNdEx > l {
  3408. return io.ErrUnexpectedEOF
  3409. }
  3410. return nil
  3411. }
  3412. func (m *ListMultiTopicVideosReq) Unmarshal(dAtA []byte) error {
  3413. l := len(dAtA)
  3414. iNdEx := 0
  3415. for iNdEx < l {
  3416. preIndex := iNdEx
  3417. var wire uint64
  3418. for shift := uint(0); ; shift += 7 {
  3419. if shift >= 64 {
  3420. return ErrIntOverflowApi
  3421. }
  3422. if iNdEx >= l {
  3423. return io.ErrUnexpectedEOF
  3424. }
  3425. b := dAtA[iNdEx]
  3426. iNdEx++
  3427. wire |= (uint64(b) & 0x7F) << shift
  3428. if b < 0x80 {
  3429. break
  3430. }
  3431. }
  3432. fieldNum := int32(wire >> 3)
  3433. wireType := int(wire & 0x7)
  3434. if wireType == 4 {
  3435. return fmt.Errorf("proto: ListMultiTopicVideosReq: wiretype end group for non-group")
  3436. }
  3437. if fieldNum <= 0 {
  3438. return fmt.Errorf("proto: ListMultiTopicVideosReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3439. }
  3440. switch fieldNum {
  3441. case 1:
  3442. if wireType != 2 {
  3443. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  3444. }
  3445. var msglen int
  3446. for shift := uint(0); ; shift += 7 {
  3447. if shift >= 64 {
  3448. return ErrIntOverflowApi
  3449. }
  3450. if iNdEx >= l {
  3451. return io.ErrUnexpectedEOF
  3452. }
  3453. b := dAtA[iNdEx]
  3454. iNdEx++
  3455. msglen |= (int(b) & 0x7F) << shift
  3456. if b < 0x80 {
  3457. break
  3458. }
  3459. }
  3460. if msglen < 0 {
  3461. return ErrInvalidLengthApi
  3462. }
  3463. postIndex := iNdEx + msglen
  3464. if postIndex > l {
  3465. return io.ErrUnexpectedEOF
  3466. }
  3467. m.List = append(m.List, &TopicVideosReq{})
  3468. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3469. return err
  3470. }
  3471. iNdEx = postIndex
  3472. default:
  3473. iNdEx = preIndex
  3474. skippy, err := skipApi(dAtA[iNdEx:])
  3475. if err != nil {
  3476. return err
  3477. }
  3478. if skippy < 0 {
  3479. return ErrInvalidLengthApi
  3480. }
  3481. if (iNdEx + skippy) > l {
  3482. return io.ErrUnexpectedEOF
  3483. }
  3484. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3485. iNdEx += skippy
  3486. }
  3487. }
  3488. if iNdEx > l {
  3489. return io.ErrUnexpectedEOF
  3490. }
  3491. return nil
  3492. }
  3493. func (m *VideoItem) Unmarshal(dAtA []byte) error {
  3494. l := len(dAtA)
  3495. iNdEx := 0
  3496. for iNdEx < l {
  3497. preIndex := iNdEx
  3498. var wire uint64
  3499. for shift := uint(0); ; shift += 7 {
  3500. if shift >= 64 {
  3501. return ErrIntOverflowApi
  3502. }
  3503. if iNdEx >= l {
  3504. return io.ErrUnexpectedEOF
  3505. }
  3506. b := dAtA[iNdEx]
  3507. iNdEx++
  3508. wire |= (uint64(b) & 0x7F) << shift
  3509. if b < 0x80 {
  3510. break
  3511. }
  3512. }
  3513. fieldNum := int32(wire >> 3)
  3514. wireType := int(wire & 0x7)
  3515. if wireType == 4 {
  3516. return fmt.Errorf("proto: VideoItem: wiretype end group for non-group")
  3517. }
  3518. if fieldNum <= 0 {
  3519. return fmt.Errorf("proto: VideoItem: illegal tag %d (wire type %d)", fieldNum, wire)
  3520. }
  3521. switch fieldNum {
  3522. case 1:
  3523. if wireType != 0 {
  3524. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  3525. }
  3526. m.Svid = 0
  3527. for shift := uint(0); ; shift += 7 {
  3528. if shift >= 64 {
  3529. return ErrIntOverflowApi
  3530. }
  3531. if iNdEx >= l {
  3532. return io.ErrUnexpectedEOF
  3533. }
  3534. b := dAtA[iNdEx]
  3535. iNdEx++
  3536. m.Svid |= (int64(b) & 0x7F) << shift
  3537. if b < 0x80 {
  3538. break
  3539. }
  3540. }
  3541. case 2:
  3542. if wireType != 2 {
  3543. return fmt.Errorf("proto: wrong wireType = %d for field CursorValue", wireType)
  3544. }
  3545. var stringLen uint64
  3546. for shift := uint(0); ; shift += 7 {
  3547. if shift >= 64 {
  3548. return ErrIntOverflowApi
  3549. }
  3550. if iNdEx >= l {
  3551. return io.ErrUnexpectedEOF
  3552. }
  3553. b := dAtA[iNdEx]
  3554. iNdEx++
  3555. stringLen |= (uint64(b) & 0x7F) << shift
  3556. if b < 0x80 {
  3557. break
  3558. }
  3559. }
  3560. intStringLen := int(stringLen)
  3561. if intStringLen < 0 {
  3562. return ErrInvalidLengthApi
  3563. }
  3564. postIndex := iNdEx + intStringLen
  3565. if postIndex > l {
  3566. return io.ErrUnexpectedEOF
  3567. }
  3568. m.CursorValue = string(dAtA[iNdEx:postIndex])
  3569. iNdEx = postIndex
  3570. case 3:
  3571. if wireType != 0 {
  3572. return fmt.Errorf("proto: wrong wireType = %d for field HotType", wireType)
  3573. }
  3574. m.HotType = 0
  3575. for shift := uint(0); ; shift += 7 {
  3576. if shift >= 64 {
  3577. return ErrIntOverflowApi
  3578. }
  3579. if iNdEx >= l {
  3580. return io.ErrUnexpectedEOF
  3581. }
  3582. b := dAtA[iNdEx]
  3583. iNdEx++
  3584. m.HotType |= (int64(b) & 0x7F) << shift
  3585. if b < 0x80 {
  3586. break
  3587. }
  3588. }
  3589. default:
  3590. iNdEx = preIndex
  3591. skippy, err := skipApi(dAtA[iNdEx:])
  3592. if err != nil {
  3593. return err
  3594. }
  3595. if skippy < 0 {
  3596. return ErrInvalidLengthApi
  3597. }
  3598. if (iNdEx + skippy) > l {
  3599. return io.ErrUnexpectedEOF
  3600. }
  3601. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3602. iNdEx += skippy
  3603. }
  3604. }
  3605. if iNdEx > l {
  3606. return io.ErrUnexpectedEOF
  3607. }
  3608. return nil
  3609. }
  3610. func (m *TopicDetail) Unmarshal(dAtA []byte) error {
  3611. l := len(dAtA)
  3612. iNdEx := 0
  3613. for iNdEx < l {
  3614. preIndex := iNdEx
  3615. var wire uint64
  3616. for shift := uint(0); ; shift += 7 {
  3617. if shift >= 64 {
  3618. return ErrIntOverflowApi
  3619. }
  3620. if iNdEx >= l {
  3621. return io.ErrUnexpectedEOF
  3622. }
  3623. b := dAtA[iNdEx]
  3624. iNdEx++
  3625. wire |= (uint64(b) & 0x7F) << shift
  3626. if b < 0x80 {
  3627. break
  3628. }
  3629. }
  3630. fieldNum := int32(wire >> 3)
  3631. wireType := int(wire & 0x7)
  3632. if wireType == 4 {
  3633. return fmt.Errorf("proto: TopicDetail: wiretype end group for non-group")
  3634. }
  3635. if fieldNum <= 0 {
  3636. return fmt.Errorf("proto: TopicDetail: illegal tag %d (wire type %d)", fieldNum, wire)
  3637. }
  3638. switch fieldNum {
  3639. case 1:
  3640. if wireType != 2 {
  3641. return fmt.Errorf("proto: wrong wireType = %d for field TopicInfo", wireType)
  3642. }
  3643. var msglen int
  3644. for shift := uint(0); ; shift += 7 {
  3645. if shift >= 64 {
  3646. return ErrIntOverflowApi
  3647. }
  3648. if iNdEx >= l {
  3649. return io.ErrUnexpectedEOF
  3650. }
  3651. b := dAtA[iNdEx]
  3652. iNdEx++
  3653. msglen |= (int(b) & 0x7F) << shift
  3654. if b < 0x80 {
  3655. break
  3656. }
  3657. }
  3658. if msglen < 0 {
  3659. return ErrInvalidLengthApi
  3660. }
  3661. postIndex := iNdEx + msglen
  3662. if postIndex > l {
  3663. return io.ErrUnexpectedEOF
  3664. }
  3665. if m.TopicInfo == nil {
  3666. m.TopicInfo = &TopicInfo{}
  3667. }
  3668. if err := m.TopicInfo.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3669. return err
  3670. }
  3671. iNdEx = postIndex
  3672. case 2:
  3673. if wireType != 2 {
  3674. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  3675. }
  3676. var msglen int
  3677. for shift := uint(0); ; shift += 7 {
  3678. if shift >= 64 {
  3679. return ErrIntOverflowApi
  3680. }
  3681. if iNdEx >= l {
  3682. return io.ErrUnexpectedEOF
  3683. }
  3684. b := dAtA[iNdEx]
  3685. iNdEx++
  3686. msglen |= (int(b) & 0x7F) << shift
  3687. if b < 0x80 {
  3688. break
  3689. }
  3690. }
  3691. if msglen < 0 {
  3692. return ErrInvalidLengthApi
  3693. }
  3694. postIndex := iNdEx + msglen
  3695. if postIndex > l {
  3696. return io.ErrUnexpectedEOF
  3697. }
  3698. m.List = append(m.List, &VideoItem{})
  3699. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3700. return err
  3701. }
  3702. iNdEx = postIndex
  3703. case 3:
  3704. if wireType != 0 {
  3705. return fmt.Errorf("proto: wrong wireType = %d for field HasMore", wireType)
  3706. }
  3707. var v int
  3708. for shift := uint(0); ; shift += 7 {
  3709. if shift >= 64 {
  3710. return ErrIntOverflowApi
  3711. }
  3712. if iNdEx >= l {
  3713. return io.ErrUnexpectedEOF
  3714. }
  3715. b := dAtA[iNdEx]
  3716. iNdEx++
  3717. v |= (int(b) & 0x7F) << shift
  3718. if b < 0x80 {
  3719. break
  3720. }
  3721. }
  3722. m.HasMore = bool(v != 0)
  3723. default:
  3724. iNdEx = preIndex
  3725. skippy, err := skipApi(dAtA[iNdEx:])
  3726. if err != nil {
  3727. return err
  3728. }
  3729. if skippy < 0 {
  3730. return ErrInvalidLengthApi
  3731. }
  3732. if (iNdEx + skippy) > l {
  3733. return io.ErrUnexpectedEOF
  3734. }
  3735. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3736. iNdEx += skippy
  3737. }
  3738. }
  3739. if iNdEx > l {
  3740. return io.ErrUnexpectedEOF
  3741. }
  3742. return nil
  3743. }
  3744. func (m *ListDiscoveryTopicReq) Unmarshal(dAtA []byte) error {
  3745. l := len(dAtA)
  3746. iNdEx := 0
  3747. for iNdEx < l {
  3748. preIndex := iNdEx
  3749. var wire uint64
  3750. for shift := uint(0); ; shift += 7 {
  3751. if shift >= 64 {
  3752. return ErrIntOverflowApi
  3753. }
  3754. if iNdEx >= l {
  3755. return io.ErrUnexpectedEOF
  3756. }
  3757. b := dAtA[iNdEx]
  3758. iNdEx++
  3759. wire |= (uint64(b) & 0x7F) << shift
  3760. if b < 0x80 {
  3761. break
  3762. }
  3763. }
  3764. fieldNum := int32(wire >> 3)
  3765. wireType := int(wire & 0x7)
  3766. if wireType == 4 {
  3767. return fmt.Errorf("proto: ListDiscoveryTopicReq: wiretype end group for non-group")
  3768. }
  3769. if fieldNum <= 0 {
  3770. return fmt.Errorf("proto: ListDiscoveryTopicReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3771. }
  3772. switch fieldNum {
  3773. case 1:
  3774. if wireType != 0 {
  3775. return fmt.Errorf("proto: wrong wireType = %d for field Page", wireType)
  3776. }
  3777. m.Page = 0
  3778. for shift := uint(0); ; shift += 7 {
  3779. if shift >= 64 {
  3780. return ErrIntOverflowApi
  3781. }
  3782. if iNdEx >= l {
  3783. return io.ErrUnexpectedEOF
  3784. }
  3785. b := dAtA[iNdEx]
  3786. iNdEx++
  3787. m.Page |= (int32(b) & 0x7F) << shift
  3788. if b < 0x80 {
  3789. break
  3790. }
  3791. }
  3792. default:
  3793. iNdEx = preIndex
  3794. skippy, err := skipApi(dAtA[iNdEx:])
  3795. if err != nil {
  3796. return err
  3797. }
  3798. if skippy < 0 {
  3799. return ErrInvalidLengthApi
  3800. }
  3801. if (iNdEx + skippy) > l {
  3802. return io.ErrUnexpectedEOF
  3803. }
  3804. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3805. iNdEx += skippy
  3806. }
  3807. }
  3808. if iNdEx > l {
  3809. return io.ErrUnexpectedEOF
  3810. }
  3811. return nil
  3812. }
  3813. func (m *ListDiscoveryTopicReply) Unmarshal(dAtA []byte) error {
  3814. l := len(dAtA)
  3815. iNdEx := 0
  3816. for iNdEx < l {
  3817. preIndex := iNdEx
  3818. var wire uint64
  3819. for shift := uint(0); ; shift += 7 {
  3820. if shift >= 64 {
  3821. return ErrIntOverflowApi
  3822. }
  3823. if iNdEx >= l {
  3824. return io.ErrUnexpectedEOF
  3825. }
  3826. b := dAtA[iNdEx]
  3827. iNdEx++
  3828. wire |= (uint64(b) & 0x7F) << shift
  3829. if b < 0x80 {
  3830. break
  3831. }
  3832. }
  3833. fieldNum := int32(wire >> 3)
  3834. wireType := int(wire & 0x7)
  3835. if wireType == 4 {
  3836. return fmt.Errorf("proto: ListDiscoveryTopicReply: wiretype end group for non-group")
  3837. }
  3838. if fieldNum <= 0 {
  3839. return fmt.Errorf("proto: ListDiscoveryTopicReply: illegal tag %d (wire type %d)", fieldNum, wire)
  3840. }
  3841. switch fieldNum {
  3842. case 1:
  3843. if wireType != 2 {
  3844. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  3845. }
  3846. var msglen int
  3847. for shift := uint(0); ; shift += 7 {
  3848. if shift >= 64 {
  3849. return ErrIntOverflowApi
  3850. }
  3851. if iNdEx >= l {
  3852. return io.ErrUnexpectedEOF
  3853. }
  3854. b := dAtA[iNdEx]
  3855. iNdEx++
  3856. msglen |= (int(b) & 0x7F) << shift
  3857. if b < 0x80 {
  3858. break
  3859. }
  3860. }
  3861. if msglen < 0 {
  3862. return ErrInvalidLengthApi
  3863. }
  3864. postIndex := iNdEx + msglen
  3865. if postIndex > l {
  3866. return io.ErrUnexpectedEOF
  3867. }
  3868. m.List = append(m.List, &TopicDetail{})
  3869. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  3870. return err
  3871. }
  3872. iNdEx = postIndex
  3873. case 2:
  3874. if wireType != 0 {
  3875. return fmt.Errorf("proto: wrong wireType = %d for field HasMore", wireType)
  3876. }
  3877. var v int
  3878. for shift := uint(0); ; shift += 7 {
  3879. if shift >= 64 {
  3880. return ErrIntOverflowApi
  3881. }
  3882. if iNdEx >= l {
  3883. return io.ErrUnexpectedEOF
  3884. }
  3885. b := dAtA[iNdEx]
  3886. iNdEx++
  3887. v |= (int(b) & 0x7F) << shift
  3888. if b < 0x80 {
  3889. break
  3890. }
  3891. }
  3892. m.HasMore = bool(v != 0)
  3893. default:
  3894. iNdEx = preIndex
  3895. skippy, err := skipApi(dAtA[iNdEx:])
  3896. if err != nil {
  3897. return err
  3898. }
  3899. if skippy < 0 {
  3900. return ErrInvalidLengthApi
  3901. }
  3902. if (iNdEx + skippy) > l {
  3903. return io.ErrUnexpectedEOF
  3904. }
  3905. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3906. iNdEx += skippy
  3907. }
  3908. }
  3909. if iNdEx > l {
  3910. return io.ErrUnexpectedEOF
  3911. }
  3912. return nil
  3913. }
  3914. func (m *ListTopicsReq) Unmarshal(dAtA []byte) error {
  3915. l := len(dAtA)
  3916. iNdEx := 0
  3917. for iNdEx < l {
  3918. preIndex := iNdEx
  3919. var wire uint64
  3920. for shift := uint(0); ; shift += 7 {
  3921. if shift >= 64 {
  3922. return ErrIntOverflowApi
  3923. }
  3924. if iNdEx >= l {
  3925. return io.ErrUnexpectedEOF
  3926. }
  3927. b := dAtA[iNdEx]
  3928. iNdEx++
  3929. wire |= (uint64(b) & 0x7F) << shift
  3930. if b < 0x80 {
  3931. break
  3932. }
  3933. }
  3934. fieldNum := int32(wire >> 3)
  3935. wireType := int(wire & 0x7)
  3936. if wireType == 4 {
  3937. return fmt.Errorf("proto: ListTopicsReq: wiretype end group for non-group")
  3938. }
  3939. if fieldNum <= 0 {
  3940. return fmt.Errorf("proto: ListTopicsReq: illegal tag %d (wire type %d)", fieldNum, wire)
  3941. }
  3942. switch fieldNum {
  3943. case 1:
  3944. if wireType != 0 {
  3945. return fmt.Errorf("proto: wrong wireType = %d for field Page", wireType)
  3946. }
  3947. m.Page = 0
  3948. for shift := uint(0); ; shift += 7 {
  3949. if shift >= 64 {
  3950. return ErrIntOverflowApi
  3951. }
  3952. if iNdEx >= l {
  3953. return io.ErrUnexpectedEOF
  3954. }
  3955. b := dAtA[iNdEx]
  3956. iNdEx++
  3957. m.Page |= (int32(b) & 0x7F) << shift
  3958. if b < 0x80 {
  3959. break
  3960. }
  3961. }
  3962. default:
  3963. iNdEx = preIndex
  3964. skippy, err := skipApi(dAtA[iNdEx:])
  3965. if err != nil {
  3966. return err
  3967. }
  3968. if skippy < 0 {
  3969. return ErrInvalidLengthApi
  3970. }
  3971. if (iNdEx + skippy) > l {
  3972. return io.ErrUnexpectedEOF
  3973. }
  3974. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  3975. iNdEx += skippy
  3976. }
  3977. }
  3978. if iNdEx > l {
  3979. return io.ErrUnexpectedEOF
  3980. }
  3981. return nil
  3982. }
  3983. func (m *ListTopicsReply) Unmarshal(dAtA []byte) error {
  3984. l := len(dAtA)
  3985. iNdEx := 0
  3986. for iNdEx < l {
  3987. preIndex := iNdEx
  3988. var wire uint64
  3989. for shift := uint(0); ; shift += 7 {
  3990. if shift >= 64 {
  3991. return ErrIntOverflowApi
  3992. }
  3993. if iNdEx >= l {
  3994. return io.ErrUnexpectedEOF
  3995. }
  3996. b := dAtA[iNdEx]
  3997. iNdEx++
  3998. wire |= (uint64(b) & 0x7F) << shift
  3999. if b < 0x80 {
  4000. break
  4001. }
  4002. }
  4003. fieldNum := int32(wire >> 3)
  4004. wireType := int(wire & 0x7)
  4005. if wireType == 4 {
  4006. return fmt.Errorf("proto: ListTopicsReply: wiretype end group for non-group")
  4007. }
  4008. if fieldNum <= 0 {
  4009. return fmt.Errorf("proto: ListTopicsReply: illegal tag %d (wire type %d)", fieldNum, wire)
  4010. }
  4011. switch fieldNum {
  4012. case 1:
  4013. if wireType != 0 {
  4014. return fmt.Errorf("proto: wrong wireType = %d for field HasMore", wireType)
  4015. }
  4016. var v int
  4017. for shift := uint(0); ; shift += 7 {
  4018. if shift >= 64 {
  4019. return ErrIntOverflowApi
  4020. }
  4021. if iNdEx >= l {
  4022. return io.ErrUnexpectedEOF
  4023. }
  4024. b := dAtA[iNdEx]
  4025. iNdEx++
  4026. v |= (int(b) & 0x7F) << shift
  4027. if b < 0x80 {
  4028. break
  4029. }
  4030. }
  4031. m.HasMore = bool(v != 0)
  4032. case 2:
  4033. if wireType != 2 {
  4034. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  4035. }
  4036. var msglen int
  4037. for shift := uint(0); ; shift += 7 {
  4038. if shift >= 64 {
  4039. return ErrIntOverflowApi
  4040. }
  4041. if iNdEx >= l {
  4042. return io.ErrUnexpectedEOF
  4043. }
  4044. b := dAtA[iNdEx]
  4045. iNdEx++
  4046. msglen |= (int(b) & 0x7F) << shift
  4047. if b < 0x80 {
  4048. break
  4049. }
  4050. }
  4051. if msglen < 0 {
  4052. return ErrInvalidLengthApi
  4053. }
  4054. postIndex := iNdEx + msglen
  4055. if postIndex > l {
  4056. return io.ErrUnexpectedEOF
  4057. }
  4058. m.List = append(m.List, &TopicInfo{})
  4059. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  4060. return err
  4061. }
  4062. iNdEx = postIndex
  4063. default:
  4064. iNdEx = preIndex
  4065. skippy, err := skipApi(dAtA[iNdEx:])
  4066. if err != nil {
  4067. return err
  4068. }
  4069. if skippy < 0 {
  4070. return ErrInvalidLengthApi
  4071. }
  4072. if (iNdEx + skippy) > l {
  4073. return io.ErrUnexpectedEOF
  4074. }
  4075. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4076. iNdEx += skippy
  4077. }
  4078. }
  4079. if iNdEx > l {
  4080. return io.ErrUnexpectedEOF
  4081. }
  4082. return nil
  4083. }
  4084. func (m *StickTopicReq) Unmarshal(dAtA []byte) error {
  4085. l := len(dAtA)
  4086. iNdEx := 0
  4087. for iNdEx < l {
  4088. preIndex := iNdEx
  4089. var wire uint64
  4090. for shift := uint(0); ; shift += 7 {
  4091. if shift >= 64 {
  4092. return ErrIntOverflowApi
  4093. }
  4094. if iNdEx >= l {
  4095. return io.ErrUnexpectedEOF
  4096. }
  4097. b := dAtA[iNdEx]
  4098. iNdEx++
  4099. wire |= (uint64(b) & 0x7F) << shift
  4100. if b < 0x80 {
  4101. break
  4102. }
  4103. }
  4104. fieldNum := int32(wire >> 3)
  4105. wireType := int(wire & 0x7)
  4106. if wireType == 4 {
  4107. return fmt.Errorf("proto: StickTopicReq: wiretype end group for non-group")
  4108. }
  4109. if fieldNum <= 0 {
  4110. return fmt.Errorf("proto: StickTopicReq: illegal tag %d (wire type %d)", fieldNum, wire)
  4111. }
  4112. switch fieldNum {
  4113. case 1:
  4114. if wireType != 0 {
  4115. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  4116. }
  4117. m.TopicId = 0
  4118. for shift := uint(0); ; shift += 7 {
  4119. if shift >= 64 {
  4120. return ErrIntOverflowApi
  4121. }
  4122. if iNdEx >= l {
  4123. return io.ErrUnexpectedEOF
  4124. }
  4125. b := dAtA[iNdEx]
  4126. iNdEx++
  4127. m.TopicId |= (int64(b) & 0x7F) << shift
  4128. if b < 0x80 {
  4129. break
  4130. }
  4131. }
  4132. case 2:
  4133. if wireType != 0 {
  4134. return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType)
  4135. }
  4136. m.Op = 0
  4137. for shift := uint(0); ; shift += 7 {
  4138. if shift >= 64 {
  4139. return ErrIntOverflowApi
  4140. }
  4141. if iNdEx >= l {
  4142. return io.ErrUnexpectedEOF
  4143. }
  4144. b := dAtA[iNdEx]
  4145. iNdEx++
  4146. m.Op |= (int64(b) & 0x7F) << shift
  4147. if b < 0x80 {
  4148. break
  4149. }
  4150. }
  4151. default:
  4152. iNdEx = preIndex
  4153. skippy, err := skipApi(dAtA[iNdEx:])
  4154. if err != nil {
  4155. return err
  4156. }
  4157. if skippy < 0 {
  4158. return ErrInvalidLengthApi
  4159. }
  4160. if (iNdEx + skippy) > l {
  4161. return io.ErrUnexpectedEOF
  4162. }
  4163. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4164. iNdEx += skippy
  4165. }
  4166. }
  4167. if iNdEx > l {
  4168. return io.ErrUnexpectedEOF
  4169. }
  4170. return nil
  4171. }
  4172. func (m *StickTopicVideoReq) Unmarshal(dAtA []byte) error {
  4173. l := len(dAtA)
  4174. iNdEx := 0
  4175. for iNdEx < l {
  4176. preIndex := iNdEx
  4177. var wire uint64
  4178. for shift := uint(0); ; shift += 7 {
  4179. if shift >= 64 {
  4180. return ErrIntOverflowApi
  4181. }
  4182. if iNdEx >= l {
  4183. return io.ErrUnexpectedEOF
  4184. }
  4185. b := dAtA[iNdEx]
  4186. iNdEx++
  4187. wire |= (uint64(b) & 0x7F) << shift
  4188. if b < 0x80 {
  4189. break
  4190. }
  4191. }
  4192. fieldNum := int32(wire >> 3)
  4193. wireType := int(wire & 0x7)
  4194. if wireType == 4 {
  4195. return fmt.Errorf("proto: StickTopicVideoReq: wiretype end group for non-group")
  4196. }
  4197. if fieldNum <= 0 {
  4198. return fmt.Errorf("proto: StickTopicVideoReq: illegal tag %d (wire type %d)", fieldNum, wire)
  4199. }
  4200. switch fieldNum {
  4201. case 1:
  4202. if wireType != 0 {
  4203. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  4204. }
  4205. m.TopicId = 0
  4206. for shift := uint(0); ; shift += 7 {
  4207. if shift >= 64 {
  4208. return ErrIntOverflowApi
  4209. }
  4210. if iNdEx >= l {
  4211. return io.ErrUnexpectedEOF
  4212. }
  4213. b := dAtA[iNdEx]
  4214. iNdEx++
  4215. m.TopicId |= (int64(b) & 0x7F) << shift
  4216. if b < 0x80 {
  4217. break
  4218. }
  4219. }
  4220. case 2:
  4221. if wireType != 0 {
  4222. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  4223. }
  4224. m.Svid = 0
  4225. for shift := uint(0); ; shift += 7 {
  4226. if shift >= 64 {
  4227. return ErrIntOverflowApi
  4228. }
  4229. if iNdEx >= l {
  4230. return io.ErrUnexpectedEOF
  4231. }
  4232. b := dAtA[iNdEx]
  4233. iNdEx++
  4234. m.Svid |= (int64(b) & 0x7F) << shift
  4235. if b < 0x80 {
  4236. break
  4237. }
  4238. }
  4239. case 3:
  4240. if wireType != 0 {
  4241. return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType)
  4242. }
  4243. m.Op = 0
  4244. for shift := uint(0); ; shift += 7 {
  4245. if shift >= 64 {
  4246. return ErrIntOverflowApi
  4247. }
  4248. if iNdEx >= l {
  4249. return io.ErrUnexpectedEOF
  4250. }
  4251. b := dAtA[iNdEx]
  4252. iNdEx++
  4253. m.Op |= (int64(b) & 0x7F) << shift
  4254. if b < 0x80 {
  4255. break
  4256. }
  4257. }
  4258. default:
  4259. iNdEx = preIndex
  4260. skippy, err := skipApi(dAtA[iNdEx:])
  4261. if err != nil {
  4262. return err
  4263. }
  4264. if skippy < 0 {
  4265. return ErrInvalidLengthApi
  4266. }
  4267. if (iNdEx + skippy) > l {
  4268. return io.ErrUnexpectedEOF
  4269. }
  4270. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4271. iNdEx += skippy
  4272. }
  4273. }
  4274. if iNdEx > l {
  4275. return io.ErrUnexpectedEOF
  4276. }
  4277. return nil
  4278. }
  4279. func (m *SetStickTopicVideoReq) Unmarshal(dAtA []byte) error {
  4280. l := len(dAtA)
  4281. iNdEx := 0
  4282. for iNdEx < l {
  4283. preIndex := iNdEx
  4284. var wire uint64
  4285. for shift := uint(0); ; shift += 7 {
  4286. if shift >= 64 {
  4287. return ErrIntOverflowApi
  4288. }
  4289. if iNdEx >= l {
  4290. return io.ErrUnexpectedEOF
  4291. }
  4292. b := dAtA[iNdEx]
  4293. iNdEx++
  4294. wire |= (uint64(b) & 0x7F) << shift
  4295. if b < 0x80 {
  4296. break
  4297. }
  4298. }
  4299. fieldNum := int32(wire >> 3)
  4300. wireType := int(wire & 0x7)
  4301. if wireType == 4 {
  4302. return fmt.Errorf("proto: SetStickTopicVideoReq: wiretype end group for non-group")
  4303. }
  4304. if fieldNum <= 0 {
  4305. return fmt.Errorf("proto: SetStickTopicVideoReq: illegal tag %d (wire type %d)", fieldNum, wire)
  4306. }
  4307. switch fieldNum {
  4308. case 1:
  4309. if wireType != 0 {
  4310. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  4311. }
  4312. m.TopicId = 0
  4313. for shift := uint(0); ; shift += 7 {
  4314. if shift >= 64 {
  4315. return ErrIntOverflowApi
  4316. }
  4317. if iNdEx >= l {
  4318. return io.ErrUnexpectedEOF
  4319. }
  4320. b := dAtA[iNdEx]
  4321. iNdEx++
  4322. m.TopicId |= (int64(b) & 0x7F) << shift
  4323. if b < 0x80 {
  4324. break
  4325. }
  4326. }
  4327. case 2:
  4328. if wireType == 0 {
  4329. var v int64
  4330. for shift := uint(0); ; shift += 7 {
  4331. if shift >= 64 {
  4332. return ErrIntOverflowApi
  4333. }
  4334. if iNdEx >= l {
  4335. return io.ErrUnexpectedEOF
  4336. }
  4337. b := dAtA[iNdEx]
  4338. iNdEx++
  4339. v |= (int64(b) & 0x7F) << shift
  4340. if b < 0x80 {
  4341. break
  4342. }
  4343. }
  4344. m.Svids = append(m.Svids, v)
  4345. } else if wireType == 2 {
  4346. var packedLen int
  4347. for shift := uint(0); ; shift += 7 {
  4348. if shift >= 64 {
  4349. return ErrIntOverflowApi
  4350. }
  4351. if iNdEx >= l {
  4352. return io.ErrUnexpectedEOF
  4353. }
  4354. b := dAtA[iNdEx]
  4355. iNdEx++
  4356. packedLen |= (int(b) & 0x7F) << shift
  4357. if b < 0x80 {
  4358. break
  4359. }
  4360. }
  4361. if packedLen < 0 {
  4362. return ErrInvalidLengthApi
  4363. }
  4364. postIndex := iNdEx + packedLen
  4365. if postIndex > l {
  4366. return io.ErrUnexpectedEOF
  4367. }
  4368. var elementCount int
  4369. var count int
  4370. for _, integer := range dAtA {
  4371. if integer < 128 {
  4372. count++
  4373. }
  4374. }
  4375. elementCount = count
  4376. if elementCount != 0 && len(m.Svids) == 0 {
  4377. m.Svids = make([]int64, 0, elementCount)
  4378. }
  4379. for iNdEx < postIndex {
  4380. var v int64
  4381. for shift := uint(0); ; shift += 7 {
  4382. if shift >= 64 {
  4383. return ErrIntOverflowApi
  4384. }
  4385. if iNdEx >= l {
  4386. return io.ErrUnexpectedEOF
  4387. }
  4388. b := dAtA[iNdEx]
  4389. iNdEx++
  4390. v |= (int64(b) & 0x7F) << shift
  4391. if b < 0x80 {
  4392. break
  4393. }
  4394. }
  4395. m.Svids = append(m.Svids, v)
  4396. }
  4397. } else {
  4398. return fmt.Errorf("proto: wrong wireType = %d for field Svids", wireType)
  4399. }
  4400. default:
  4401. iNdEx = preIndex
  4402. skippy, err := skipApi(dAtA[iNdEx:])
  4403. if err != nil {
  4404. return err
  4405. }
  4406. if skippy < 0 {
  4407. return ErrInvalidLengthApi
  4408. }
  4409. if (iNdEx + skippy) > l {
  4410. return io.ErrUnexpectedEOF
  4411. }
  4412. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4413. iNdEx += skippy
  4414. }
  4415. }
  4416. if iNdEx > l {
  4417. return io.ErrUnexpectedEOF
  4418. }
  4419. return nil
  4420. }
  4421. func (m *ListCmsTopicsReq) Unmarshal(dAtA []byte) error {
  4422. l := len(dAtA)
  4423. iNdEx := 0
  4424. for iNdEx < l {
  4425. preIndex := iNdEx
  4426. var wire uint64
  4427. for shift := uint(0); ; shift += 7 {
  4428. if shift >= 64 {
  4429. return ErrIntOverflowApi
  4430. }
  4431. if iNdEx >= l {
  4432. return io.ErrUnexpectedEOF
  4433. }
  4434. b := dAtA[iNdEx]
  4435. iNdEx++
  4436. wire |= (uint64(b) & 0x7F) << shift
  4437. if b < 0x80 {
  4438. break
  4439. }
  4440. }
  4441. fieldNum := int32(wire >> 3)
  4442. wireType := int(wire & 0x7)
  4443. if wireType == 4 {
  4444. return fmt.Errorf("proto: ListCmsTopicsReq: wiretype end group for non-group")
  4445. }
  4446. if fieldNum <= 0 {
  4447. return fmt.Errorf("proto: ListCmsTopicsReq: illegal tag %d (wire type %d)", fieldNum, wire)
  4448. }
  4449. switch fieldNum {
  4450. case 1:
  4451. if wireType != 0 {
  4452. return fmt.Errorf("proto: wrong wireType = %d for field Page", wireType)
  4453. }
  4454. m.Page = 0
  4455. for shift := uint(0); ; shift += 7 {
  4456. if shift >= 64 {
  4457. return ErrIntOverflowApi
  4458. }
  4459. if iNdEx >= l {
  4460. return io.ErrUnexpectedEOF
  4461. }
  4462. b := dAtA[iNdEx]
  4463. iNdEx++
  4464. m.Page |= (int32(b) & 0x7F) << shift
  4465. if b < 0x80 {
  4466. break
  4467. }
  4468. }
  4469. case 2:
  4470. if wireType != 2 {
  4471. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  4472. }
  4473. var stringLen uint64
  4474. for shift := uint(0); ; shift += 7 {
  4475. if shift >= 64 {
  4476. return ErrIntOverflowApi
  4477. }
  4478. if iNdEx >= l {
  4479. return io.ErrUnexpectedEOF
  4480. }
  4481. b := dAtA[iNdEx]
  4482. iNdEx++
  4483. stringLen |= (uint64(b) & 0x7F) << shift
  4484. if b < 0x80 {
  4485. break
  4486. }
  4487. }
  4488. intStringLen := int(stringLen)
  4489. if intStringLen < 0 {
  4490. return ErrInvalidLengthApi
  4491. }
  4492. postIndex := iNdEx + intStringLen
  4493. if postIndex > l {
  4494. return io.ErrUnexpectedEOF
  4495. }
  4496. m.Name = string(dAtA[iNdEx:postIndex])
  4497. iNdEx = postIndex
  4498. case 3:
  4499. if wireType != 0 {
  4500. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  4501. }
  4502. m.TopicId = 0
  4503. for shift := uint(0); ; shift += 7 {
  4504. if shift >= 64 {
  4505. return ErrIntOverflowApi
  4506. }
  4507. if iNdEx >= l {
  4508. return io.ErrUnexpectedEOF
  4509. }
  4510. b := dAtA[iNdEx]
  4511. iNdEx++
  4512. m.TopicId |= (int64(b) & 0x7F) << shift
  4513. if b < 0x80 {
  4514. break
  4515. }
  4516. }
  4517. case 4:
  4518. if wireType != 0 {
  4519. return fmt.Errorf("proto: wrong wireType = %d for field State", wireType)
  4520. }
  4521. m.State = 0
  4522. for shift := uint(0); ; shift += 7 {
  4523. if shift >= 64 {
  4524. return ErrIntOverflowApi
  4525. }
  4526. if iNdEx >= l {
  4527. return io.ErrUnexpectedEOF
  4528. }
  4529. b := dAtA[iNdEx]
  4530. iNdEx++
  4531. m.State |= (int32(b) & 0x7F) << shift
  4532. if b < 0x80 {
  4533. break
  4534. }
  4535. }
  4536. default:
  4537. iNdEx = preIndex
  4538. skippy, err := skipApi(dAtA[iNdEx:])
  4539. if err != nil {
  4540. return err
  4541. }
  4542. if skippy < 0 {
  4543. return ErrInvalidLengthApi
  4544. }
  4545. if (iNdEx + skippy) > l {
  4546. return io.ErrUnexpectedEOF
  4547. }
  4548. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4549. iNdEx += skippy
  4550. }
  4551. }
  4552. if iNdEx > l {
  4553. return io.ErrUnexpectedEOF
  4554. }
  4555. return nil
  4556. }
  4557. func (m *ListCmsTopicsReply) Unmarshal(dAtA []byte) error {
  4558. l := len(dAtA)
  4559. iNdEx := 0
  4560. for iNdEx < l {
  4561. preIndex := iNdEx
  4562. var wire uint64
  4563. for shift := uint(0); ; shift += 7 {
  4564. if shift >= 64 {
  4565. return ErrIntOverflowApi
  4566. }
  4567. if iNdEx >= l {
  4568. return io.ErrUnexpectedEOF
  4569. }
  4570. b := dAtA[iNdEx]
  4571. iNdEx++
  4572. wire |= (uint64(b) & 0x7F) << shift
  4573. if b < 0x80 {
  4574. break
  4575. }
  4576. }
  4577. fieldNum := int32(wire >> 3)
  4578. wireType := int(wire & 0x7)
  4579. if wireType == 4 {
  4580. return fmt.Errorf("proto: ListCmsTopicsReply: wiretype end group for non-group")
  4581. }
  4582. if fieldNum <= 0 {
  4583. return fmt.Errorf("proto: ListCmsTopicsReply: illegal tag %d (wire type %d)", fieldNum, wire)
  4584. }
  4585. switch fieldNum {
  4586. case 1:
  4587. if wireType != 0 {
  4588. return fmt.Errorf("proto: wrong wireType = %d for field HasMore", wireType)
  4589. }
  4590. var v int
  4591. for shift := uint(0); ; shift += 7 {
  4592. if shift >= 64 {
  4593. return ErrIntOverflowApi
  4594. }
  4595. if iNdEx >= l {
  4596. return io.ErrUnexpectedEOF
  4597. }
  4598. b := dAtA[iNdEx]
  4599. iNdEx++
  4600. v |= (int(b) & 0x7F) << shift
  4601. if b < 0x80 {
  4602. break
  4603. }
  4604. }
  4605. m.HasMore = bool(v != 0)
  4606. case 2:
  4607. if wireType != 2 {
  4608. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  4609. }
  4610. var msglen int
  4611. for shift := uint(0); ; shift += 7 {
  4612. if shift >= 64 {
  4613. return ErrIntOverflowApi
  4614. }
  4615. if iNdEx >= l {
  4616. return io.ErrUnexpectedEOF
  4617. }
  4618. b := dAtA[iNdEx]
  4619. iNdEx++
  4620. msglen |= (int(b) & 0x7F) << shift
  4621. if b < 0x80 {
  4622. break
  4623. }
  4624. }
  4625. if msglen < 0 {
  4626. return ErrInvalidLengthApi
  4627. }
  4628. postIndex := iNdEx + msglen
  4629. if postIndex > l {
  4630. return io.ErrUnexpectedEOF
  4631. }
  4632. m.List = append(m.List, &TopicInfo{})
  4633. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  4634. return err
  4635. }
  4636. iNdEx = postIndex
  4637. default:
  4638. iNdEx = preIndex
  4639. skippy, err := skipApi(dAtA[iNdEx:])
  4640. if err != nil {
  4641. return err
  4642. }
  4643. if skippy < 0 {
  4644. return ErrInvalidLengthApi
  4645. }
  4646. if (iNdEx + skippy) > l {
  4647. return io.ErrUnexpectedEOF
  4648. }
  4649. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4650. iNdEx += skippy
  4651. }
  4652. }
  4653. if iNdEx > l {
  4654. return io.ErrUnexpectedEOF
  4655. }
  4656. return nil
  4657. }
  4658. func (m *TopicVideoItem) Unmarshal(dAtA []byte) error {
  4659. l := len(dAtA)
  4660. iNdEx := 0
  4661. for iNdEx < l {
  4662. preIndex := iNdEx
  4663. var wire uint64
  4664. for shift := uint(0); ; shift += 7 {
  4665. if shift >= 64 {
  4666. return ErrIntOverflowApi
  4667. }
  4668. if iNdEx >= l {
  4669. return io.ErrUnexpectedEOF
  4670. }
  4671. b := dAtA[iNdEx]
  4672. iNdEx++
  4673. wire |= (uint64(b) & 0x7F) << shift
  4674. if b < 0x80 {
  4675. break
  4676. }
  4677. }
  4678. fieldNum := int32(wire >> 3)
  4679. wireType := int(wire & 0x7)
  4680. if wireType == 4 {
  4681. return fmt.Errorf("proto: TopicVideoItem: wiretype end group for non-group")
  4682. }
  4683. if fieldNum <= 0 {
  4684. return fmt.Errorf("proto: TopicVideoItem: illegal tag %d (wire type %d)", fieldNum, wire)
  4685. }
  4686. switch fieldNum {
  4687. case 1:
  4688. if wireType != 0 {
  4689. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  4690. }
  4691. m.TopicId = 0
  4692. for shift := uint(0); ; shift += 7 {
  4693. if shift >= 64 {
  4694. return ErrIntOverflowApi
  4695. }
  4696. if iNdEx >= l {
  4697. return io.ErrUnexpectedEOF
  4698. }
  4699. b := dAtA[iNdEx]
  4700. iNdEx++
  4701. m.TopicId |= (int64(b) & 0x7F) << shift
  4702. if b < 0x80 {
  4703. break
  4704. }
  4705. }
  4706. case 2:
  4707. if wireType != 0 {
  4708. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  4709. }
  4710. m.Svid = 0
  4711. for shift := uint(0); ; shift += 7 {
  4712. if shift >= 64 {
  4713. return ErrIntOverflowApi
  4714. }
  4715. if iNdEx >= l {
  4716. return io.ErrUnexpectedEOF
  4717. }
  4718. b := dAtA[iNdEx]
  4719. iNdEx++
  4720. m.Svid |= (int64(b) & 0x7F) << shift
  4721. if b < 0x80 {
  4722. break
  4723. }
  4724. }
  4725. case 3:
  4726. if wireType != 1 {
  4727. return fmt.Errorf("proto: wrong wireType = %d for field Score", wireType)
  4728. }
  4729. var v uint64
  4730. if (iNdEx + 8) > l {
  4731. return io.ErrUnexpectedEOF
  4732. }
  4733. v = uint64(encoding_binary.LittleEndian.Uint64(dAtA[iNdEx:]))
  4734. iNdEx += 8
  4735. m.Score = float64(math.Float64frombits(v))
  4736. case 4:
  4737. if wireType != 0 {
  4738. return fmt.Errorf("proto: wrong wireType = %d for field State", wireType)
  4739. }
  4740. m.State = 0
  4741. for shift := uint(0); ; shift += 7 {
  4742. if shift >= 64 {
  4743. return ErrIntOverflowApi
  4744. }
  4745. if iNdEx >= l {
  4746. return io.ErrUnexpectedEOF
  4747. }
  4748. b := dAtA[iNdEx]
  4749. iNdEx++
  4750. m.State |= (int32(b) & 0x7F) << shift
  4751. if b < 0x80 {
  4752. break
  4753. }
  4754. }
  4755. default:
  4756. iNdEx = preIndex
  4757. skippy, err := skipApi(dAtA[iNdEx:])
  4758. if err != nil {
  4759. return err
  4760. }
  4761. if skippy < 0 {
  4762. return ErrInvalidLengthApi
  4763. }
  4764. if (iNdEx + skippy) > l {
  4765. return io.ErrUnexpectedEOF
  4766. }
  4767. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4768. iNdEx += skippy
  4769. }
  4770. }
  4771. if iNdEx > l {
  4772. return io.ErrUnexpectedEOF
  4773. }
  4774. return nil
  4775. }
  4776. func (m *VideoTopicReq) Unmarshal(dAtA []byte) error {
  4777. l := len(dAtA)
  4778. iNdEx := 0
  4779. for iNdEx < l {
  4780. preIndex := iNdEx
  4781. var wire uint64
  4782. for shift := uint(0); ; shift += 7 {
  4783. if shift >= 64 {
  4784. return ErrIntOverflowApi
  4785. }
  4786. if iNdEx >= l {
  4787. return io.ErrUnexpectedEOF
  4788. }
  4789. b := dAtA[iNdEx]
  4790. iNdEx++
  4791. wire |= (uint64(b) & 0x7F) << shift
  4792. if b < 0x80 {
  4793. break
  4794. }
  4795. }
  4796. fieldNum := int32(wire >> 3)
  4797. wireType := int(wire & 0x7)
  4798. if wireType == 4 {
  4799. return fmt.Errorf("proto: VideoTopicReq: wiretype end group for non-group")
  4800. }
  4801. if fieldNum <= 0 {
  4802. return fmt.Errorf("proto: VideoTopicReq: illegal tag %d (wire type %d)", fieldNum, wire)
  4803. }
  4804. switch fieldNum {
  4805. case 1:
  4806. if wireType != 0 {
  4807. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  4808. }
  4809. m.Svid = 0
  4810. for shift := uint(0); ; shift += 7 {
  4811. if shift >= 64 {
  4812. return ErrIntOverflowApi
  4813. }
  4814. if iNdEx >= l {
  4815. return io.ErrUnexpectedEOF
  4816. }
  4817. b := dAtA[iNdEx]
  4818. iNdEx++
  4819. m.Svid |= (int64(b) & 0x7F) << shift
  4820. if b < 0x80 {
  4821. break
  4822. }
  4823. }
  4824. default:
  4825. iNdEx = preIndex
  4826. skippy, err := skipApi(dAtA[iNdEx:])
  4827. if err != nil {
  4828. return err
  4829. }
  4830. if skippy < 0 {
  4831. return ErrInvalidLengthApi
  4832. }
  4833. if (iNdEx + skippy) > l {
  4834. return io.ErrUnexpectedEOF
  4835. }
  4836. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4837. iNdEx += skippy
  4838. }
  4839. }
  4840. if iNdEx > l {
  4841. return io.ErrUnexpectedEOF
  4842. }
  4843. return nil
  4844. }
  4845. func (m *VideoTopicReply) Unmarshal(dAtA []byte) error {
  4846. l := len(dAtA)
  4847. iNdEx := 0
  4848. for iNdEx < l {
  4849. preIndex := iNdEx
  4850. var wire uint64
  4851. for shift := uint(0); ; shift += 7 {
  4852. if shift >= 64 {
  4853. return ErrIntOverflowApi
  4854. }
  4855. if iNdEx >= l {
  4856. return io.ErrUnexpectedEOF
  4857. }
  4858. b := dAtA[iNdEx]
  4859. iNdEx++
  4860. wire |= (uint64(b) & 0x7F) << shift
  4861. if b < 0x80 {
  4862. break
  4863. }
  4864. }
  4865. fieldNum := int32(wire >> 3)
  4866. wireType := int(wire & 0x7)
  4867. if wireType == 4 {
  4868. return fmt.Errorf("proto: VideoTopicReply: wiretype end group for non-group")
  4869. }
  4870. if fieldNum <= 0 {
  4871. return fmt.Errorf("proto: VideoTopicReply: illegal tag %d (wire type %d)", fieldNum, wire)
  4872. }
  4873. switch fieldNum {
  4874. case 1:
  4875. if wireType != 2 {
  4876. return fmt.Errorf("proto: wrong wireType = %d for field List", wireType)
  4877. }
  4878. var msglen int
  4879. for shift := uint(0); ; shift += 7 {
  4880. if shift >= 64 {
  4881. return ErrIntOverflowApi
  4882. }
  4883. if iNdEx >= l {
  4884. return io.ErrUnexpectedEOF
  4885. }
  4886. b := dAtA[iNdEx]
  4887. iNdEx++
  4888. msglen |= (int(b) & 0x7F) << shift
  4889. if b < 0x80 {
  4890. break
  4891. }
  4892. }
  4893. if msglen < 0 {
  4894. return ErrInvalidLengthApi
  4895. }
  4896. postIndex := iNdEx + msglen
  4897. if postIndex > l {
  4898. return io.ErrUnexpectedEOF
  4899. }
  4900. m.List = append(m.List, &TopicVideoItem{})
  4901. if err := m.List[len(m.List)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  4902. return err
  4903. }
  4904. iNdEx = postIndex
  4905. default:
  4906. iNdEx = preIndex
  4907. skippy, err := skipApi(dAtA[iNdEx:])
  4908. if err != nil {
  4909. return err
  4910. }
  4911. if skippy < 0 {
  4912. return ErrInvalidLengthApi
  4913. }
  4914. if (iNdEx + skippy) > l {
  4915. return io.ErrUnexpectedEOF
  4916. }
  4917. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  4918. iNdEx += skippy
  4919. }
  4920. }
  4921. if iNdEx > l {
  4922. return io.ErrUnexpectedEOF
  4923. }
  4924. return nil
  4925. }
  4926. func (m *UpdateTopicStateReq) Unmarshal(dAtA []byte) error {
  4927. l := len(dAtA)
  4928. iNdEx := 0
  4929. for iNdEx < l {
  4930. preIndex := iNdEx
  4931. var wire uint64
  4932. for shift := uint(0); ; shift += 7 {
  4933. if shift >= 64 {
  4934. return ErrIntOverflowApi
  4935. }
  4936. if iNdEx >= l {
  4937. return io.ErrUnexpectedEOF
  4938. }
  4939. b := dAtA[iNdEx]
  4940. iNdEx++
  4941. wire |= (uint64(b) & 0x7F) << shift
  4942. if b < 0x80 {
  4943. break
  4944. }
  4945. }
  4946. fieldNum := int32(wire >> 3)
  4947. wireType := int(wire & 0x7)
  4948. if wireType == 4 {
  4949. return fmt.Errorf("proto: UpdateTopicStateReq: wiretype end group for non-group")
  4950. }
  4951. if fieldNum <= 0 {
  4952. return fmt.Errorf("proto: UpdateTopicStateReq: illegal tag %d (wire type %d)", fieldNum, wire)
  4953. }
  4954. switch fieldNum {
  4955. case 1:
  4956. if wireType != 0 {
  4957. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  4958. }
  4959. m.TopicId = 0
  4960. for shift := uint(0); ; shift += 7 {
  4961. if shift >= 64 {
  4962. return ErrIntOverflowApi
  4963. }
  4964. if iNdEx >= l {
  4965. return io.ErrUnexpectedEOF
  4966. }
  4967. b := dAtA[iNdEx]
  4968. iNdEx++
  4969. m.TopicId |= (int64(b) & 0x7F) << shift
  4970. if b < 0x80 {
  4971. break
  4972. }
  4973. }
  4974. case 2:
  4975. if wireType != 0 {
  4976. return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType)
  4977. }
  4978. m.Op = 0
  4979. for shift := uint(0); ; shift += 7 {
  4980. if shift >= 64 {
  4981. return ErrIntOverflowApi
  4982. }
  4983. if iNdEx >= l {
  4984. return io.ErrUnexpectedEOF
  4985. }
  4986. b := dAtA[iNdEx]
  4987. iNdEx++
  4988. m.Op |= (int32(b) & 0x7F) << shift
  4989. if b < 0x80 {
  4990. break
  4991. }
  4992. }
  4993. default:
  4994. iNdEx = preIndex
  4995. skippy, err := skipApi(dAtA[iNdEx:])
  4996. if err != nil {
  4997. return err
  4998. }
  4999. if skippy < 0 {
  5000. return ErrInvalidLengthApi
  5001. }
  5002. if (iNdEx + skippy) > l {
  5003. return io.ErrUnexpectedEOF
  5004. }
  5005. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  5006. iNdEx += skippy
  5007. }
  5008. }
  5009. if iNdEx > l {
  5010. return io.ErrUnexpectedEOF
  5011. }
  5012. return nil
  5013. }
  5014. func (m *TopicInfo) Unmarshal(dAtA []byte) error {
  5015. l := len(dAtA)
  5016. iNdEx := 0
  5017. for iNdEx < l {
  5018. preIndex := iNdEx
  5019. var wire uint64
  5020. for shift := uint(0); ; shift += 7 {
  5021. if shift >= 64 {
  5022. return ErrIntOverflowApi
  5023. }
  5024. if iNdEx >= l {
  5025. return io.ErrUnexpectedEOF
  5026. }
  5027. b := dAtA[iNdEx]
  5028. iNdEx++
  5029. wire |= (uint64(b) & 0x7F) << shift
  5030. if b < 0x80 {
  5031. break
  5032. }
  5033. }
  5034. fieldNum := int32(wire >> 3)
  5035. wireType := int(wire & 0x7)
  5036. if wireType == 4 {
  5037. return fmt.Errorf("proto: TopicInfo: wiretype end group for non-group")
  5038. }
  5039. if fieldNum <= 0 {
  5040. return fmt.Errorf("proto: TopicInfo: illegal tag %d (wire type %d)", fieldNum, wire)
  5041. }
  5042. switch fieldNum {
  5043. case 1:
  5044. if wireType != 0 {
  5045. return fmt.Errorf("proto: wrong wireType = %d for field TopicId", wireType)
  5046. }
  5047. m.TopicId = 0
  5048. for shift := uint(0); ; shift += 7 {
  5049. if shift >= 64 {
  5050. return ErrIntOverflowApi
  5051. }
  5052. if iNdEx >= l {
  5053. return io.ErrUnexpectedEOF
  5054. }
  5055. b := dAtA[iNdEx]
  5056. iNdEx++
  5057. m.TopicId |= (int64(b) & 0x7F) << shift
  5058. if b < 0x80 {
  5059. break
  5060. }
  5061. }
  5062. case 2:
  5063. if wireType != 2 {
  5064. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  5065. }
  5066. var stringLen uint64
  5067. for shift := uint(0); ; shift += 7 {
  5068. if shift >= 64 {
  5069. return ErrIntOverflowApi
  5070. }
  5071. if iNdEx >= l {
  5072. return io.ErrUnexpectedEOF
  5073. }
  5074. b := dAtA[iNdEx]
  5075. iNdEx++
  5076. stringLen |= (uint64(b) & 0x7F) << shift
  5077. if b < 0x80 {
  5078. break
  5079. }
  5080. }
  5081. intStringLen := int(stringLen)
  5082. if intStringLen < 0 {
  5083. return ErrInvalidLengthApi
  5084. }
  5085. postIndex := iNdEx + intStringLen
  5086. if postIndex > l {
  5087. return io.ErrUnexpectedEOF
  5088. }
  5089. m.Name = string(dAtA[iNdEx:postIndex])
  5090. iNdEx = postIndex
  5091. case 3:
  5092. if wireType != 2 {
  5093. return fmt.Errorf("proto: wrong wireType = %d for field Desc", wireType)
  5094. }
  5095. var stringLen uint64
  5096. for shift := uint(0); ; shift += 7 {
  5097. if shift >= 64 {
  5098. return ErrIntOverflowApi
  5099. }
  5100. if iNdEx >= l {
  5101. return io.ErrUnexpectedEOF
  5102. }
  5103. b := dAtA[iNdEx]
  5104. iNdEx++
  5105. stringLen |= (uint64(b) & 0x7F) << shift
  5106. if b < 0x80 {
  5107. break
  5108. }
  5109. }
  5110. intStringLen := int(stringLen)
  5111. if intStringLen < 0 {
  5112. return ErrInvalidLengthApi
  5113. }
  5114. postIndex := iNdEx + intStringLen
  5115. if postIndex > l {
  5116. return io.ErrUnexpectedEOF
  5117. }
  5118. m.Desc = string(dAtA[iNdEx:postIndex])
  5119. iNdEx = postIndex
  5120. case 4:
  5121. if wireType != 1 {
  5122. return fmt.Errorf("proto: wrong wireType = %d for field Score", wireType)
  5123. }
  5124. var v uint64
  5125. if (iNdEx + 8) > l {
  5126. return io.ErrUnexpectedEOF
  5127. }
  5128. v = uint64(encoding_binary.LittleEndian.Uint64(dAtA[iNdEx:]))
  5129. iNdEx += 8
  5130. m.Score = float64(math.Float64frombits(v))
  5131. case 5:
  5132. if wireType != 0 {
  5133. return fmt.Errorf("proto: wrong wireType = %d for field State", wireType)
  5134. }
  5135. m.State = 0
  5136. for shift := uint(0); ; shift += 7 {
  5137. if shift >= 64 {
  5138. return ErrIntOverflowApi
  5139. }
  5140. if iNdEx >= l {
  5141. return io.ErrUnexpectedEOF
  5142. }
  5143. b := dAtA[iNdEx]
  5144. iNdEx++
  5145. m.State |= (int32(b) & 0x7F) << shift
  5146. if b < 0x80 {
  5147. break
  5148. }
  5149. }
  5150. case 6:
  5151. if wireType != 0 {
  5152. return fmt.Errorf("proto: wrong wireType = %d for field HotType", wireType)
  5153. }
  5154. m.HotType = 0
  5155. for shift := uint(0); ; shift += 7 {
  5156. if shift >= 64 {
  5157. return ErrIntOverflowApi
  5158. }
  5159. if iNdEx >= l {
  5160. return io.ErrUnexpectedEOF
  5161. }
  5162. b := dAtA[iNdEx]
  5163. iNdEx++
  5164. m.HotType |= (int32(b) & 0x7F) << shift
  5165. if b < 0x80 {
  5166. break
  5167. }
  5168. }
  5169. case 7:
  5170. if wireType != 2 {
  5171. return fmt.Errorf("proto: wrong wireType = %d for field CoverUrl", wireType)
  5172. }
  5173. var stringLen uint64
  5174. for shift := uint(0); ; shift += 7 {
  5175. if shift >= 64 {
  5176. return ErrIntOverflowApi
  5177. }
  5178. if iNdEx >= l {
  5179. return io.ErrUnexpectedEOF
  5180. }
  5181. b := dAtA[iNdEx]
  5182. iNdEx++
  5183. stringLen |= (uint64(b) & 0x7F) << shift
  5184. if b < 0x80 {
  5185. break
  5186. }
  5187. }
  5188. intStringLen := int(stringLen)
  5189. if intStringLen < 0 {
  5190. return ErrInvalidLengthApi
  5191. }
  5192. postIndex := iNdEx + intStringLen
  5193. if postIndex > l {
  5194. return io.ErrUnexpectedEOF
  5195. }
  5196. m.CoverUrl = string(dAtA[iNdEx:postIndex])
  5197. iNdEx = postIndex
  5198. default:
  5199. iNdEx = preIndex
  5200. skippy, err := skipApi(dAtA[iNdEx:])
  5201. if err != nil {
  5202. return err
  5203. }
  5204. if skippy < 0 {
  5205. return ErrInvalidLengthApi
  5206. }
  5207. if (iNdEx + skippy) > l {
  5208. return io.ErrUnexpectedEOF
  5209. }
  5210. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  5211. iNdEx += skippy
  5212. }
  5213. }
  5214. if iNdEx > l {
  5215. return io.ErrUnexpectedEOF
  5216. }
  5217. return nil
  5218. }
  5219. func (m *TitleExtraItem) Unmarshal(dAtA []byte) error {
  5220. l := len(dAtA)
  5221. iNdEx := 0
  5222. for iNdEx < l {
  5223. preIndex := iNdEx
  5224. var wire uint64
  5225. for shift := uint(0); ; shift += 7 {
  5226. if shift >= 64 {
  5227. return ErrIntOverflowApi
  5228. }
  5229. if iNdEx >= l {
  5230. return io.ErrUnexpectedEOF
  5231. }
  5232. b := dAtA[iNdEx]
  5233. iNdEx++
  5234. wire |= (uint64(b) & 0x7F) << shift
  5235. if b < 0x80 {
  5236. break
  5237. }
  5238. }
  5239. fieldNum := int32(wire >> 3)
  5240. wireType := int(wire & 0x7)
  5241. if wireType == 4 {
  5242. return fmt.Errorf("proto: TitleExtraItem: wiretype end group for non-group")
  5243. }
  5244. if fieldNum <= 0 {
  5245. return fmt.Errorf("proto: TitleExtraItem: illegal tag %d (wire type %d)", fieldNum, wire)
  5246. }
  5247. switch fieldNum {
  5248. case 1:
  5249. if wireType != 0 {
  5250. return fmt.Errorf("proto: wrong wireType = %d for field Id", wireType)
  5251. }
  5252. m.Id = 0
  5253. for shift := uint(0); ; shift += 7 {
  5254. if shift >= 64 {
  5255. return ErrIntOverflowApi
  5256. }
  5257. if iNdEx >= l {
  5258. return io.ErrUnexpectedEOF
  5259. }
  5260. b := dAtA[iNdEx]
  5261. iNdEx++
  5262. m.Id |= (int64(b) & 0x7F) << shift
  5263. if b < 0x80 {
  5264. break
  5265. }
  5266. }
  5267. case 2:
  5268. if wireType != 0 {
  5269. return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
  5270. }
  5271. m.Type = 0
  5272. for shift := uint(0); ; shift += 7 {
  5273. if shift >= 64 {
  5274. return ErrIntOverflowApi
  5275. }
  5276. if iNdEx >= l {
  5277. return io.ErrUnexpectedEOF
  5278. }
  5279. b := dAtA[iNdEx]
  5280. iNdEx++
  5281. m.Type |= (int64(b) & 0x7F) << shift
  5282. if b < 0x80 {
  5283. break
  5284. }
  5285. }
  5286. case 3:
  5287. if wireType != 2 {
  5288. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  5289. }
  5290. var stringLen uint64
  5291. for shift := uint(0); ; shift += 7 {
  5292. if shift >= 64 {
  5293. return ErrIntOverflowApi
  5294. }
  5295. if iNdEx >= l {
  5296. return io.ErrUnexpectedEOF
  5297. }
  5298. b := dAtA[iNdEx]
  5299. iNdEx++
  5300. stringLen |= (uint64(b) & 0x7F) << shift
  5301. if b < 0x80 {
  5302. break
  5303. }
  5304. }
  5305. intStringLen := int(stringLen)
  5306. if intStringLen < 0 {
  5307. return ErrInvalidLengthApi
  5308. }
  5309. postIndex := iNdEx + intStringLen
  5310. if postIndex > l {
  5311. return io.ErrUnexpectedEOF
  5312. }
  5313. m.Name = string(dAtA[iNdEx:postIndex])
  5314. iNdEx = postIndex
  5315. case 4:
  5316. if wireType != 0 {
  5317. return fmt.Errorf("proto: wrong wireType = %d for field Start", wireType)
  5318. }
  5319. m.Start = 0
  5320. for shift := uint(0); ; shift += 7 {
  5321. if shift >= 64 {
  5322. return ErrIntOverflowApi
  5323. }
  5324. if iNdEx >= l {
  5325. return io.ErrUnexpectedEOF
  5326. }
  5327. b := dAtA[iNdEx]
  5328. iNdEx++
  5329. m.Start |= (int64(b) & 0x7F) << shift
  5330. if b < 0x80 {
  5331. break
  5332. }
  5333. }
  5334. case 5:
  5335. if wireType != 0 {
  5336. return fmt.Errorf("proto: wrong wireType = %d for field End", wireType)
  5337. }
  5338. m.End = 0
  5339. for shift := uint(0); ; shift += 7 {
  5340. if shift >= 64 {
  5341. return ErrIntOverflowApi
  5342. }
  5343. if iNdEx >= l {
  5344. return io.ErrUnexpectedEOF
  5345. }
  5346. b := dAtA[iNdEx]
  5347. iNdEx++
  5348. m.End |= (int64(b) & 0x7F) << shift
  5349. if b < 0x80 {
  5350. break
  5351. }
  5352. }
  5353. case 6:
  5354. if wireType != 2 {
  5355. return fmt.Errorf("proto: wrong wireType = %d for field Scheme", wireType)
  5356. }
  5357. var stringLen uint64
  5358. for shift := uint(0); ; shift += 7 {
  5359. if shift >= 64 {
  5360. return ErrIntOverflowApi
  5361. }
  5362. if iNdEx >= l {
  5363. return io.ErrUnexpectedEOF
  5364. }
  5365. b := dAtA[iNdEx]
  5366. iNdEx++
  5367. stringLen |= (uint64(b) & 0x7F) << shift
  5368. if b < 0x80 {
  5369. break
  5370. }
  5371. }
  5372. intStringLen := int(stringLen)
  5373. if intStringLen < 0 {
  5374. return ErrInvalidLengthApi
  5375. }
  5376. postIndex := iNdEx + intStringLen
  5377. if postIndex > l {
  5378. return io.ErrUnexpectedEOF
  5379. }
  5380. m.Scheme = string(dAtA[iNdEx:postIndex])
  5381. iNdEx = postIndex
  5382. default:
  5383. iNdEx = preIndex
  5384. skippy, err := skipApi(dAtA[iNdEx:])
  5385. if err != nil {
  5386. return err
  5387. }
  5388. if skippy < 0 {
  5389. return ErrInvalidLengthApi
  5390. }
  5391. if (iNdEx + skippy) > l {
  5392. return io.ErrUnexpectedEOF
  5393. }
  5394. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  5395. iNdEx += skippy
  5396. }
  5397. }
  5398. if iNdEx > l {
  5399. return io.ErrUnexpectedEOF
  5400. }
  5401. return nil
  5402. }
  5403. func (m *VideoExtension) Unmarshal(dAtA []byte) error {
  5404. l := len(dAtA)
  5405. iNdEx := 0
  5406. for iNdEx < l {
  5407. preIndex := iNdEx
  5408. var wire uint64
  5409. for shift := uint(0); ; shift += 7 {
  5410. if shift >= 64 {
  5411. return ErrIntOverflowApi
  5412. }
  5413. if iNdEx >= l {
  5414. return io.ErrUnexpectedEOF
  5415. }
  5416. b := dAtA[iNdEx]
  5417. iNdEx++
  5418. wire |= (uint64(b) & 0x7F) << shift
  5419. if b < 0x80 {
  5420. break
  5421. }
  5422. }
  5423. fieldNum := int32(wire >> 3)
  5424. wireType := int(wire & 0x7)
  5425. if wireType == 4 {
  5426. return fmt.Errorf("proto: VideoExtension: wiretype end group for non-group")
  5427. }
  5428. if fieldNum <= 0 {
  5429. return fmt.Errorf("proto: VideoExtension: illegal tag %d (wire type %d)", fieldNum, wire)
  5430. }
  5431. switch fieldNum {
  5432. case 1:
  5433. if wireType != 0 {
  5434. return fmt.Errorf("proto: wrong wireType = %d for field Svid", wireType)
  5435. }
  5436. m.Svid = 0
  5437. for shift := uint(0); ; shift += 7 {
  5438. if shift >= 64 {
  5439. return ErrIntOverflowApi
  5440. }
  5441. if iNdEx >= l {
  5442. return io.ErrUnexpectedEOF
  5443. }
  5444. b := dAtA[iNdEx]
  5445. iNdEx++
  5446. m.Svid |= (int64(b) & 0x7F) << shift
  5447. if b < 0x80 {
  5448. break
  5449. }
  5450. }
  5451. case 2:
  5452. if wireType != 2 {
  5453. return fmt.Errorf("proto: wrong wireType = %d for field Extension", wireType)
  5454. }
  5455. var stringLen uint64
  5456. for shift := uint(0); ; shift += 7 {
  5457. if shift >= 64 {
  5458. return ErrIntOverflowApi
  5459. }
  5460. if iNdEx >= l {
  5461. return io.ErrUnexpectedEOF
  5462. }
  5463. b := dAtA[iNdEx]
  5464. iNdEx++
  5465. stringLen |= (uint64(b) & 0x7F) << shift
  5466. if b < 0x80 {
  5467. break
  5468. }
  5469. }
  5470. intStringLen := int(stringLen)
  5471. if intStringLen < 0 {
  5472. return ErrInvalidLengthApi
  5473. }
  5474. postIndex := iNdEx + intStringLen
  5475. if postIndex > l {
  5476. return io.ErrUnexpectedEOF
  5477. }
  5478. m.Extension = string(dAtA[iNdEx:postIndex])
  5479. iNdEx = postIndex
  5480. default:
  5481. iNdEx = preIndex
  5482. skippy, err := skipApi(dAtA[iNdEx:])
  5483. if err != nil {
  5484. return err
  5485. }
  5486. if skippy < 0 {
  5487. return ErrInvalidLengthApi
  5488. }
  5489. if (iNdEx + skippy) > l {
  5490. return io.ErrUnexpectedEOF
  5491. }
  5492. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  5493. iNdEx += skippy
  5494. }
  5495. }
  5496. if iNdEx > l {
  5497. return io.ErrUnexpectedEOF
  5498. }
  5499. return nil
  5500. }
  5501. func (m *Extension) Unmarshal(dAtA []byte) error {
  5502. l := len(dAtA)
  5503. iNdEx := 0
  5504. for iNdEx < l {
  5505. preIndex := iNdEx
  5506. var wire uint64
  5507. for shift := uint(0); ; shift += 7 {
  5508. if shift >= 64 {
  5509. return ErrIntOverflowApi
  5510. }
  5511. if iNdEx >= l {
  5512. return io.ErrUnexpectedEOF
  5513. }
  5514. b := dAtA[iNdEx]
  5515. iNdEx++
  5516. wire |= (uint64(b) & 0x7F) << shift
  5517. if b < 0x80 {
  5518. break
  5519. }
  5520. }
  5521. fieldNum := int32(wire >> 3)
  5522. wireType := int(wire & 0x7)
  5523. if wireType == 4 {
  5524. return fmt.Errorf("proto: Extension: wiretype end group for non-group")
  5525. }
  5526. if fieldNum <= 0 {
  5527. return fmt.Errorf("proto: Extension: illegal tag %d (wire type %d)", fieldNum, wire)
  5528. }
  5529. switch fieldNum {
  5530. case 1:
  5531. if wireType != 2 {
  5532. return fmt.Errorf("proto: wrong wireType = %d for field TitleExtra", wireType)
  5533. }
  5534. var msglen int
  5535. for shift := uint(0); ; shift += 7 {
  5536. if shift >= 64 {
  5537. return ErrIntOverflowApi
  5538. }
  5539. if iNdEx >= l {
  5540. return io.ErrUnexpectedEOF
  5541. }
  5542. b := dAtA[iNdEx]
  5543. iNdEx++
  5544. msglen |= (int(b) & 0x7F) << shift
  5545. if b < 0x80 {
  5546. break
  5547. }
  5548. }
  5549. if msglen < 0 {
  5550. return ErrInvalidLengthApi
  5551. }
  5552. postIndex := iNdEx + msglen
  5553. if postIndex > l {
  5554. return io.ErrUnexpectedEOF
  5555. }
  5556. m.TitleExtra = append(m.TitleExtra, &TitleExtraItem{})
  5557. if err := m.TitleExtra[len(m.TitleExtra)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
  5558. return err
  5559. }
  5560. iNdEx = postIndex
  5561. default:
  5562. iNdEx = preIndex
  5563. skippy, err := skipApi(dAtA[iNdEx:])
  5564. if err != nil {
  5565. return err
  5566. }
  5567. if skippy < 0 {
  5568. return ErrInvalidLengthApi
  5569. }
  5570. if (iNdEx + skippy) > l {
  5571. return io.ErrUnexpectedEOF
  5572. }
  5573. m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
  5574. iNdEx += skippy
  5575. }
  5576. }
  5577. if iNdEx > l {
  5578. return io.ErrUnexpectedEOF
  5579. }
  5580. return nil
  5581. }
  5582. func skipApi(dAtA []byte) (n int, err error) {
  5583. l := len(dAtA)
  5584. iNdEx := 0
  5585. for iNdEx < l {
  5586. var wire uint64
  5587. for shift := uint(0); ; shift += 7 {
  5588. if shift >= 64 {
  5589. return 0, ErrIntOverflowApi
  5590. }
  5591. if iNdEx >= l {
  5592. return 0, io.ErrUnexpectedEOF
  5593. }
  5594. b := dAtA[iNdEx]
  5595. iNdEx++
  5596. wire |= (uint64(b) & 0x7F) << shift
  5597. if b < 0x80 {
  5598. break
  5599. }
  5600. }
  5601. wireType := int(wire & 0x7)
  5602. switch wireType {
  5603. case 0:
  5604. for shift := uint(0); ; shift += 7 {
  5605. if shift >= 64 {
  5606. return 0, ErrIntOverflowApi
  5607. }
  5608. if iNdEx >= l {
  5609. return 0, io.ErrUnexpectedEOF
  5610. }
  5611. iNdEx++
  5612. if dAtA[iNdEx-1] < 0x80 {
  5613. break
  5614. }
  5615. }
  5616. return iNdEx, nil
  5617. case 1:
  5618. iNdEx += 8
  5619. return iNdEx, nil
  5620. case 2:
  5621. var length int
  5622. for shift := uint(0); ; shift += 7 {
  5623. if shift >= 64 {
  5624. return 0, ErrIntOverflowApi
  5625. }
  5626. if iNdEx >= l {
  5627. return 0, io.ErrUnexpectedEOF
  5628. }
  5629. b := dAtA[iNdEx]
  5630. iNdEx++
  5631. length |= (int(b) & 0x7F) << shift
  5632. if b < 0x80 {
  5633. break
  5634. }
  5635. }
  5636. iNdEx += length
  5637. if length < 0 {
  5638. return 0, ErrInvalidLengthApi
  5639. }
  5640. return iNdEx, nil
  5641. case 3:
  5642. for {
  5643. var innerWire uint64
  5644. var start int = iNdEx
  5645. for shift := uint(0); ; shift += 7 {
  5646. if shift >= 64 {
  5647. return 0, ErrIntOverflowApi
  5648. }
  5649. if iNdEx >= l {
  5650. return 0, io.ErrUnexpectedEOF
  5651. }
  5652. b := dAtA[iNdEx]
  5653. iNdEx++
  5654. innerWire |= (uint64(b) & 0x7F) << shift
  5655. if b < 0x80 {
  5656. break
  5657. }
  5658. }
  5659. innerWireType := int(innerWire & 0x7)
  5660. if innerWireType == 4 {
  5661. break
  5662. }
  5663. next, err := skipApi(dAtA[start:])
  5664. if err != nil {
  5665. return 0, err
  5666. }
  5667. iNdEx = start + next
  5668. }
  5669. return iNdEx, nil
  5670. case 4:
  5671. return iNdEx, nil
  5672. case 5:
  5673. iNdEx += 4
  5674. return iNdEx, nil
  5675. default:
  5676. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  5677. }
  5678. }
  5679. panic("unreachable")
  5680. }
  5681. var (
  5682. ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
  5683. ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")
  5684. )
  5685. func init() {
  5686. proto.RegisterFile("app/service/bbq/topic/api/api.proto", fileDescriptor_api_328ca58160a5beb9)
  5687. }
  5688. var fileDescriptor_api_328ca58160a5beb9 = []byte{
  5689. // 1303 bytes of a gzipped FileDescriptorProto
  5690. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x56, 0xcd, 0x6e, 0xdb, 0xc6,
  5691. 0x13, 0xff, 0x53, 0x94, 0x6d, 0x71, 0x1c, 0x47, 0xc6, 0xe6, 0xe3, 0x6f, 0xab, 0xa9, 0xe9, 0x50,
  5692. 0x6d, 0xa2, 0xa2, 0x88, 0x84, 0x24, 0x2d, 0x52, 0xe4, 0xd0, 0x02, 0x6c, 0x0c, 0xc4, 0x4d, 0x13,
  5693. 0x04, 0xeb, 0x24, 0x48, 0x03, 0x14, 0x02, 0x25, 0xad, 0x25, 0x22, 0x92, 0x48, 0x93, 0x2b, 0x21,
  5694. 0x3e, 0xf7, 0xde, 0x17, 0xe9, 0xa5, 0xe8, 0x33, 0xf4, 0x90, 0x63, 0x1f, 0xa0, 0x20, 0x5a, 0x1f,
  5695. 0x75, 0xd4, 0x13, 0x14, 0x3b, 0xcb, 0x2f, 0xd1, 0xa2, 0xa4, 0x34, 0xcd, 0xc1, 0x16, 0x77, 0x67,
  5696. 0x67, 0x76, 0xe6, 0x37, 0x33, 0xfb, 0x1b, 0xa8, 0x5a, 0xae, 0xdb, 0xf0, 0x99, 0x37, 0xb6, 0xdb,
  5697. 0xac, 0xd1, 0x6a, 0x9d, 0x34, 0xb8, 0xe3, 0xda, 0xed, 0x86, 0xe5, 0xda, 0xe2, 0xaf, 0xee, 0x7a,
  5698. 0x0e, 0x77, 0xc8, 0xe5, 0x56, 0xeb, 0xa4, 0x1e, 0x1e, 0xaa, 0xe3, 0x81, 0xfa, 0xf8, 0x76, 0xe5,
  5699. 0x56, 0xd7, 0xe6, 0xbd, 0x51, 0xab, 0xde, 0x76, 0x06, 0x8d, 0xae, 0xd3, 0x75, 0x1a, 0x78, 0xb8,
  5700. 0x35, 0x3a, 0xc6, 0x15, 0x2e, 0xf0, 0x4b, 0x1a, 0xa9, 0x7c, 0xd4, 0x75, 0x9c, 0x6e, 0x9f, 0x25,
  5701. 0xa7, 0xd8, 0xc0, 0xe5, 0xa7, 0x52, 0x68, 0xd4, 0x60, 0xfb, 0x7b, 0xdb, 0xe7, 0x07, 0x6f, 0x38,
  5702. 0x1b, 0xfa, 0xb6, 0x33, 0xa4, 0xec, 0x84, 0x5c, 0x86, 0x35, 0x7f, 0x6c, 0x77, 0xfc, 0x1d, 0x65,
  5703. 0x5f, 0xad, 0xa9, 0x54, 0x2e, 0x8c, 0x27, 0x40, 0x32, 0x27, 0xdd, 0xfe, 0x29, 0xf9, 0x0a, 0x8a,
  5704. 0x7d, 0xdb, 0xe7, 0x78, 0x74, 0xf3, 0xce, 0x27, 0xf5, 0x79, 0x0e, 0xd7, 0x5f, 0xd8, 0x1d, 0xe6,
  5705. 0x24, 0x8a, 0xa8, 0x61, 0x7c, 0x03, 0x97, 0x9e, 0xbb, 0x1d, 0x8b, 0x33, 0x94, 0x1e, 0xb5, 0x1d,
  5706. 0x8f, 0x89, 0xcb, 0x09, 0x14, 0xc5, 0x7d, 0x3b, 0xca, 0xbe, 0x52, 0x53, 0x29, 0x7e, 0xa3, 0x43,
  5707. 0x42, 0xbe, 0x53, 0xd8, 0x57, 0x6a, 0x0a, 0x95, 0x8b, 0xac, 0x01, 0x6e, 0xf1, 0x85, 0x06, 0x84,
  5708. 0x1c, 0x0d, 0xac, 0x51, 0xb9, 0x30, 0x7e, 0x53, 0xe0, 0xe2, 0x33, 0xe1, 0x23, 0x1a, 0xf0, 0x85,
  5709. 0x72, 0x1d, 0x4a, 0xe8, 0x75, 0x33, 0x32, 0x60, 0x5e, 0x9a, 0x06, 0x7a, 0xf9, 0xd8, 0xf1, 0x06,
  5710. 0xf7, 0x8d, 0x48, 0x62, 0xd0, 0x0d, 0xfc, 0x3c, 0xec, 0x90, 0x7b, 0xb0, 0xd9, 0x1e, 0x79, 0xbe,
  5711. 0xe3, 0x35, 0x5d, 0x8f, 0x8d, 0xd1, 0xbc, 0x66, 0x5e, 0x9d, 0x06, 0x3a, 0x91, 0x2a, 0x29, 0xa1,
  5712. 0x41, 0x41, 0xae, 0x9e, 0x7a, 0x6c, 0x9c, 0x52, 0x1c, 0xb2, 0x37, 0x7c, 0x47, 0xcd, 0x51, 0x14,
  5713. 0xc2, 0x58, 0xf1, 0x89, 0x58, 0x1c, 0xc1, 0xff, 0x45, 0x1a, 0x1e, 0x8f, 0xfa, 0xdc, 0xce, 0x38,
  5714. 0xbf, 0x52, 0x2e, 0x66, 0x75, 0xc2, 0x5c, 0xfc, 0x08, 0x1a, 0x6e, 0x1d, 0x72, 0x36, 0x98, 0x0b,
  5715. 0xe0, 0x75, 0xb8, 0x10, 0x7a, 0x34, 0xb6, 0xfa, 0x23, 0x89, 0xa3, 0x46, 0xc3, 0x10, 0x5e, 0x88,
  5716. 0x2d, 0xb2, 0x0b, 0xa5, 0x9e, 0xc3, 0x9b, 0xfc, 0xd4, 0x65, 0x18, 0x8e, 0x4a, 0x37, 0x7a, 0x0e,
  5717. 0x7f, 0x76, 0xea, 0x32, 0xe3, 0x17, 0x05, 0x36, 0xf1, 0xde, 0x07, 0x8c, 0x5b, 0x76, 0x9f, 0x7c,
  5718. 0x0d, 0x10, 0x62, 0x39, 0x3c, 0x76, 0xf0, 0x9e, 0xcd, 0x3b, 0xfa, 0x02, 0x77, 0x0f, 0x87, 0xc7,
  5719. 0x0e, 0xd5, 0x78, 0xf4, 0x49, 0xee, 0x86, 0x81, 0x16, 0x30, 0x50, 0x7d, 0x41, 0xd1, 0x89, 0x80,
  5720. 0x64, 0x8c, 0xe4, 0x26, 0x94, 0x7a, 0x96, 0xdf, 0x1c, 0x88, 0x3a, 0x12, 0xfe, 0x95, 0xcc, 0x0b,
  5721. 0x93, 0x40, 0x8f, 0xf7, 0xe8, 0x46, 0xcf, 0xf2, 0x1f, 0x8b, 0xba, 0x7a, 0x0a, 0x57, 0x04, 0xc2,
  5722. 0x0f, 0x6c, 0xbf, 0xed, 0x8c, 0x99, 0x77, 0x8a, 0x2e, 0x08, 0x7c, 0xef, 0x41, 0xd1, 0xb5, 0xba,
  5723. 0x0c, 0x1d, 0x5e, 0x33, 0xab, 0xd3, 0x40, 0xd7, 0x65, 0xb2, 0xc4, 0xae, 0xb1, 0x3f, 0xb6, 0xfa,
  5724. 0xb6, 0x28, 0xc7, 0xfb, 0x86, 0xc7, 0x4e, 0x46, 0xb6, 0xc7, 0x3a, 0x06, 0x45, 0x05, 0xe3, 0xb5,
  5725. 0xcc, 0x59, 0xd6, 0xa2, 0xe8, 0x9f, 0x2f, 0x67, 0x72, 0x76, 0x7d, 0x01, 0x08, 0x12, 0xbb, 0x30,
  5726. 0x98, 0xdd, 0x54, 0x30, 0x22, 0x17, 0xa5, 0xc4, 0xfd, 0x87, 0xb0, 0x25, 0x2e, 0x43, 0x1d, 0xff,
  5727. 0xbd, 0xdc, 0x76, 0xa0, 0x9c, 0xb6, 0x24, 0xdc, 0x4d, 0x83, 0xa8, 0x2c, 0x00, 0x71, 0xb5, 0x14,
  5728. 0x25, 0xc9, 0x95, 0x65, 0xe8, 0xc1, 0xd6, 0x11, 0xb7, 0xdb, 0xaf, 0x63, 0xc4, 0xcd, 0x73, 0xed,
  5729. 0x78, 0x73, 0x1a, 0xe8, 0xd5, 0x4c, 0x3b, 0xce, 0x0d, 0x21, 0x6e, 0xd1, 0x8f, 0xa1, 0xe0, 0xb8,
  5730. 0x08, 0x92, 0x6a, 0x6e, 0x4d, 0x03, 0x5d, 0x93, 0xda, 0x8e, 0x6b, 0xd0, 0x82, 0xe3, 0x1a, 0xbf,
  5731. 0x2a, 0x40, 0x92, 0x4b, 0xb1, 0x68, 0xfe, 0xab, 0x9b, 0xef, 0x85, 0x8d, 0x24, 0xef, 0x4e, 0x01,
  5732. 0x2f, 0x76, 0x73, 0x80, 0xc7, 0x6e, 0x93, 0x2e, 0xab, 0x79, 0x2e, 0xff, 0xa4, 0xc0, 0x95, 0x23,
  5733. 0xc6, 0x3f, 0x90, 0xd7, 0x37, 0xa2, 0xd7, 0x5f, 0xa4, 0x4e, 0x35, 0xb7, 0xa7, 0x81, 0x7e, 0x21,
  5734. 0x71, 0xdb, 0x37, 0x22, 0x3e, 0x78, 0xab, 0x48, 0xea, 0xf8, 0x76, 0xe0, 0xbf, 0x7f, 0xad, 0x91,
  5735. 0x2a, 0x14, 0x87, 0xd6, 0x20, 0x7c, 0x58, 0xcc, 0xf2, 0x34, 0xd0, 0x37, 0xa5, 0xa2, 0xd8, 0x35,
  5736. 0x28, 0x0a, 0x67, 0x5e, 0x67, 0x75, 0x85, 0xd7, 0xf9, 0x46, 0xf4, 0xec, 0x17, 0xd1, 0x9d, 0x74,
  5737. 0x28, 0x48, 0x00, 0x11, 0x11, 0x78, 0x92, 0xda, 0x52, 0x91, 0x7c, 0xf8, 0x5a, 0x7f, 0x9d, 0xe6,
  5738. 0x1e, 0x7c, 0x77, 0x77, 0xb3, 0xc9, 0x4b, 0x02, 0x21, 0xe9, 0x4a, 0xca, 0x92, 0xa2, 0x9a, 0x22,
  5739. 0xc5, 0x84, 0xe9, 0x8a, 0x69, 0xa6, 0xfb, 0x02, 0xb6, 0xf0, 0x9e, 0xb8, 0xb1, 0xaa, 0xe9, 0x37,
  5740. 0x3e, 0x0d, 0x37, 0x96, 0xa6, 0xbc, 0xc1, 0x78, 0x04, 0xe5, 0xb4, 0xd6, 0xca, 0x74, 0x3f, 0x1b,
  5741. 0x57, 0x18, 0x6f, 0x27, 0x62, 0x6b, 0x94, 0xc6, 0x6c, 0xfd, 0xae, 0x84, 0x9b, 0x74, 0xf3, 0xda,
  5742. 0xbc, 0xd6, 0xf8, 0xb9, 0x00, 0x5a, 0x8c, 0xf4, 0x3b, 0x1b, 0x27, 0xe9, 0x22, 0x0c, 0x6b, 0xae,
  5743. 0x0a, 0xc5, 0x0e, 0xf3, 0xdb, 0x21, 0x43, 0xa7, 0x90, 0x12, 0xbb, 0x06, 0x45, 0x61, 0x92, 0x8b,
  5744. 0x62, 0x3a, 0x17, 0x71, 0xf9, 0xad, 0x2d, 0x2c, 0x3f, 0x2c, 0xb4, 0x88, 0x39, 0xd7, 0xf1, 0xa8,
  5745. 0x2c, 0xb4, 0x70, 0x2f, 0xe6, 0x51, 0x72, 0x1b, 0x34, 0x24, 0x90, 0xe6, 0xc8, 0xeb, 0xef, 0x6c,
  5746. 0xa0, 0x43, 0x97, 0xa7, 0x81, 0xbe, 0x1d, 0x8e, 0x0c, 0x91, 0xc8, 0xa0, 0x25, 0xfc, 0x7e, 0xee,
  5747. 0xf5, 0x8d, 0xdf, 0xc5, 0x8c, 0x63, 0xf3, 0x3e, 0x3b, 0x78, 0xc3, 0x3d, 0x0b, 0xeb, 0xec, 0x2a,
  5748. 0x14, 0x62, 0x3c, 0xd6, 0x27, 0x81, 0x5e, 0xb0, 0x3b, 0xb4, 0x60, 0x77, 0xc8, 0x35, 0x28, 0xa2,
  5749. 0x0b, 0xf2, 0xb9, 0x2a, 0x4d, 0x02, 0x1d, 0xd7, 0x14, 0xff, 0x0b, 0x29, 0x62, 0x23, 0x71, 0x40,
  5750. 0xa9, 0x58, 0x87, 0x28, 0xe9, 0x18, 0xaa, 0xc7, 0x11, 0x00, 0xd5, 0xd4, 0x26, 0x81, 0x2e, 0x37,
  5751. 0xa8, 0xfc, 0x21, 0xbb, 0xa0, 0xb2, 0x61, 0x07, 0x91, 0x50, 0xcd, 0x8d, 0x49, 0xa0, 0x8b, 0x25,
  5752. 0x15, 0xff, 0x88, 0x01, 0xeb, 0x7e, 0xbb, 0xc7, 0x06, 0x32, 0x78, 0xcd, 0x84, 0x49, 0xa0, 0x87,
  5753. 0x3b, 0x34, 0xfc, 0x35, 0x4c, 0xb8, 0x38, 0x3b, 0x44, 0xce, 0x9d, 0x52, 0xae, 0x81, 0xc6, 0xa2,
  5754. 0x03, 0x61, 0x12, 0x93, 0x0d, 0x83, 0x82, 0x96, 0xa8, 0x1f, 0xc0, 0x26, 0x17, 0xb0, 0x34, 0x99,
  5755. 0xc0, 0x65, 0x49, 0x3d, 0xcf, 0xe0, 0x47, 0x81, 0xc7, 0xeb, 0x3b, 0x7f, 0x6a, 0xb0, 0x86, 0xf5,
  5756. 0x46, 0x1e, 0x42, 0x89, 0xb2, 0xae, 0xed, 0x73, 0xe6, 0x91, 0x95, 0xc6, 0xe0, 0xca, 0xd5, 0xba,
  5757. 0x1c, 0xcc, 0xeb, 0xd1, 0x60, 0x5e, 0x3f, 0x10, 0x83, 0x39, 0xb1, 0x24, 0x81, 0x27, 0xbe, 0xde,
  5758. 0x98, 0x6f, 0x2e, 0x3b, 0xb7, 0x57, 0x6a, 0x2b, 0x9d, 0x13, 0x6d, 0xfc, 0x1c, 0xb6, 0xb3, 0xb3,
  5759. 0x37, 0xf9, 0x6c, 0xbe, 0xf6, 0x9c, 0x19, 0x3d, 0xd7, 0xf3, 0x8c, 0x59, 0x2c, 0xee, 0x15, 0xcc,
  5760. 0x86, 0x6f, 0x41, 0xae, 0xd9, 0x57, 0xa9, 0x39, 0x44, 0x4e, 0xae, 0x64, 0xa5, 0xe1, 0xb6, 0xb2,
  5761. 0x7c, 0x9c, 0x22, 0x27, 0x70, 0xe9, 0xfc, 0x68, 0xe6, 0x93, 0xcf, 0xf3, 0xa1, 0x3c, 0x37, 0x17,
  5762. 0x56, 0x6e, 0xad, 0x7e, 0x58, 0x80, 0xff, 0x12, 0x20, 0x19, 0xab, 0x48, 0x35, 0x5f, 0x39, 0xa6,
  5763. 0xd5, 0xca, 0xa7, 0xcb, 0x0f, 0x09, 0xcb, 0x87, 0x00, 0xc9, 0x50, 0x90, 0x67, 0x79, 0x66, 0xc2,
  5764. 0xca, 0xc5, 0xfc, 0x08, 0xca, 0x99, 0xf9, 0x82, 0xd4, 0x96, 0xd9, 0x8b, 0xc6, 0x90, 0x5c, 0xa3,
  5765. 0x3f, 0x00, 0x39, 0x3f, 0xb7, 0xe4, 0x61, 0x3d, 0x77, 0xc2, 0x59, 0xd6, 0x34, 0x31, 0x85, 0x2f,
  5766. 0x6a, 0x9a, 0xf4, 0xc4, 0xb2, 0xa8, 0x69, 0x32, 0xf3, 0xc0, 0x77, 0x50, 0x4e, 0x31, 0xd8, 0x03,
  5767. 0xf1, 0xee, 0x2f, 0xe3, 0xfa, 0x5c, 0x77, 0x1f, 0x45, 0x9d, 0x92, 0xb0, 0xe1, 0xbf, 0x37, 0xf6,
  5768. 0x12, 0x20, 0xe1, 0xe9, 0xbc, 0xb4, 0xcf, 0xf0, 0x7f, 0x5e, 0x41, 0x65, 0xe8, 0xde, 0xbc, 0xf2,
  5769. 0xf6, 0xef, 0xbd, 0xff, 0xbd, 0x3d, 0xdb, 0x53, 0xfe, 0x38, 0xdb, 0x53, 0xfe, 0x3a, 0xdb, 0x53,
  5770. 0x5e, 0xa9, 0x96, 0x6b, 0xb7, 0xd6, 0xd1, 0x81, 0xbb, 0xff, 0x04, 0x00, 0x00, 0xff, 0xff, 0x51,
  5771. 0x5d, 0x7d, 0x73, 0xc4, 0x10, 0x00, 0x00,
  5772. }