volume_server.pb.go 141 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603
  1. // Code generated by protoc-gen-go.
  2. // source: volume_server.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package volume_server_pb is a generated protocol buffer package.
  6. It is generated from these files:
  7. volume_server.proto
  8. It has these top-level messages:
  9. BatchDeleteRequest
  10. BatchDeleteResponse
  11. DeleteResult
  12. Empty
  13. VacuumVolumeCheckRequest
  14. VacuumVolumeCheckResponse
  15. VacuumVolumeCompactRequest
  16. VacuumVolumeCompactResponse
  17. VacuumVolumeCommitRequest
  18. VacuumVolumeCommitResponse
  19. VacuumVolumeCleanupRequest
  20. VacuumVolumeCleanupResponse
  21. DeleteCollectionRequest
  22. DeleteCollectionResponse
  23. AllocateVolumeRequest
  24. AllocateVolumeResponse
  25. VolumeSyncStatusRequest
  26. VolumeSyncStatusResponse
  27. VolumeIncrementalCopyRequest
  28. VolumeIncrementalCopyResponse
  29. VolumeMountRequest
  30. VolumeMountResponse
  31. VolumeUnmountRequest
  32. VolumeUnmountResponse
  33. VolumeDeleteRequest
  34. VolumeDeleteResponse
  35. VolumeMarkReadonlyRequest
  36. VolumeMarkReadonlyResponse
  37. VolumeConfigureRequest
  38. VolumeConfigureResponse
  39. VolumeCopyRequest
  40. VolumeCopyResponse
  41. CopyFileRequest
  42. CopyFileResponse
  43. VolumeTailSenderRequest
  44. VolumeTailSenderResponse
  45. VolumeTailReceiverRequest
  46. VolumeTailReceiverResponse
  47. VolumeEcShardsGenerateRequest
  48. VolumeEcShardsGenerateResponse
  49. VolumeEcShardsRebuildRequest
  50. VolumeEcShardsRebuildResponse
  51. VolumeEcShardsCopyRequest
  52. VolumeEcShardsCopyResponse
  53. VolumeEcShardsDeleteRequest
  54. VolumeEcShardsDeleteResponse
  55. VolumeEcShardsMountRequest
  56. VolumeEcShardsMountResponse
  57. VolumeEcShardsUnmountRequest
  58. VolumeEcShardsUnmountResponse
  59. VolumeEcShardReadRequest
  60. VolumeEcShardReadResponse
  61. VolumeEcBlobDeleteRequest
  62. VolumeEcBlobDeleteResponse
  63. VolumeEcShardsToVolumeRequest
  64. VolumeEcShardsToVolumeResponse
  65. ReadVolumeFileStatusRequest
  66. ReadVolumeFileStatusResponse
  67. DiskStatus
  68. MemStatus
  69. RemoteFile
  70. VolumeInfo
  71. VolumeTierMoveDatToRemoteRequest
  72. VolumeTierMoveDatToRemoteResponse
  73. VolumeTierMoveDatFromRemoteRequest
  74. VolumeTierMoveDatFromRemoteResponse
  75. QueryRequest
  76. QueriedStripe
  77. */
  78. package volume_server_pb
  79. import proto "github.com/golang/protobuf/proto"
  80. import fmt "fmt"
  81. import math "math"
  82. import (
  83. context "golang.org/x/net/context"
  84. grpc "google.golang.org/grpc"
  85. )
  86. // Reference imports to suppress errors if they are not otherwise used.
  87. var _ = proto.Marshal
  88. var _ = fmt.Errorf
  89. var _ = math.Inf
  90. // This is a compile-time assertion to ensure that this generated file
  91. // is compatible with the proto package it is being compiled against.
  92. // A compilation error at this line likely means your copy of the
  93. // proto package needs to be updated.
  94. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  95. type BatchDeleteRequest struct {
  96. FileIds []string `protobuf:"bytes,1,rep,name=file_ids,json=fileIds" json:"file_ids,omitempty"`
  97. }
  98. func (m *BatchDeleteRequest) Reset() { *m = BatchDeleteRequest{} }
  99. func (m *BatchDeleteRequest) String() string { return proto.CompactTextString(m) }
  100. func (*BatchDeleteRequest) ProtoMessage() {}
  101. func (*BatchDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
  102. func (m *BatchDeleteRequest) GetFileIds() []string {
  103. if m != nil {
  104. return m.FileIds
  105. }
  106. return nil
  107. }
  108. type BatchDeleteResponse struct {
  109. Results []*DeleteResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
  110. }
  111. func (m *BatchDeleteResponse) Reset() { *m = BatchDeleteResponse{} }
  112. func (m *BatchDeleteResponse) String() string { return proto.CompactTextString(m) }
  113. func (*BatchDeleteResponse) ProtoMessage() {}
  114. func (*BatchDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
  115. func (m *BatchDeleteResponse) GetResults() []*DeleteResult {
  116. if m != nil {
  117. return m.Results
  118. }
  119. return nil
  120. }
  121. type DeleteResult struct {
  122. FileId string `protobuf:"bytes,1,opt,name=file_id,json=fileId" json:"file_id,omitempty"`
  123. Status int32 `protobuf:"varint,2,opt,name=status" json:"status,omitempty"`
  124. Error string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
  125. Size uint32 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
  126. Version uint32 `protobuf:"varint,5,opt,name=version" json:"version,omitempty"`
  127. }
  128. func (m *DeleteResult) Reset() { *m = DeleteResult{} }
  129. func (m *DeleteResult) String() string { return proto.CompactTextString(m) }
  130. func (*DeleteResult) ProtoMessage() {}
  131. func (*DeleteResult) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
  132. func (m *DeleteResult) GetFileId() string {
  133. if m != nil {
  134. return m.FileId
  135. }
  136. return ""
  137. }
  138. func (m *DeleteResult) GetStatus() int32 {
  139. if m != nil {
  140. return m.Status
  141. }
  142. return 0
  143. }
  144. func (m *DeleteResult) GetError() string {
  145. if m != nil {
  146. return m.Error
  147. }
  148. return ""
  149. }
  150. func (m *DeleteResult) GetSize() uint32 {
  151. if m != nil {
  152. return m.Size
  153. }
  154. return 0
  155. }
  156. func (m *DeleteResult) GetVersion() uint32 {
  157. if m != nil {
  158. return m.Version
  159. }
  160. return 0
  161. }
  162. type Empty struct {
  163. }
  164. func (m *Empty) Reset() { *m = Empty{} }
  165. func (m *Empty) String() string { return proto.CompactTextString(m) }
  166. func (*Empty) ProtoMessage() {}
  167. func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
  168. type VacuumVolumeCheckRequest struct {
  169. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  170. }
  171. func (m *VacuumVolumeCheckRequest) Reset() { *m = VacuumVolumeCheckRequest{} }
  172. func (m *VacuumVolumeCheckRequest) String() string { return proto.CompactTextString(m) }
  173. func (*VacuumVolumeCheckRequest) ProtoMessage() {}
  174. func (*VacuumVolumeCheckRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
  175. func (m *VacuumVolumeCheckRequest) GetVolumeId() uint32 {
  176. if m != nil {
  177. return m.VolumeId
  178. }
  179. return 0
  180. }
  181. type VacuumVolumeCheckResponse struct {
  182. GarbageRatio float64 `protobuf:"fixed64,1,opt,name=garbage_ratio,json=garbageRatio" json:"garbage_ratio,omitempty"`
  183. }
  184. func (m *VacuumVolumeCheckResponse) Reset() { *m = VacuumVolumeCheckResponse{} }
  185. func (m *VacuumVolumeCheckResponse) String() string { return proto.CompactTextString(m) }
  186. func (*VacuumVolumeCheckResponse) ProtoMessage() {}
  187. func (*VacuumVolumeCheckResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
  188. func (m *VacuumVolumeCheckResponse) GetGarbageRatio() float64 {
  189. if m != nil {
  190. return m.GarbageRatio
  191. }
  192. return 0
  193. }
  194. type VacuumVolumeCompactRequest struct {
  195. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  196. Preallocate int64 `protobuf:"varint,2,opt,name=preallocate" json:"preallocate,omitempty"`
  197. }
  198. func (m *VacuumVolumeCompactRequest) Reset() { *m = VacuumVolumeCompactRequest{} }
  199. func (m *VacuumVolumeCompactRequest) String() string { return proto.CompactTextString(m) }
  200. func (*VacuumVolumeCompactRequest) ProtoMessage() {}
  201. func (*VacuumVolumeCompactRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
  202. func (m *VacuumVolumeCompactRequest) GetVolumeId() uint32 {
  203. if m != nil {
  204. return m.VolumeId
  205. }
  206. return 0
  207. }
  208. func (m *VacuumVolumeCompactRequest) GetPreallocate() int64 {
  209. if m != nil {
  210. return m.Preallocate
  211. }
  212. return 0
  213. }
  214. type VacuumVolumeCompactResponse struct {
  215. }
  216. func (m *VacuumVolumeCompactResponse) Reset() { *m = VacuumVolumeCompactResponse{} }
  217. func (m *VacuumVolumeCompactResponse) String() string { return proto.CompactTextString(m) }
  218. func (*VacuumVolumeCompactResponse) ProtoMessage() {}
  219. func (*VacuumVolumeCompactResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
  220. type VacuumVolumeCommitRequest struct {
  221. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  222. }
  223. func (m *VacuumVolumeCommitRequest) Reset() { *m = VacuumVolumeCommitRequest{} }
  224. func (m *VacuumVolumeCommitRequest) String() string { return proto.CompactTextString(m) }
  225. func (*VacuumVolumeCommitRequest) ProtoMessage() {}
  226. func (*VacuumVolumeCommitRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
  227. func (m *VacuumVolumeCommitRequest) GetVolumeId() uint32 {
  228. if m != nil {
  229. return m.VolumeId
  230. }
  231. return 0
  232. }
  233. type VacuumVolumeCommitResponse struct {
  234. }
  235. func (m *VacuumVolumeCommitResponse) Reset() { *m = VacuumVolumeCommitResponse{} }
  236. func (m *VacuumVolumeCommitResponse) String() string { return proto.CompactTextString(m) }
  237. func (*VacuumVolumeCommitResponse) ProtoMessage() {}
  238. func (*VacuumVolumeCommitResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
  239. type VacuumVolumeCleanupRequest struct {
  240. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  241. }
  242. func (m *VacuumVolumeCleanupRequest) Reset() { *m = VacuumVolumeCleanupRequest{} }
  243. func (m *VacuumVolumeCleanupRequest) String() string { return proto.CompactTextString(m) }
  244. func (*VacuumVolumeCleanupRequest) ProtoMessage() {}
  245. func (*VacuumVolumeCleanupRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
  246. func (m *VacuumVolumeCleanupRequest) GetVolumeId() uint32 {
  247. if m != nil {
  248. return m.VolumeId
  249. }
  250. return 0
  251. }
  252. type VacuumVolumeCleanupResponse struct {
  253. }
  254. func (m *VacuumVolumeCleanupResponse) Reset() { *m = VacuumVolumeCleanupResponse{} }
  255. func (m *VacuumVolumeCleanupResponse) String() string { return proto.CompactTextString(m) }
  256. func (*VacuumVolumeCleanupResponse) ProtoMessage() {}
  257. func (*VacuumVolumeCleanupResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
  258. type DeleteCollectionRequest struct {
  259. Collection string `protobuf:"bytes,1,opt,name=collection" json:"collection,omitempty"`
  260. }
  261. func (m *DeleteCollectionRequest) Reset() { *m = DeleteCollectionRequest{} }
  262. func (m *DeleteCollectionRequest) String() string { return proto.CompactTextString(m) }
  263. func (*DeleteCollectionRequest) ProtoMessage() {}
  264. func (*DeleteCollectionRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
  265. func (m *DeleteCollectionRequest) GetCollection() string {
  266. if m != nil {
  267. return m.Collection
  268. }
  269. return ""
  270. }
  271. type DeleteCollectionResponse struct {
  272. }
  273. func (m *DeleteCollectionResponse) Reset() { *m = DeleteCollectionResponse{} }
  274. func (m *DeleteCollectionResponse) String() string { return proto.CompactTextString(m) }
  275. func (*DeleteCollectionResponse) ProtoMessage() {}
  276. func (*DeleteCollectionResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
  277. type AllocateVolumeRequest struct {
  278. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  279. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  280. Preallocate int64 `protobuf:"varint,3,opt,name=preallocate" json:"preallocate,omitempty"`
  281. Replication string `protobuf:"bytes,4,opt,name=replication" json:"replication,omitempty"`
  282. Ttl string `protobuf:"bytes,5,opt,name=ttl" json:"ttl,omitempty"`
  283. MemoryMapMaxSizeMb uint32 `protobuf:"varint,6,opt,name=memory_map_max_size_mb,json=memoryMapMaxSizeMb" json:"memory_map_max_size_mb,omitempty"`
  284. }
  285. func (m *AllocateVolumeRequest) Reset() { *m = AllocateVolumeRequest{} }
  286. func (m *AllocateVolumeRequest) String() string { return proto.CompactTextString(m) }
  287. func (*AllocateVolumeRequest) ProtoMessage() {}
  288. func (*AllocateVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
  289. func (m *AllocateVolumeRequest) GetVolumeId() uint32 {
  290. if m != nil {
  291. return m.VolumeId
  292. }
  293. return 0
  294. }
  295. func (m *AllocateVolumeRequest) GetCollection() string {
  296. if m != nil {
  297. return m.Collection
  298. }
  299. return ""
  300. }
  301. func (m *AllocateVolumeRequest) GetPreallocate() int64 {
  302. if m != nil {
  303. return m.Preallocate
  304. }
  305. return 0
  306. }
  307. func (m *AllocateVolumeRequest) GetReplication() string {
  308. if m != nil {
  309. return m.Replication
  310. }
  311. return ""
  312. }
  313. func (m *AllocateVolumeRequest) GetTtl() string {
  314. if m != nil {
  315. return m.Ttl
  316. }
  317. return ""
  318. }
  319. func (m *AllocateVolumeRequest) GetMemoryMapMaxSizeMb() uint32 {
  320. if m != nil {
  321. return m.MemoryMapMaxSizeMb
  322. }
  323. return 0
  324. }
  325. type AllocateVolumeResponse struct {
  326. }
  327. func (m *AllocateVolumeResponse) Reset() { *m = AllocateVolumeResponse{} }
  328. func (m *AllocateVolumeResponse) String() string { return proto.CompactTextString(m) }
  329. func (*AllocateVolumeResponse) ProtoMessage() {}
  330. func (*AllocateVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
  331. type VolumeSyncStatusRequest struct {
  332. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  333. }
  334. func (m *VolumeSyncStatusRequest) Reset() { *m = VolumeSyncStatusRequest{} }
  335. func (m *VolumeSyncStatusRequest) String() string { return proto.CompactTextString(m) }
  336. func (*VolumeSyncStatusRequest) ProtoMessage() {}
  337. func (*VolumeSyncStatusRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
  338. func (m *VolumeSyncStatusRequest) GetVolumeId() uint32 {
  339. if m != nil {
  340. return m.VolumeId
  341. }
  342. return 0
  343. }
  344. type VolumeSyncStatusResponse struct {
  345. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  346. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  347. Replication string `protobuf:"bytes,4,opt,name=replication" json:"replication,omitempty"`
  348. Ttl string `protobuf:"bytes,5,opt,name=ttl" json:"ttl,omitempty"`
  349. TailOffset uint64 `protobuf:"varint,6,opt,name=tail_offset,json=tailOffset" json:"tail_offset,omitempty"`
  350. CompactRevision uint32 `protobuf:"varint,7,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
  351. IdxFileSize uint64 `protobuf:"varint,8,opt,name=idx_file_size,json=idxFileSize" json:"idx_file_size,omitempty"`
  352. }
  353. func (m *VolumeSyncStatusResponse) Reset() { *m = VolumeSyncStatusResponse{} }
  354. func (m *VolumeSyncStatusResponse) String() string { return proto.CompactTextString(m) }
  355. func (*VolumeSyncStatusResponse) ProtoMessage() {}
  356. func (*VolumeSyncStatusResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} }
  357. func (m *VolumeSyncStatusResponse) GetVolumeId() uint32 {
  358. if m != nil {
  359. return m.VolumeId
  360. }
  361. return 0
  362. }
  363. func (m *VolumeSyncStatusResponse) GetCollection() string {
  364. if m != nil {
  365. return m.Collection
  366. }
  367. return ""
  368. }
  369. func (m *VolumeSyncStatusResponse) GetReplication() string {
  370. if m != nil {
  371. return m.Replication
  372. }
  373. return ""
  374. }
  375. func (m *VolumeSyncStatusResponse) GetTtl() string {
  376. if m != nil {
  377. return m.Ttl
  378. }
  379. return ""
  380. }
  381. func (m *VolumeSyncStatusResponse) GetTailOffset() uint64 {
  382. if m != nil {
  383. return m.TailOffset
  384. }
  385. return 0
  386. }
  387. func (m *VolumeSyncStatusResponse) GetCompactRevision() uint32 {
  388. if m != nil {
  389. return m.CompactRevision
  390. }
  391. return 0
  392. }
  393. func (m *VolumeSyncStatusResponse) GetIdxFileSize() uint64 {
  394. if m != nil {
  395. return m.IdxFileSize
  396. }
  397. return 0
  398. }
  399. type VolumeIncrementalCopyRequest struct {
  400. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  401. SinceNs uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
  402. }
  403. func (m *VolumeIncrementalCopyRequest) Reset() { *m = VolumeIncrementalCopyRequest{} }
  404. func (m *VolumeIncrementalCopyRequest) String() string { return proto.CompactTextString(m) }
  405. func (*VolumeIncrementalCopyRequest) ProtoMessage() {}
  406. func (*VolumeIncrementalCopyRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{18} }
  407. func (m *VolumeIncrementalCopyRequest) GetVolumeId() uint32 {
  408. if m != nil {
  409. return m.VolumeId
  410. }
  411. return 0
  412. }
  413. func (m *VolumeIncrementalCopyRequest) GetSinceNs() uint64 {
  414. if m != nil {
  415. return m.SinceNs
  416. }
  417. return 0
  418. }
  419. type VolumeIncrementalCopyResponse struct {
  420. FileContent []byte `protobuf:"bytes,1,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
  421. }
  422. func (m *VolumeIncrementalCopyResponse) Reset() { *m = VolumeIncrementalCopyResponse{} }
  423. func (m *VolumeIncrementalCopyResponse) String() string { return proto.CompactTextString(m) }
  424. func (*VolumeIncrementalCopyResponse) ProtoMessage() {}
  425. func (*VolumeIncrementalCopyResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{19} }
  426. func (m *VolumeIncrementalCopyResponse) GetFileContent() []byte {
  427. if m != nil {
  428. return m.FileContent
  429. }
  430. return nil
  431. }
  432. type VolumeMountRequest struct {
  433. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  434. }
  435. func (m *VolumeMountRequest) Reset() { *m = VolumeMountRequest{} }
  436. func (m *VolumeMountRequest) String() string { return proto.CompactTextString(m) }
  437. func (*VolumeMountRequest) ProtoMessage() {}
  438. func (*VolumeMountRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{20} }
  439. func (m *VolumeMountRequest) GetVolumeId() uint32 {
  440. if m != nil {
  441. return m.VolumeId
  442. }
  443. return 0
  444. }
  445. type VolumeMountResponse struct {
  446. }
  447. func (m *VolumeMountResponse) Reset() { *m = VolumeMountResponse{} }
  448. func (m *VolumeMountResponse) String() string { return proto.CompactTextString(m) }
  449. func (*VolumeMountResponse) ProtoMessage() {}
  450. func (*VolumeMountResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{21} }
  451. type VolumeUnmountRequest struct {
  452. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  453. }
  454. func (m *VolumeUnmountRequest) Reset() { *m = VolumeUnmountRequest{} }
  455. func (m *VolumeUnmountRequest) String() string { return proto.CompactTextString(m) }
  456. func (*VolumeUnmountRequest) ProtoMessage() {}
  457. func (*VolumeUnmountRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{22} }
  458. func (m *VolumeUnmountRequest) GetVolumeId() uint32 {
  459. if m != nil {
  460. return m.VolumeId
  461. }
  462. return 0
  463. }
  464. type VolumeUnmountResponse struct {
  465. }
  466. func (m *VolumeUnmountResponse) Reset() { *m = VolumeUnmountResponse{} }
  467. func (m *VolumeUnmountResponse) String() string { return proto.CompactTextString(m) }
  468. func (*VolumeUnmountResponse) ProtoMessage() {}
  469. func (*VolumeUnmountResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{23} }
  470. type VolumeDeleteRequest struct {
  471. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  472. }
  473. func (m *VolumeDeleteRequest) Reset() { *m = VolumeDeleteRequest{} }
  474. func (m *VolumeDeleteRequest) String() string { return proto.CompactTextString(m) }
  475. func (*VolumeDeleteRequest) ProtoMessage() {}
  476. func (*VolumeDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{24} }
  477. func (m *VolumeDeleteRequest) GetVolumeId() uint32 {
  478. if m != nil {
  479. return m.VolumeId
  480. }
  481. return 0
  482. }
  483. type VolumeDeleteResponse struct {
  484. }
  485. func (m *VolumeDeleteResponse) Reset() { *m = VolumeDeleteResponse{} }
  486. func (m *VolumeDeleteResponse) String() string { return proto.CompactTextString(m) }
  487. func (*VolumeDeleteResponse) ProtoMessage() {}
  488. func (*VolumeDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{25} }
  489. type VolumeMarkReadonlyRequest struct {
  490. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  491. }
  492. func (m *VolumeMarkReadonlyRequest) Reset() { *m = VolumeMarkReadonlyRequest{} }
  493. func (m *VolumeMarkReadonlyRequest) String() string { return proto.CompactTextString(m) }
  494. func (*VolumeMarkReadonlyRequest) ProtoMessage() {}
  495. func (*VolumeMarkReadonlyRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{26} }
  496. func (m *VolumeMarkReadonlyRequest) GetVolumeId() uint32 {
  497. if m != nil {
  498. return m.VolumeId
  499. }
  500. return 0
  501. }
  502. type VolumeMarkReadonlyResponse struct {
  503. }
  504. func (m *VolumeMarkReadonlyResponse) Reset() { *m = VolumeMarkReadonlyResponse{} }
  505. func (m *VolumeMarkReadonlyResponse) String() string { return proto.CompactTextString(m) }
  506. func (*VolumeMarkReadonlyResponse) ProtoMessage() {}
  507. func (*VolumeMarkReadonlyResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{27} }
  508. type VolumeConfigureRequest struct {
  509. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  510. Replication string `protobuf:"bytes,2,opt,name=replication" json:"replication,omitempty"`
  511. }
  512. func (m *VolumeConfigureRequest) Reset() { *m = VolumeConfigureRequest{} }
  513. func (m *VolumeConfigureRequest) String() string { return proto.CompactTextString(m) }
  514. func (*VolumeConfigureRequest) ProtoMessage() {}
  515. func (*VolumeConfigureRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{28} }
  516. func (m *VolumeConfigureRequest) GetVolumeId() uint32 {
  517. if m != nil {
  518. return m.VolumeId
  519. }
  520. return 0
  521. }
  522. func (m *VolumeConfigureRequest) GetReplication() string {
  523. if m != nil {
  524. return m.Replication
  525. }
  526. return ""
  527. }
  528. type VolumeConfigureResponse struct {
  529. Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
  530. }
  531. func (m *VolumeConfigureResponse) Reset() { *m = VolumeConfigureResponse{} }
  532. func (m *VolumeConfigureResponse) String() string { return proto.CompactTextString(m) }
  533. func (*VolumeConfigureResponse) ProtoMessage() {}
  534. func (*VolumeConfigureResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{29} }
  535. func (m *VolumeConfigureResponse) GetError() string {
  536. if m != nil {
  537. return m.Error
  538. }
  539. return ""
  540. }
  541. type VolumeCopyRequest struct {
  542. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  543. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  544. Replication string `protobuf:"bytes,3,opt,name=replication" json:"replication,omitempty"`
  545. Ttl string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
  546. SourceDataNode string `protobuf:"bytes,5,opt,name=source_data_node,json=sourceDataNode" json:"source_data_node,omitempty"`
  547. }
  548. func (m *VolumeCopyRequest) Reset() { *m = VolumeCopyRequest{} }
  549. func (m *VolumeCopyRequest) String() string { return proto.CompactTextString(m) }
  550. func (*VolumeCopyRequest) ProtoMessage() {}
  551. func (*VolumeCopyRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{30} }
  552. func (m *VolumeCopyRequest) GetVolumeId() uint32 {
  553. if m != nil {
  554. return m.VolumeId
  555. }
  556. return 0
  557. }
  558. func (m *VolumeCopyRequest) GetCollection() string {
  559. if m != nil {
  560. return m.Collection
  561. }
  562. return ""
  563. }
  564. func (m *VolumeCopyRequest) GetReplication() string {
  565. if m != nil {
  566. return m.Replication
  567. }
  568. return ""
  569. }
  570. func (m *VolumeCopyRequest) GetTtl() string {
  571. if m != nil {
  572. return m.Ttl
  573. }
  574. return ""
  575. }
  576. func (m *VolumeCopyRequest) GetSourceDataNode() string {
  577. if m != nil {
  578. return m.SourceDataNode
  579. }
  580. return ""
  581. }
  582. type VolumeCopyResponse struct {
  583. LastAppendAtNs uint64 `protobuf:"varint,1,opt,name=last_append_at_ns,json=lastAppendAtNs" json:"last_append_at_ns,omitempty"`
  584. }
  585. func (m *VolumeCopyResponse) Reset() { *m = VolumeCopyResponse{} }
  586. func (m *VolumeCopyResponse) String() string { return proto.CompactTextString(m) }
  587. func (*VolumeCopyResponse) ProtoMessage() {}
  588. func (*VolumeCopyResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{31} }
  589. func (m *VolumeCopyResponse) GetLastAppendAtNs() uint64 {
  590. if m != nil {
  591. return m.LastAppendAtNs
  592. }
  593. return 0
  594. }
  595. type CopyFileRequest struct {
  596. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  597. Ext string `protobuf:"bytes,2,opt,name=ext" json:"ext,omitempty"`
  598. CompactionRevision uint32 `protobuf:"varint,3,opt,name=compaction_revision,json=compactionRevision" json:"compaction_revision,omitempty"`
  599. StopOffset uint64 `protobuf:"varint,4,opt,name=stop_offset,json=stopOffset" json:"stop_offset,omitempty"`
  600. Collection string `protobuf:"bytes,5,opt,name=collection" json:"collection,omitempty"`
  601. IsEcVolume bool `protobuf:"varint,6,opt,name=is_ec_volume,json=isEcVolume" json:"is_ec_volume,omitempty"`
  602. IgnoreSourceFileNotFound bool `protobuf:"varint,7,opt,name=ignore_source_file_not_found,json=ignoreSourceFileNotFound" json:"ignore_source_file_not_found,omitempty"`
  603. }
  604. func (m *CopyFileRequest) Reset() { *m = CopyFileRequest{} }
  605. func (m *CopyFileRequest) String() string { return proto.CompactTextString(m) }
  606. func (*CopyFileRequest) ProtoMessage() {}
  607. func (*CopyFileRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{32} }
  608. func (m *CopyFileRequest) GetVolumeId() uint32 {
  609. if m != nil {
  610. return m.VolumeId
  611. }
  612. return 0
  613. }
  614. func (m *CopyFileRequest) GetExt() string {
  615. if m != nil {
  616. return m.Ext
  617. }
  618. return ""
  619. }
  620. func (m *CopyFileRequest) GetCompactionRevision() uint32 {
  621. if m != nil {
  622. return m.CompactionRevision
  623. }
  624. return 0
  625. }
  626. func (m *CopyFileRequest) GetStopOffset() uint64 {
  627. if m != nil {
  628. return m.StopOffset
  629. }
  630. return 0
  631. }
  632. func (m *CopyFileRequest) GetCollection() string {
  633. if m != nil {
  634. return m.Collection
  635. }
  636. return ""
  637. }
  638. func (m *CopyFileRequest) GetIsEcVolume() bool {
  639. if m != nil {
  640. return m.IsEcVolume
  641. }
  642. return false
  643. }
  644. func (m *CopyFileRequest) GetIgnoreSourceFileNotFound() bool {
  645. if m != nil {
  646. return m.IgnoreSourceFileNotFound
  647. }
  648. return false
  649. }
  650. type CopyFileResponse struct {
  651. FileContent []byte `protobuf:"bytes,1,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
  652. }
  653. func (m *CopyFileResponse) Reset() { *m = CopyFileResponse{} }
  654. func (m *CopyFileResponse) String() string { return proto.CompactTextString(m) }
  655. func (*CopyFileResponse) ProtoMessage() {}
  656. func (*CopyFileResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{33} }
  657. func (m *CopyFileResponse) GetFileContent() []byte {
  658. if m != nil {
  659. return m.FileContent
  660. }
  661. return nil
  662. }
  663. type VolumeTailSenderRequest struct {
  664. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  665. SinceNs uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
  666. IdleTimeoutSeconds uint32 `protobuf:"varint,3,opt,name=idle_timeout_seconds,json=idleTimeoutSeconds" json:"idle_timeout_seconds,omitempty"`
  667. }
  668. func (m *VolumeTailSenderRequest) Reset() { *m = VolumeTailSenderRequest{} }
  669. func (m *VolumeTailSenderRequest) String() string { return proto.CompactTextString(m) }
  670. func (*VolumeTailSenderRequest) ProtoMessage() {}
  671. func (*VolumeTailSenderRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{34} }
  672. func (m *VolumeTailSenderRequest) GetVolumeId() uint32 {
  673. if m != nil {
  674. return m.VolumeId
  675. }
  676. return 0
  677. }
  678. func (m *VolumeTailSenderRequest) GetSinceNs() uint64 {
  679. if m != nil {
  680. return m.SinceNs
  681. }
  682. return 0
  683. }
  684. func (m *VolumeTailSenderRequest) GetIdleTimeoutSeconds() uint32 {
  685. if m != nil {
  686. return m.IdleTimeoutSeconds
  687. }
  688. return 0
  689. }
  690. type VolumeTailSenderResponse struct {
  691. NeedleHeader []byte `protobuf:"bytes,1,opt,name=needle_header,json=needleHeader,proto3" json:"needle_header,omitempty"`
  692. NeedleBody []byte `protobuf:"bytes,2,opt,name=needle_body,json=needleBody,proto3" json:"needle_body,omitempty"`
  693. IsLastChunk bool `protobuf:"varint,3,opt,name=is_last_chunk,json=isLastChunk" json:"is_last_chunk,omitempty"`
  694. }
  695. func (m *VolumeTailSenderResponse) Reset() { *m = VolumeTailSenderResponse{} }
  696. func (m *VolumeTailSenderResponse) String() string { return proto.CompactTextString(m) }
  697. func (*VolumeTailSenderResponse) ProtoMessage() {}
  698. func (*VolumeTailSenderResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{35} }
  699. func (m *VolumeTailSenderResponse) GetNeedleHeader() []byte {
  700. if m != nil {
  701. return m.NeedleHeader
  702. }
  703. return nil
  704. }
  705. func (m *VolumeTailSenderResponse) GetNeedleBody() []byte {
  706. if m != nil {
  707. return m.NeedleBody
  708. }
  709. return nil
  710. }
  711. func (m *VolumeTailSenderResponse) GetIsLastChunk() bool {
  712. if m != nil {
  713. return m.IsLastChunk
  714. }
  715. return false
  716. }
  717. type VolumeTailReceiverRequest struct {
  718. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  719. SinceNs uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
  720. IdleTimeoutSeconds uint32 `protobuf:"varint,3,opt,name=idle_timeout_seconds,json=idleTimeoutSeconds" json:"idle_timeout_seconds,omitempty"`
  721. SourceVolumeServer string `protobuf:"bytes,4,opt,name=source_volume_server,json=sourceVolumeServer" json:"source_volume_server,omitempty"`
  722. }
  723. func (m *VolumeTailReceiverRequest) Reset() { *m = VolumeTailReceiverRequest{} }
  724. func (m *VolumeTailReceiverRequest) String() string { return proto.CompactTextString(m) }
  725. func (*VolumeTailReceiverRequest) ProtoMessage() {}
  726. func (*VolumeTailReceiverRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{36} }
  727. func (m *VolumeTailReceiverRequest) GetVolumeId() uint32 {
  728. if m != nil {
  729. return m.VolumeId
  730. }
  731. return 0
  732. }
  733. func (m *VolumeTailReceiverRequest) GetSinceNs() uint64 {
  734. if m != nil {
  735. return m.SinceNs
  736. }
  737. return 0
  738. }
  739. func (m *VolumeTailReceiverRequest) GetIdleTimeoutSeconds() uint32 {
  740. if m != nil {
  741. return m.IdleTimeoutSeconds
  742. }
  743. return 0
  744. }
  745. func (m *VolumeTailReceiverRequest) GetSourceVolumeServer() string {
  746. if m != nil {
  747. return m.SourceVolumeServer
  748. }
  749. return ""
  750. }
  751. type VolumeTailReceiverResponse struct {
  752. }
  753. func (m *VolumeTailReceiverResponse) Reset() { *m = VolumeTailReceiverResponse{} }
  754. func (m *VolumeTailReceiverResponse) String() string { return proto.CompactTextString(m) }
  755. func (*VolumeTailReceiverResponse) ProtoMessage() {}
  756. func (*VolumeTailReceiverResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{37} }
  757. type VolumeEcShardsGenerateRequest struct {
  758. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  759. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  760. }
  761. func (m *VolumeEcShardsGenerateRequest) Reset() { *m = VolumeEcShardsGenerateRequest{} }
  762. func (m *VolumeEcShardsGenerateRequest) String() string { return proto.CompactTextString(m) }
  763. func (*VolumeEcShardsGenerateRequest) ProtoMessage() {}
  764. func (*VolumeEcShardsGenerateRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{38} }
  765. func (m *VolumeEcShardsGenerateRequest) GetVolumeId() uint32 {
  766. if m != nil {
  767. return m.VolumeId
  768. }
  769. return 0
  770. }
  771. func (m *VolumeEcShardsGenerateRequest) GetCollection() string {
  772. if m != nil {
  773. return m.Collection
  774. }
  775. return ""
  776. }
  777. type VolumeEcShardsGenerateResponse struct {
  778. }
  779. func (m *VolumeEcShardsGenerateResponse) Reset() { *m = VolumeEcShardsGenerateResponse{} }
  780. func (m *VolumeEcShardsGenerateResponse) String() string { return proto.CompactTextString(m) }
  781. func (*VolumeEcShardsGenerateResponse) ProtoMessage() {}
  782. func (*VolumeEcShardsGenerateResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{39} }
  783. type VolumeEcShardsRebuildRequest struct {
  784. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  785. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  786. }
  787. func (m *VolumeEcShardsRebuildRequest) Reset() { *m = VolumeEcShardsRebuildRequest{} }
  788. func (m *VolumeEcShardsRebuildRequest) String() string { return proto.CompactTextString(m) }
  789. func (*VolumeEcShardsRebuildRequest) ProtoMessage() {}
  790. func (*VolumeEcShardsRebuildRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{40} }
  791. func (m *VolumeEcShardsRebuildRequest) GetVolumeId() uint32 {
  792. if m != nil {
  793. return m.VolumeId
  794. }
  795. return 0
  796. }
  797. func (m *VolumeEcShardsRebuildRequest) GetCollection() string {
  798. if m != nil {
  799. return m.Collection
  800. }
  801. return ""
  802. }
  803. type VolumeEcShardsRebuildResponse struct {
  804. RebuiltShardIds []uint32 `protobuf:"varint,1,rep,packed,name=rebuilt_shard_ids,json=rebuiltShardIds" json:"rebuilt_shard_ids,omitempty"`
  805. }
  806. func (m *VolumeEcShardsRebuildResponse) Reset() { *m = VolumeEcShardsRebuildResponse{} }
  807. func (m *VolumeEcShardsRebuildResponse) String() string { return proto.CompactTextString(m) }
  808. func (*VolumeEcShardsRebuildResponse) ProtoMessage() {}
  809. func (*VolumeEcShardsRebuildResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{41} }
  810. func (m *VolumeEcShardsRebuildResponse) GetRebuiltShardIds() []uint32 {
  811. if m != nil {
  812. return m.RebuiltShardIds
  813. }
  814. return nil
  815. }
  816. type VolumeEcShardsCopyRequest struct {
  817. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  818. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  819. ShardIds []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
  820. CopyEcxFile bool `protobuf:"varint,4,opt,name=copy_ecx_file,json=copyEcxFile" json:"copy_ecx_file,omitempty"`
  821. SourceDataNode string `protobuf:"bytes,5,opt,name=source_data_node,json=sourceDataNode" json:"source_data_node,omitempty"`
  822. CopyEcjFile bool `protobuf:"varint,6,opt,name=copy_ecj_file,json=copyEcjFile" json:"copy_ecj_file,omitempty"`
  823. CopyVifFile bool `protobuf:"varint,7,opt,name=copy_vif_file,json=copyVifFile" json:"copy_vif_file,omitempty"`
  824. }
  825. func (m *VolumeEcShardsCopyRequest) Reset() { *m = VolumeEcShardsCopyRequest{} }
  826. func (m *VolumeEcShardsCopyRequest) String() string { return proto.CompactTextString(m) }
  827. func (*VolumeEcShardsCopyRequest) ProtoMessage() {}
  828. func (*VolumeEcShardsCopyRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{42} }
  829. func (m *VolumeEcShardsCopyRequest) GetVolumeId() uint32 {
  830. if m != nil {
  831. return m.VolumeId
  832. }
  833. return 0
  834. }
  835. func (m *VolumeEcShardsCopyRequest) GetCollection() string {
  836. if m != nil {
  837. return m.Collection
  838. }
  839. return ""
  840. }
  841. func (m *VolumeEcShardsCopyRequest) GetShardIds() []uint32 {
  842. if m != nil {
  843. return m.ShardIds
  844. }
  845. return nil
  846. }
  847. func (m *VolumeEcShardsCopyRequest) GetCopyEcxFile() bool {
  848. if m != nil {
  849. return m.CopyEcxFile
  850. }
  851. return false
  852. }
  853. func (m *VolumeEcShardsCopyRequest) GetSourceDataNode() string {
  854. if m != nil {
  855. return m.SourceDataNode
  856. }
  857. return ""
  858. }
  859. func (m *VolumeEcShardsCopyRequest) GetCopyEcjFile() bool {
  860. if m != nil {
  861. return m.CopyEcjFile
  862. }
  863. return false
  864. }
  865. func (m *VolumeEcShardsCopyRequest) GetCopyVifFile() bool {
  866. if m != nil {
  867. return m.CopyVifFile
  868. }
  869. return false
  870. }
  871. type VolumeEcShardsCopyResponse struct {
  872. }
  873. func (m *VolumeEcShardsCopyResponse) Reset() { *m = VolumeEcShardsCopyResponse{} }
  874. func (m *VolumeEcShardsCopyResponse) String() string { return proto.CompactTextString(m) }
  875. func (*VolumeEcShardsCopyResponse) ProtoMessage() {}
  876. func (*VolumeEcShardsCopyResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{43} }
  877. type VolumeEcShardsDeleteRequest struct {
  878. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  879. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  880. ShardIds []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
  881. }
  882. func (m *VolumeEcShardsDeleteRequest) Reset() { *m = VolumeEcShardsDeleteRequest{} }
  883. func (m *VolumeEcShardsDeleteRequest) String() string { return proto.CompactTextString(m) }
  884. func (*VolumeEcShardsDeleteRequest) ProtoMessage() {}
  885. func (*VolumeEcShardsDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{44} }
  886. func (m *VolumeEcShardsDeleteRequest) GetVolumeId() uint32 {
  887. if m != nil {
  888. return m.VolumeId
  889. }
  890. return 0
  891. }
  892. func (m *VolumeEcShardsDeleteRequest) GetCollection() string {
  893. if m != nil {
  894. return m.Collection
  895. }
  896. return ""
  897. }
  898. func (m *VolumeEcShardsDeleteRequest) GetShardIds() []uint32 {
  899. if m != nil {
  900. return m.ShardIds
  901. }
  902. return nil
  903. }
  904. type VolumeEcShardsDeleteResponse struct {
  905. }
  906. func (m *VolumeEcShardsDeleteResponse) Reset() { *m = VolumeEcShardsDeleteResponse{} }
  907. func (m *VolumeEcShardsDeleteResponse) String() string { return proto.CompactTextString(m) }
  908. func (*VolumeEcShardsDeleteResponse) ProtoMessage() {}
  909. func (*VolumeEcShardsDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{45} }
  910. type VolumeEcShardsMountRequest struct {
  911. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  912. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  913. ShardIds []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
  914. }
  915. func (m *VolumeEcShardsMountRequest) Reset() { *m = VolumeEcShardsMountRequest{} }
  916. func (m *VolumeEcShardsMountRequest) String() string { return proto.CompactTextString(m) }
  917. func (*VolumeEcShardsMountRequest) ProtoMessage() {}
  918. func (*VolumeEcShardsMountRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{46} }
  919. func (m *VolumeEcShardsMountRequest) GetVolumeId() uint32 {
  920. if m != nil {
  921. return m.VolumeId
  922. }
  923. return 0
  924. }
  925. func (m *VolumeEcShardsMountRequest) GetCollection() string {
  926. if m != nil {
  927. return m.Collection
  928. }
  929. return ""
  930. }
  931. func (m *VolumeEcShardsMountRequest) GetShardIds() []uint32 {
  932. if m != nil {
  933. return m.ShardIds
  934. }
  935. return nil
  936. }
  937. type VolumeEcShardsMountResponse struct {
  938. }
  939. func (m *VolumeEcShardsMountResponse) Reset() { *m = VolumeEcShardsMountResponse{} }
  940. func (m *VolumeEcShardsMountResponse) String() string { return proto.CompactTextString(m) }
  941. func (*VolumeEcShardsMountResponse) ProtoMessage() {}
  942. func (*VolumeEcShardsMountResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{47} }
  943. type VolumeEcShardsUnmountRequest struct {
  944. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  945. ShardIds []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
  946. }
  947. func (m *VolumeEcShardsUnmountRequest) Reset() { *m = VolumeEcShardsUnmountRequest{} }
  948. func (m *VolumeEcShardsUnmountRequest) String() string { return proto.CompactTextString(m) }
  949. func (*VolumeEcShardsUnmountRequest) ProtoMessage() {}
  950. func (*VolumeEcShardsUnmountRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{48} }
  951. func (m *VolumeEcShardsUnmountRequest) GetVolumeId() uint32 {
  952. if m != nil {
  953. return m.VolumeId
  954. }
  955. return 0
  956. }
  957. func (m *VolumeEcShardsUnmountRequest) GetShardIds() []uint32 {
  958. if m != nil {
  959. return m.ShardIds
  960. }
  961. return nil
  962. }
  963. type VolumeEcShardsUnmountResponse struct {
  964. }
  965. func (m *VolumeEcShardsUnmountResponse) Reset() { *m = VolumeEcShardsUnmountResponse{} }
  966. func (m *VolumeEcShardsUnmountResponse) String() string { return proto.CompactTextString(m) }
  967. func (*VolumeEcShardsUnmountResponse) ProtoMessage() {}
  968. func (*VolumeEcShardsUnmountResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{49} }
  969. type VolumeEcShardReadRequest struct {
  970. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  971. ShardId uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
  972. Offset int64 `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
  973. Size int64 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
  974. FileKey uint64 `protobuf:"varint,5,opt,name=file_key,json=fileKey" json:"file_key,omitempty"`
  975. }
  976. func (m *VolumeEcShardReadRequest) Reset() { *m = VolumeEcShardReadRequest{} }
  977. func (m *VolumeEcShardReadRequest) String() string { return proto.CompactTextString(m) }
  978. func (*VolumeEcShardReadRequest) ProtoMessage() {}
  979. func (*VolumeEcShardReadRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{50} }
  980. func (m *VolumeEcShardReadRequest) GetVolumeId() uint32 {
  981. if m != nil {
  982. return m.VolumeId
  983. }
  984. return 0
  985. }
  986. func (m *VolumeEcShardReadRequest) GetShardId() uint32 {
  987. if m != nil {
  988. return m.ShardId
  989. }
  990. return 0
  991. }
  992. func (m *VolumeEcShardReadRequest) GetOffset() int64 {
  993. if m != nil {
  994. return m.Offset
  995. }
  996. return 0
  997. }
  998. func (m *VolumeEcShardReadRequest) GetSize() int64 {
  999. if m != nil {
  1000. return m.Size
  1001. }
  1002. return 0
  1003. }
  1004. func (m *VolumeEcShardReadRequest) GetFileKey() uint64 {
  1005. if m != nil {
  1006. return m.FileKey
  1007. }
  1008. return 0
  1009. }
  1010. type VolumeEcShardReadResponse struct {
  1011. Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
  1012. IsDeleted bool `protobuf:"varint,2,opt,name=is_deleted,json=isDeleted" json:"is_deleted,omitempty"`
  1013. }
  1014. func (m *VolumeEcShardReadResponse) Reset() { *m = VolumeEcShardReadResponse{} }
  1015. func (m *VolumeEcShardReadResponse) String() string { return proto.CompactTextString(m) }
  1016. func (*VolumeEcShardReadResponse) ProtoMessage() {}
  1017. func (*VolumeEcShardReadResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{51} }
  1018. func (m *VolumeEcShardReadResponse) GetData() []byte {
  1019. if m != nil {
  1020. return m.Data
  1021. }
  1022. return nil
  1023. }
  1024. func (m *VolumeEcShardReadResponse) GetIsDeleted() bool {
  1025. if m != nil {
  1026. return m.IsDeleted
  1027. }
  1028. return false
  1029. }
  1030. type VolumeEcBlobDeleteRequest struct {
  1031. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1032. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  1033. FileKey uint64 `protobuf:"varint,3,opt,name=file_key,json=fileKey" json:"file_key,omitempty"`
  1034. Version uint32 `protobuf:"varint,4,opt,name=version" json:"version,omitempty"`
  1035. }
  1036. func (m *VolumeEcBlobDeleteRequest) Reset() { *m = VolumeEcBlobDeleteRequest{} }
  1037. func (m *VolumeEcBlobDeleteRequest) String() string { return proto.CompactTextString(m) }
  1038. func (*VolumeEcBlobDeleteRequest) ProtoMessage() {}
  1039. func (*VolumeEcBlobDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{52} }
  1040. func (m *VolumeEcBlobDeleteRequest) GetVolumeId() uint32 {
  1041. if m != nil {
  1042. return m.VolumeId
  1043. }
  1044. return 0
  1045. }
  1046. func (m *VolumeEcBlobDeleteRequest) GetCollection() string {
  1047. if m != nil {
  1048. return m.Collection
  1049. }
  1050. return ""
  1051. }
  1052. func (m *VolumeEcBlobDeleteRequest) GetFileKey() uint64 {
  1053. if m != nil {
  1054. return m.FileKey
  1055. }
  1056. return 0
  1057. }
  1058. func (m *VolumeEcBlobDeleteRequest) GetVersion() uint32 {
  1059. if m != nil {
  1060. return m.Version
  1061. }
  1062. return 0
  1063. }
  1064. type VolumeEcBlobDeleteResponse struct {
  1065. }
  1066. func (m *VolumeEcBlobDeleteResponse) Reset() { *m = VolumeEcBlobDeleteResponse{} }
  1067. func (m *VolumeEcBlobDeleteResponse) String() string { return proto.CompactTextString(m) }
  1068. func (*VolumeEcBlobDeleteResponse) ProtoMessage() {}
  1069. func (*VolumeEcBlobDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{53} }
  1070. type VolumeEcShardsToVolumeRequest struct {
  1071. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1072. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  1073. }
  1074. func (m *VolumeEcShardsToVolumeRequest) Reset() { *m = VolumeEcShardsToVolumeRequest{} }
  1075. func (m *VolumeEcShardsToVolumeRequest) String() string { return proto.CompactTextString(m) }
  1076. func (*VolumeEcShardsToVolumeRequest) ProtoMessage() {}
  1077. func (*VolumeEcShardsToVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{54} }
  1078. func (m *VolumeEcShardsToVolumeRequest) GetVolumeId() uint32 {
  1079. if m != nil {
  1080. return m.VolumeId
  1081. }
  1082. return 0
  1083. }
  1084. func (m *VolumeEcShardsToVolumeRequest) GetCollection() string {
  1085. if m != nil {
  1086. return m.Collection
  1087. }
  1088. return ""
  1089. }
  1090. type VolumeEcShardsToVolumeResponse struct {
  1091. }
  1092. func (m *VolumeEcShardsToVolumeResponse) Reset() { *m = VolumeEcShardsToVolumeResponse{} }
  1093. func (m *VolumeEcShardsToVolumeResponse) String() string { return proto.CompactTextString(m) }
  1094. func (*VolumeEcShardsToVolumeResponse) ProtoMessage() {}
  1095. func (*VolumeEcShardsToVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{55} }
  1096. type ReadVolumeFileStatusRequest struct {
  1097. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1098. }
  1099. func (m *ReadVolumeFileStatusRequest) Reset() { *m = ReadVolumeFileStatusRequest{} }
  1100. func (m *ReadVolumeFileStatusRequest) String() string { return proto.CompactTextString(m) }
  1101. func (*ReadVolumeFileStatusRequest) ProtoMessage() {}
  1102. func (*ReadVolumeFileStatusRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{56} }
  1103. func (m *ReadVolumeFileStatusRequest) GetVolumeId() uint32 {
  1104. if m != nil {
  1105. return m.VolumeId
  1106. }
  1107. return 0
  1108. }
  1109. type ReadVolumeFileStatusResponse struct {
  1110. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1111. IdxFileTimestampSeconds uint64 `protobuf:"varint,2,opt,name=idx_file_timestamp_seconds,json=idxFileTimestampSeconds" json:"idx_file_timestamp_seconds,omitempty"`
  1112. IdxFileSize uint64 `protobuf:"varint,3,opt,name=idx_file_size,json=idxFileSize" json:"idx_file_size,omitempty"`
  1113. DatFileTimestampSeconds uint64 `protobuf:"varint,4,opt,name=dat_file_timestamp_seconds,json=datFileTimestampSeconds" json:"dat_file_timestamp_seconds,omitempty"`
  1114. DatFileSize uint64 `protobuf:"varint,5,opt,name=dat_file_size,json=datFileSize" json:"dat_file_size,omitempty"`
  1115. FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  1116. CompactionRevision uint32 `protobuf:"varint,7,opt,name=compaction_revision,json=compactionRevision" json:"compaction_revision,omitempty"`
  1117. Collection string `protobuf:"bytes,8,opt,name=collection" json:"collection,omitempty"`
  1118. }
  1119. func (m *ReadVolumeFileStatusResponse) Reset() { *m = ReadVolumeFileStatusResponse{} }
  1120. func (m *ReadVolumeFileStatusResponse) String() string { return proto.CompactTextString(m) }
  1121. func (*ReadVolumeFileStatusResponse) ProtoMessage() {}
  1122. func (*ReadVolumeFileStatusResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{57} }
  1123. func (m *ReadVolumeFileStatusResponse) GetVolumeId() uint32 {
  1124. if m != nil {
  1125. return m.VolumeId
  1126. }
  1127. return 0
  1128. }
  1129. func (m *ReadVolumeFileStatusResponse) GetIdxFileTimestampSeconds() uint64 {
  1130. if m != nil {
  1131. return m.IdxFileTimestampSeconds
  1132. }
  1133. return 0
  1134. }
  1135. func (m *ReadVolumeFileStatusResponse) GetIdxFileSize() uint64 {
  1136. if m != nil {
  1137. return m.IdxFileSize
  1138. }
  1139. return 0
  1140. }
  1141. func (m *ReadVolumeFileStatusResponse) GetDatFileTimestampSeconds() uint64 {
  1142. if m != nil {
  1143. return m.DatFileTimestampSeconds
  1144. }
  1145. return 0
  1146. }
  1147. func (m *ReadVolumeFileStatusResponse) GetDatFileSize() uint64 {
  1148. if m != nil {
  1149. return m.DatFileSize
  1150. }
  1151. return 0
  1152. }
  1153. func (m *ReadVolumeFileStatusResponse) GetFileCount() uint64 {
  1154. if m != nil {
  1155. return m.FileCount
  1156. }
  1157. return 0
  1158. }
  1159. func (m *ReadVolumeFileStatusResponse) GetCompactionRevision() uint32 {
  1160. if m != nil {
  1161. return m.CompactionRevision
  1162. }
  1163. return 0
  1164. }
  1165. func (m *ReadVolumeFileStatusResponse) GetCollection() string {
  1166. if m != nil {
  1167. return m.Collection
  1168. }
  1169. return ""
  1170. }
  1171. type DiskStatus struct {
  1172. Dir string `protobuf:"bytes,1,opt,name=dir" json:"dir,omitempty"`
  1173. All uint64 `protobuf:"varint,2,opt,name=all" json:"all,omitempty"`
  1174. Used uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
  1175. Free uint64 `protobuf:"varint,4,opt,name=free" json:"free,omitempty"`
  1176. }
  1177. func (m *DiskStatus) Reset() { *m = DiskStatus{} }
  1178. func (m *DiskStatus) String() string { return proto.CompactTextString(m) }
  1179. func (*DiskStatus) ProtoMessage() {}
  1180. func (*DiskStatus) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{58} }
  1181. func (m *DiskStatus) GetDir() string {
  1182. if m != nil {
  1183. return m.Dir
  1184. }
  1185. return ""
  1186. }
  1187. func (m *DiskStatus) GetAll() uint64 {
  1188. if m != nil {
  1189. return m.All
  1190. }
  1191. return 0
  1192. }
  1193. func (m *DiskStatus) GetUsed() uint64 {
  1194. if m != nil {
  1195. return m.Used
  1196. }
  1197. return 0
  1198. }
  1199. func (m *DiskStatus) GetFree() uint64 {
  1200. if m != nil {
  1201. return m.Free
  1202. }
  1203. return 0
  1204. }
  1205. type MemStatus struct {
  1206. Goroutines int32 `protobuf:"varint,1,opt,name=goroutines" json:"goroutines,omitempty"`
  1207. All uint64 `protobuf:"varint,2,opt,name=all" json:"all,omitempty"`
  1208. Used uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
  1209. Free uint64 `protobuf:"varint,4,opt,name=free" json:"free,omitempty"`
  1210. Self uint64 `protobuf:"varint,5,opt,name=self" json:"self,omitempty"`
  1211. Heap uint64 `protobuf:"varint,6,opt,name=heap" json:"heap,omitempty"`
  1212. Stack uint64 `protobuf:"varint,7,opt,name=stack" json:"stack,omitempty"`
  1213. }
  1214. func (m *MemStatus) Reset() { *m = MemStatus{} }
  1215. func (m *MemStatus) String() string { return proto.CompactTextString(m) }
  1216. func (*MemStatus) ProtoMessage() {}
  1217. func (*MemStatus) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{59} }
  1218. func (m *MemStatus) GetGoroutines() int32 {
  1219. if m != nil {
  1220. return m.Goroutines
  1221. }
  1222. return 0
  1223. }
  1224. func (m *MemStatus) GetAll() uint64 {
  1225. if m != nil {
  1226. return m.All
  1227. }
  1228. return 0
  1229. }
  1230. func (m *MemStatus) GetUsed() uint64 {
  1231. if m != nil {
  1232. return m.Used
  1233. }
  1234. return 0
  1235. }
  1236. func (m *MemStatus) GetFree() uint64 {
  1237. if m != nil {
  1238. return m.Free
  1239. }
  1240. return 0
  1241. }
  1242. func (m *MemStatus) GetSelf() uint64 {
  1243. if m != nil {
  1244. return m.Self
  1245. }
  1246. return 0
  1247. }
  1248. func (m *MemStatus) GetHeap() uint64 {
  1249. if m != nil {
  1250. return m.Heap
  1251. }
  1252. return 0
  1253. }
  1254. func (m *MemStatus) GetStack() uint64 {
  1255. if m != nil {
  1256. return m.Stack
  1257. }
  1258. return 0
  1259. }
  1260. // tired storage on volume servers
  1261. type RemoteFile struct {
  1262. BackendType string `protobuf:"bytes,1,opt,name=backend_type,json=backendType" json:"backend_type,omitempty"`
  1263. BackendId string `protobuf:"bytes,2,opt,name=backend_id,json=backendId" json:"backend_id,omitempty"`
  1264. Key string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
  1265. Offset uint64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
  1266. FileSize uint64 `protobuf:"varint,5,opt,name=file_size,json=fileSize" json:"file_size,omitempty"`
  1267. ModifiedTime uint64 `protobuf:"varint,6,opt,name=modified_time,json=modifiedTime" json:"modified_time,omitempty"`
  1268. Extension string `protobuf:"bytes,7,opt,name=extension" json:"extension,omitempty"`
  1269. }
  1270. func (m *RemoteFile) Reset() { *m = RemoteFile{} }
  1271. func (m *RemoteFile) String() string { return proto.CompactTextString(m) }
  1272. func (*RemoteFile) ProtoMessage() {}
  1273. func (*RemoteFile) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{60} }
  1274. func (m *RemoteFile) GetBackendType() string {
  1275. if m != nil {
  1276. return m.BackendType
  1277. }
  1278. return ""
  1279. }
  1280. func (m *RemoteFile) GetBackendId() string {
  1281. if m != nil {
  1282. return m.BackendId
  1283. }
  1284. return ""
  1285. }
  1286. func (m *RemoteFile) GetKey() string {
  1287. if m != nil {
  1288. return m.Key
  1289. }
  1290. return ""
  1291. }
  1292. func (m *RemoteFile) GetOffset() uint64 {
  1293. if m != nil {
  1294. return m.Offset
  1295. }
  1296. return 0
  1297. }
  1298. func (m *RemoteFile) GetFileSize() uint64 {
  1299. if m != nil {
  1300. return m.FileSize
  1301. }
  1302. return 0
  1303. }
  1304. func (m *RemoteFile) GetModifiedTime() uint64 {
  1305. if m != nil {
  1306. return m.ModifiedTime
  1307. }
  1308. return 0
  1309. }
  1310. func (m *RemoteFile) GetExtension() string {
  1311. if m != nil {
  1312. return m.Extension
  1313. }
  1314. return ""
  1315. }
  1316. type VolumeInfo struct {
  1317. Files []*RemoteFile `protobuf:"bytes,1,rep,name=files" json:"files,omitempty"`
  1318. Version uint32 `protobuf:"varint,2,opt,name=version" json:"version,omitempty"`
  1319. Replication string `protobuf:"bytes,3,opt,name=replication" json:"replication,omitempty"`
  1320. }
  1321. func (m *VolumeInfo) Reset() { *m = VolumeInfo{} }
  1322. func (m *VolumeInfo) String() string { return proto.CompactTextString(m) }
  1323. func (*VolumeInfo) ProtoMessage() {}
  1324. func (*VolumeInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{61} }
  1325. func (m *VolumeInfo) GetFiles() []*RemoteFile {
  1326. if m != nil {
  1327. return m.Files
  1328. }
  1329. return nil
  1330. }
  1331. func (m *VolumeInfo) GetVersion() uint32 {
  1332. if m != nil {
  1333. return m.Version
  1334. }
  1335. return 0
  1336. }
  1337. func (m *VolumeInfo) GetReplication() string {
  1338. if m != nil {
  1339. return m.Replication
  1340. }
  1341. return ""
  1342. }
  1343. type VolumeTierMoveDatToRemoteRequest struct {
  1344. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1345. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  1346. DestinationBackendName string `protobuf:"bytes,3,opt,name=destination_backend_name,json=destinationBackendName" json:"destination_backend_name,omitempty"`
  1347. KeepLocalDatFile bool `protobuf:"varint,4,opt,name=keep_local_dat_file,json=keepLocalDatFile" json:"keep_local_dat_file,omitempty"`
  1348. }
  1349. func (m *VolumeTierMoveDatToRemoteRequest) Reset() { *m = VolumeTierMoveDatToRemoteRequest{} }
  1350. func (m *VolumeTierMoveDatToRemoteRequest) String() string { return proto.CompactTextString(m) }
  1351. func (*VolumeTierMoveDatToRemoteRequest) ProtoMessage() {}
  1352. func (*VolumeTierMoveDatToRemoteRequest) Descriptor() ([]byte, []int) {
  1353. return fileDescriptor0, []int{62}
  1354. }
  1355. func (m *VolumeTierMoveDatToRemoteRequest) GetVolumeId() uint32 {
  1356. if m != nil {
  1357. return m.VolumeId
  1358. }
  1359. return 0
  1360. }
  1361. func (m *VolumeTierMoveDatToRemoteRequest) GetCollection() string {
  1362. if m != nil {
  1363. return m.Collection
  1364. }
  1365. return ""
  1366. }
  1367. func (m *VolumeTierMoveDatToRemoteRequest) GetDestinationBackendName() string {
  1368. if m != nil {
  1369. return m.DestinationBackendName
  1370. }
  1371. return ""
  1372. }
  1373. func (m *VolumeTierMoveDatToRemoteRequest) GetKeepLocalDatFile() bool {
  1374. if m != nil {
  1375. return m.KeepLocalDatFile
  1376. }
  1377. return false
  1378. }
  1379. type VolumeTierMoveDatToRemoteResponse struct {
  1380. Processed int64 `protobuf:"varint,1,opt,name=processed" json:"processed,omitempty"`
  1381. ProcessedPercentage float32 `protobuf:"fixed32,2,opt,name=processedPercentage" json:"processedPercentage,omitempty"`
  1382. }
  1383. func (m *VolumeTierMoveDatToRemoteResponse) Reset() { *m = VolumeTierMoveDatToRemoteResponse{} }
  1384. func (m *VolumeTierMoveDatToRemoteResponse) String() string { return proto.CompactTextString(m) }
  1385. func (*VolumeTierMoveDatToRemoteResponse) ProtoMessage() {}
  1386. func (*VolumeTierMoveDatToRemoteResponse) Descriptor() ([]byte, []int) {
  1387. return fileDescriptor0, []int{63}
  1388. }
  1389. func (m *VolumeTierMoveDatToRemoteResponse) GetProcessed() int64 {
  1390. if m != nil {
  1391. return m.Processed
  1392. }
  1393. return 0
  1394. }
  1395. func (m *VolumeTierMoveDatToRemoteResponse) GetProcessedPercentage() float32 {
  1396. if m != nil {
  1397. return m.ProcessedPercentage
  1398. }
  1399. return 0
  1400. }
  1401. type VolumeTierMoveDatFromRemoteRequest struct {
  1402. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1403. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  1404. KeepRemoteDatFile bool `protobuf:"varint,3,opt,name=keep_remote_dat_file,json=keepRemoteDatFile" json:"keep_remote_dat_file,omitempty"`
  1405. }
  1406. func (m *VolumeTierMoveDatFromRemoteRequest) Reset() { *m = VolumeTierMoveDatFromRemoteRequest{} }
  1407. func (m *VolumeTierMoveDatFromRemoteRequest) String() string { return proto.CompactTextString(m) }
  1408. func (*VolumeTierMoveDatFromRemoteRequest) ProtoMessage() {}
  1409. func (*VolumeTierMoveDatFromRemoteRequest) Descriptor() ([]byte, []int) {
  1410. return fileDescriptor0, []int{64}
  1411. }
  1412. func (m *VolumeTierMoveDatFromRemoteRequest) GetVolumeId() uint32 {
  1413. if m != nil {
  1414. return m.VolumeId
  1415. }
  1416. return 0
  1417. }
  1418. func (m *VolumeTierMoveDatFromRemoteRequest) GetCollection() string {
  1419. if m != nil {
  1420. return m.Collection
  1421. }
  1422. return ""
  1423. }
  1424. func (m *VolumeTierMoveDatFromRemoteRequest) GetKeepRemoteDatFile() bool {
  1425. if m != nil {
  1426. return m.KeepRemoteDatFile
  1427. }
  1428. return false
  1429. }
  1430. type VolumeTierMoveDatFromRemoteResponse struct {
  1431. Processed int64 `protobuf:"varint,1,opt,name=processed" json:"processed,omitempty"`
  1432. ProcessedPercentage float32 `protobuf:"fixed32,2,opt,name=processedPercentage" json:"processedPercentage,omitempty"`
  1433. }
  1434. func (m *VolumeTierMoveDatFromRemoteResponse) Reset() { *m = VolumeTierMoveDatFromRemoteResponse{} }
  1435. func (m *VolumeTierMoveDatFromRemoteResponse) String() string { return proto.CompactTextString(m) }
  1436. func (*VolumeTierMoveDatFromRemoteResponse) ProtoMessage() {}
  1437. func (*VolumeTierMoveDatFromRemoteResponse) Descriptor() ([]byte, []int) {
  1438. return fileDescriptor0, []int{65}
  1439. }
  1440. func (m *VolumeTierMoveDatFromRemoteResponse) GetProcessed() int64 {
  1441. if m != nil {
  1442. return m.Processed
  1443. }
  1444. return 0
  1445. }
  1446. func (m *VolumeTierMoveDatFromRemoteResponse) GetProcessedPercentage() float32 {
  1447. if m != nil {
  1448. return m.ProcessedPercentage
  1449. }
  1450. return 0
  1451. }
  1452. // select on volume servers
  1453. type QueryRequest struct {
  1454. Selections []string `protobuf:"bytes,1,rep,name=selections" json:"selections,omitempty"`
  1455. FromFileIds []string `protobuf:"bytes,2,rep,name=from_file_ids,json=fromFileIds" json:"from_file_ids,omitempty"`
  1456. Filter *QueryRequest_Filter `protobuf:"bytes,3,opt,name=filter" json:"filter,omitempty"`
  1457. InputSerialization *QueryRequest_InputSerialization `protobuf:"bytes,4,opt,name=input_serialization,json=inputSerialization" json:"input_serialization,omitempty"`
  1458. OutputSerialization *QueryRequest_OutputSerialization `protobuf:"bytes,5,opt,name=output_serialization,json=outputSerialization" json:"output_serialization,omitempty"`
  1459. }
  1460. func (m *QueryRequest) Reset() { *m = QueryRequest{} }
  1461. func (m *QueryRequest) String() string { return proto.CompactTextString(m) }
  1462. func (*QueryRequest) ProtoMessage() {}
  1463. func (*QueryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{66} }
  1464. func (m *QueryRequest) GetSelections() []string {
  1465. if m != nil {
  1466. return m.Selections
  1467. }
  1468. return nil
  1469. }
  1470. func (m *QueryRequest) GetFromFileIds() []string {
  1471. if m != nil {
  1472. return m.FromFileIds
  1473. }
  1474. return nil
  1475. }
  1476. func (m *QueryRequest) GetFilter() *QueryRequest_Filter {
  1477. if m != nil {
  1478. return m.Filter
  1479. }
  1480. return nil
  1481. }
  1482. func (m *QueryRequest) GetInputSerialization() *QueryRequest_InputSerialization {
  1483. if m != nil {
  1484. return m.InputSerialization
  1485. }
  1486. return nil
  1487. }
  1488. func (m *QueryRequest) GetOutputSerialization() *QueryRequest_OutputSerialization {
  1489. if m != nil {
  1490. return m.OutputSerialization
  1491. }
  1492. return nil
  1493. }
  1494. type QueryRequest_Filter struct {
  1495. Field string `protobuf:"bytes,1,opt,name=field" json:"field,omitempty"`
  1496. Operand string `protobuf:"bytes,2,opt,name=operand" json:"operand,omitempty"`
  1497. Value string `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
  1498. }
  1499. func (m *QueryRequest_Filter) Reset() { *m = QueryRequest_Filter{} }
  1500. func (m *QueryRequest_Filter) String() string { return proto.CompactTextString(m) }
  1501. func (*QueryRequest_Filter) ProtoMessage() {}
  1502. func (*QueryRequest_Filter) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{66, 0} }
  1503. func (m *QueryRequest_Filter) GetField() string {
  1504. if m != nil {
  1505. return m.Field
  1506. }
  1507. return ""
  1508. }
  1509. func (m *QueryRequest_Filter) GetOperand() string {
  1510. if m != nil {
  1511. return m.Operand
  1512. }
  1513. return ""
  1514. }
  1515. func (m *QueryRequest_Filter) GetValue() string {
  1516. if m != nil {
  1517. return m.Value
  1518. }
  1519. return ""
  1520. }
  1521. type QueryRequest_InputSerialization struct {
  1522. // NONE | GZIP | BZIP2
  1523. CompressionType string `protobuf:"bytes,1,opt,name=compression_type,json=compressionType" json:"compression_type,omitempty"`
  1524. CsvInput *QueryRequest_InputSerialization_CSVInput `protobuf:"bytes,2,opt,name=csv_input,json=csvInput" json:"csv_input,omitempty"`
  1525. JsonInput *QueryRequest_InputSerialization_JSONInput `protobuf:"bytes,3,opt,name=json_input,json=jsonInput" json:"json_input,omitempty"`
  1526. ParquetInput *QueryRequest_InputSerialization_ParquetInput `protobuf:"bytes,4,opt,name=parquet_input,json=parquetInput" json:"parquet_input,omitempty"`
  1527. }
  1528. func (m *QueryRequest_InputSerialization) Reset() { *m = QueryRequest_InputSerialization{} }
  1529. func (m *QueryRequest_InputSerialization) String() string { return proto.CompactTextString(m) }
  1530. func (*QueryRequest_InputSerialization) ProtoMessage() {}
  1531. func (*QueryRequest_InputSerialization) Descriptor() ([]byte, []int) {
  1532. return fileDescriptor0, []int{66, 1}
  1533. }
  1534. func (m *QueryRequest_InputSerialization) GetCompressionType() string {
  1535. if m != nil {
  1536. return m.CompressionType
  1537. }
  1538. return ""
  1539. }
  1540. func (m *QueryRequest_InputSerialization) GetCsvInput() *QueryRequest_InputSerialization_CSVInput {
  1541. if m != nil {
  1542. return m.CsvInput
  1543. }
  1544. return nil
  1545. }
  1546. func (m *QueryRequest_InputSerialization) GetJsonInput() *QueryRequest_InputSerialization_JSONInput {
  1547. if m != nil {
  1548. return m.JsonInput
  1549. }
  1550. return nil
  1551. }
  1552. func (m *QueryRequest_InputSerialization) GetParquetInput() *QueryRequest_InputSerialization_ParquetInput {
  1553. if m != nil {
  1554. return m.ParquetInput
  1555. }
  1556. return nil
  1557. }
  1558. type QueryRequest_InputSerialization_CSVInput struct {
  1559. FileHeaderInfo string `protobuf:"bytes,1,opt,name=file_header_info,json=fileHeaderInfo" json:"file_header_info,omitempty"`
  1560. RecordDelimiter string `protobuf:"bytes,2,opt,name=record_delimiter,json=recordDelimiter" json:"record_delimiter,omitempty"`
  1561. FieldDelimiter string `protobuf:"bytes,3,opt,name=field_delimiter,json=fieldDelimiter" json:"field_delimiter,omitempty"`
  1562. QuoteCharactoer string `protobuf:"bytes,4,opt,name=quote_charactoer,json=quoteCharactoer" json:"quote_charactoer,omitempty"`
  1563. QuoteEscapeCharacter string `protobuf:"bytes,5,opt,name=quote_escape_character,json=quoteEscapeCharacter" json:"quote_escape_character,omitempty"`
  1564. Comments string `protobuf:"bytes,6,opt,name=comments" json:"comments,omitempty"`
  1565. // If true, records might contain record delimiters within quote characters
  1566. AllowQuotedRecordDelimiter bool `protobuf:"varint,7,opt,name=allow_quoted_record_delimiter,json=allowQuotedRecordDelimiter" json:"allow_quoted_record_delimiter,omitempty"`
  1567. }
  1568. func (m *QueryRequest_InputSerialization_CSVInput) Reset() {
  1569. *m = QueryRequest_InputSerialization_CSVInput{}
  1570. }
  1571. func (m *QueryRequest_InputSerialization_CSVInput) String() string { return proto.CompactTextString(m) }
  1572. func (*QueryRequest_InputSerialization_CSVInput) ProtoMessage() {}
  1573. func (*QueryRequest_InputSerialization_CSVInput) Descriptor() ([]byte, []int) {
  1574. return fileDescriptor0, []int{66, 1, 0}
  1575. }
  1576. func (m *QueryRequest_InputSerialization_CSVInput) GetFileHeaderInfo() string {
  1577. if m != nil {
  1578. return m.FileHeaderInfo
  1579. }
  1580. return ""
  1581. }
  1582. func (m *QueryRequest_InputSerialization_CSVInput) GetRecordDelimiter() string {
  1583. if m != nil {
  1584. return m.RecordDelimiter
  1585. }
  1586. return ""
  1587. }
  1588. func (m *QueryRequest_InputSerialization_CSVInput) GetFieldDelimiter() string {
  1589. if m != nil {
  1590. return m.FieldDelimiter
  1591. }
  1592. return ""
  1593. }
  1594. func (m *QueryRequest_InputSerialization_CSVInput) GetQuoteCharactoer() string {
  1595. if m != nil {
  1596. return m.QuoteCharactoer
  1597. }
  1598. return ""
  1599. }
  1600. func (m *QueryRequest_InputSerialization_CSVInput) GetQuoteEscapeCharacter() string {
  1601. if m != nil {
  1602. return m.QuoteEscapeCharacter
  1603. }
  1604. return ""
  1605. }
  1606. func (m *QueryRequest_InputSerialization_CSVInput) GetComments() string {
  1607. if m != nil {
  1608. return m.Comments
  1609. }
  1610. return ""
  1611. }
  1612. func (m *QueryRequest_InputSerialization_CSVInput) GetAllowQuotedRecordDelimiter() bool {
  1613. if m != nil {
  1614. return m.AllowQuotedRecordDelimiter
  1615. }
  1616. return false
  1617. }
  1618. type QueryRequest_InputSerialization_JSONInput struct {
  1619. Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
  1620. }
  1621. func (m *QueryRequest_InputSerialization_JSONInput) Reset() {
  1622. *m = QueryRequest_InputSerialization_JSONInput{}
  1623. }
  1624. func (m *QueryRequest_InputSerialization_JSONInput) String() string { return proto.CompactTextString(m) }
  1625. func (*QueryRequest_InputSerialization_JSONInput) ProtoMessage() {}
  1626. func (*QueryRequest_InputSerialization_JSONInput) Descriptor() ([]byte, []int) {
  1627. return fileDescriptor0, []int{66, 1, 1}
  1628. }
  1629. func (m *QueryRequest_InputSerialization_JSONInput) GetType() string {
  1630. if m != nil {
  1631. return m.Type
  1632. }
  1633. return ""
  1634. }
  1635. type QueryRequest_InputSerialization_ParquetInput struct {
  1636. }
  1637. func (m *QueryRequest_InputSerialization_ParquetInput) Reset() {
  1638. *m = QueryRequest_InputSerialization_ParquetInput{}
  1639. }
  1640. func (m *QueryRequest_InputSerialization_ParquetInput) String() string {
  1641. return proto.CompactTextString(m)
  1642. }
  1643. func (*QueryRequest_InputSerialization_ParquetInput) ProtoMessage() {}
  1644. func (*QueryRequest_InputSerialization_ParquetInput) Descriptor() ([]byte, []int) {
  1645. return fileDescriptor0, []int{66, 1, 2}
  1646. }
  1647. type QueryRequest_OutputSerialization struct {
  1648. CsvOutput *QueryRequest_OutputSerialization_CSVOutput `protobuf:"bytes,2,opt,name=csv_output,json=csvOutput" json:"csv_output,omitempty"`
  1649. JsonOutput *QueryRequest_OutputSerialization_JSONOutput `protobuf:"bytes,3,opt,name=json_output,json=jsonOutput" json:"json_output,omitempty"`
  1650. }
  1651. func (m *QueryRequest_OutputSerialization) Reset() { *m = QueryRequest_OutputSerialization{} }
  1652. func (m *QueryRequest_OutputSerialization) String() string { return proto.CompactTextString(m) }
  1653. func (*QueryRequest_OutputSerialization) ProtoMessage() {}
  1654. func (*QueryRequest_OutputSerialization) Descriptor() ([]byte, []int) {
  1655. return fileDescriptor0, []int{66, 2}
  1656. }
  1657. func (m *QueryRequest_OutputSerialization) GetCsvOutput() *QueryRequest_OutputSerialization_CSVOutput {
  1658. if m != nil {
  1659. return m.CsvOutput
  1660. }
  1661. return nil
  1662. }
  1663. func (m *QueryRequest_OutputSerialization) GetJsonOutput() *QueryRequest_OutputSerialization_JSONOutput {
  1664. if m != nil {
  1665. return m.JsonOutput
  1666. }
  1667. return nil
  1668. }
  1669. type QueryRequest_OutputSerialization_CSVOutput struct {
  1670. QuoteFields string `protobuf:"bytes,1,opt,name=quote_fields,json=quoteFields" json:"quote_fields,omitempty"`
  1671. RecordDelimiter string `protobuf:"bytes,2,opt,name=record_delimiter,json=recordDelimiter" json:"record_delimiter,omitempty"`
  1672. FieldDelimiter string `protobuf:"bytes,3,opt,name=field_delimiter,json=fieldDelimiter" json:"field_delimiter,omitempty"`
  1673. QuoteCharactoer string `protobuf:"bytes,4,opt,name=quote_charactoer,json=quoteCharactoer" json:"quote_charactoer,omitempty"`
  1674. QuoteEscapeCharacter string `protobuf:"bytes,5,opt,name=quote_escape_character,json=quoteEscapeCharacter" json:"quote_escape_character,omitempty"`
  1675. }
  1676. func (m *QueryRequest_OutputSerialization_CSVOutput) Reset() {
  1677. *m = QueryRequest_OutputSerialization_CSVOutput{}
  1678. }
  1679. func (m *QueryRequest_OutputSerialization_CSVOutput) String() string {
  1680. return proto.CompactTextString(m)
  1681. }
  1682. func (*QueryRequest_OutputSerialization_CSVOutput) ProtoMessage() {}
  1683. func (*QueryRequest_OutputSerialization_CSVOutput) Descriptor() ([]byte, []int) {
  1684. return fileDescriptor0, []int{66, 2, 0}
  1685. }
  1686. func (m *QueryRequest_OutputSerialization_CSVOutput) GetQuoteFields() string {
  1687. if m != nil {
  1688. return m.QuoteFields
  1689. }
  1690. return ""
  1691. }
  1692. func (m *QueryRequest_OutputSerialization_CSVOutput) GetRecordDelimiter() string {
  1693. if m != nil {
  1694. return m.RecordDelimiter
  1695. }
  1696. return ""
  1697. }
  1698. func (m *QueryRequest_OutputSerialization_CSVOutput) GetFieldDelimiter() string {
  1699. if m != nil {
  1700. return m.FieldDelimiter
  1701. }
  1702. return ""
  1703. }
  1704. func (m *QueryRequest_OutputSerialization_CSVOutput) GetQuoteCharactoer() string {
  1705. if m != nil {
  1706. return m.QuoteCharactoer
  1707. }
  1708. return ""
  1709. }
  1710. func (m *QueryRequest_OutputSerialization_CSVOutput) GetQuoteEscapeCharacter() string {
  1711. if m != nil {
  1712. return m.QuoteEscapeCharacter
  1713. }
  1714. return ""
  1715. }
  1716. type QueryRequest_OutputSerialization_JSONOutput struct {
  1717. RecordDelimiter string `protobuf:"bytes,1,opt,name=record_delimiter,json=recordDelimiter" json:"record_delimiter,omitempty"`
  1718. }
  1719. func (m *QueryRequest_OutputSerialization_JSONOutput) Reset() {
  1720. *m = QueryRequest_OutputSerialization_JSONOutput{}
  1721. }
  1722. func (m *QueryRequest_OutputSerialization_JSONOutput) String() string {
  1723. return proto.CompactTextString(m)
  1724. }
  1725. func (*QueryRequest_OutputSerialization_JSONOutput) ProtoMessage() {}
  1726. func (*QueryRequest_OutputSerialization_JSONOutput) Descriptor() ([]byte, []int) {
  1727. return fileDescriptor0, []int{66, 2, 1}
  1728. }
  1729. func (m *QueryRequest_OutputSerialization_JSONOutput) GetRecordDelimiter() string {
  1730. if m != nil {
  1731. return m.RecordDelimiter
  1732. }
  1733. return ""
  1734. }
  1735. type QueriedStripe struct {
  1736. Records []byte `protobuf:"bytes,1,opt,name=records,proto3" json:"records,omitempty"`
  1737. }
  1738. func (m *QueriedStripe) Reset() { *m = QueriedStripe{} }
  1739. func (m *QueriedStripe) String() string { return proto.CompactTextString(m) }
  1740. func (*QueriedStripe) ProtoMessage() {}
  1741. func (*QueriedStripe) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{67} }
  1742. func (m *QueriedStripe) GetRecords() []byte {
  1743. if m != nil {
  1744. return m.Records
  1745. }
  1746. return nil
  1747. }
  1748. func init() {
  1749. proto.RegisterType((*BatchDeleteRequest)(nil), "volume_server_pb.BatchDeleteRequest")
  1750. proto.RegisterType((*BatchDeleteResponse)(nil), "volume_server_pb.BatchDeleteResponse")
  1751. proto.RegisterType((*DeleteResult)(nil), "volume_server_pb.DeleteResult")
  1752. proto.RegisterType((*Empty)(nil), "volume_server_pb.Empty")
  1753. proto.RegisterType((*VacuumVolumeCheckRequest)(nil), "volume_server_pb.VacuumVolumeCheckRequest")
  1754. proto.RegisterType((*VacuumVolumeCheckResponse)(nil), "volume_server_pb.VacuumVolumeCheckResponse")
  1755. proto.RegisterType((*VacuumVolumeCompactRequest)(nil), "volume_server_pb.VacuumVolumeCompactRequest")
  1756. proto.RegisterType((*VacuumVolumeCompactResponse)(nil), "volume_server_pb.VacuumVolumeCompactResponse")
  1757. proto.RegisterType((*VacuumVolumeCommitRequest)(nil), "volume_server_pb.VacuumVolumeCommitRequest")
  1758. proto.RegisterType((*VacuumVolumeCommitResponse)(nil), "volume_server_pb.VacuumVolumeCommitResponse")
  1759. proto.RegisterType((*VacuumVolumeCleanupRequest)(nil), "volume_server_pb.VacuumVolumeCleanupRequest")
  1760. proto.RegisterType((*VacuumVolumeCleanupResponse)(nil), "volume_server_pb.VacuumVolumeCleanupResponse")
  1761. proto.RegisterType((*DeleteCollectionRequest)(nil), "volume_server_pb.DeleteCollectionRequest")
  1762. proto.RegisterType((*DeleteCollectionResponse)(nil), "volume_server_pb.DeleteCollectionResponse")
  1763. proto.RegisterType((*AllocateVolumeRequest)(nil), "volume_server_pb.AllocateVolumeRequest")
  1764. proto.RegisterType((*AllocateVolumeResponse)(nil), "volume_server_pb.AllocateVolumeResponse")
  1765. proto.RegisterType((*VolumeSyncStatusRequest)(nil), "volume_server_pb.VolumeSyncStatusRequest")
  1766. proto.RegisterType((*VolumeSyncStatusResponse)(nil), "volume_server_pb.VolumeSyncStatusResponse")
  1767. proto.RegisterType((*VolumeIncrementalCopyRequest)(nil), "volume_server_pb.VolumeIncrementalCopyRequest")
  1768. proto.RegisterType((*VolumeIncrementalCopyResponse)(nil), "volume_server_pb.VolumeIncrementalCopyResponse")
  1769. proto.RegisterType((*VolumeMountRequest)(nil), "volume_server_pb.VolumeMountRequest")
  1770. proto.RegisterType((*VolumeMountResponse)(nil), "volume_server_pb.VolumeMountResponse")
  1771. proto.RegisterType((*VolumeUnmountRequest)(nil), "volume_server_pb.VolumeUnmountRequest")
  1772. proto.RegisterType((*VolumeUnmountResponse)(nil), "volume_server_pb.VolumeUnmountResponse")
  1773. proto.RegisterType((*VolumeDeleteRequest)(nil), "volume_server_pb.VolumeDeleteRequest")
  1774. proto.RegisterType((*VolumeDeleteResponse)(nil), "volume_server_pb.VolumeDeleteResponse")
  1775. proto.RegisterType((*VolumeMarkReadonlyRequest)(nil), "volume_server_pb.VolumeMarkReadonlyRequest")
  1776. proto.RegisterType((*VolumeMarkReadonlyResponse)(nil), "volume_server_pb.VolumeMarkReadonlyResponse")
  1777. proto.RegisterType((*VolumeConfigureRequest)(nil), "volume_server_pb.VolumeConfigureRequest")
  1778. proto.RegisterType((*VolumeConfigureResponse)(nil), "volume_server_pb.VolumeConfigureResponse")
  1779. proto.RegisterType((*VolumeCopyRequest)(nil), "volume_server_pb.VolumeCopyRequest")
  1780. proto.RegisterType((*VolumeCopyResponse)(nil), "volume_server_pb.VolumeCopyResponse")
  1781. proto.RegisterType((*CopyFileRequest)(nil), "volume_server_pb.CopyFileRequest")
  1782. proto.RegisterType((*CopyFileResponse)(nil), "volume_server_pb.CopyFileResponse")
  1783. proto.RegisterType((*VolumeTailSenderRequest)(nil), "volume_server_pb.VolumeTailSenderRequest")
  1784. proto.RegisterType((*VolumeTailSenderResponse)(nil), "volume_server_pb.VolumeTailSenderResponse")
  1785. proto.RegisterType((*VolumeTailReceiverRequest)(nil), "volume_server_pb.VolumeTailReceiverRequest")
  1786. proto.RegisterType((*VolumeTailReceiverResponse)(nil), "volume_server_pb.VolumeTailReceiverResponse")
  1787. proto.RegisterType((*VolumeEcShardsGenerateRequest)(nil), "volume_server_pb.VolumeEcShardsGenerateRequest")
  1788. proto.RegisterType((*VolumeEcShardsGenerateResponse)(nil), "volume_server_pb.VolumeEcShardsGenerateResponse")
  1789. proto.RegisterType((*VolumeEcShardsRebuildRequest)(nil), "volume_server_pb.VolumeEcShardsRebuildRequest")
  1790. proto.RegisterType((*VolumeEcShardsRebuildResponse)(nil), "volume_server_pb.VolumeEcShardsRebuildResponse")
  1791. proto.RegisterType((*VolumeEcShardsCopyRequest)(nil), "volume_server_pb.VolumeEcShardsCopyRequest")
  1792. proto.RegisterType((*VolumeEcShardsCopyResponse)(nil), "volume_server_pb.VolumeEcShardsCopyResponse")
  1793. proto.RegisterType((*VolumeEcShardsDeleteRequest)(nil), "volume_server_pb.VolumeEcShardsDeleteRequest")
  1794. proto.RegisterType((*VolumeEcShardsDeleteResponse)(nil), "volume_server_pb.VolumeEcShardsDeleteResponse")
  1795. proto.RegisterType((*VolumeEcShardsMountRequest)(nil), "volume_server_pb.VolumeEcShardsMountRequest")
  1796. proto.RegisterType((*VolumeEcShardsMountResponse)(nil), "volume_server_pb.VolumeEcShardsMountResponse")
  1797. proto.RegisterType((*VolumeEcShardsUnmountRequest)(nil), "volume_server_pb.VolumeEcShardsUnmountRequest")
  1798. proto.RegisterType((*VolumeEcShardsUnmountResponse)(nil), "volume_server_pb.VolumeEcShardsUnmountResponse")
  1799. proto.RegisterType((*VolumeEcShardReadRequest)(nil), "volume_server_pb.VolumeEcShardReadRequest")
  1800. proto.RegisterType((*VolumeEcShardReadResponse)(nil), "volume_server_pb.VolumeEcShardReadResponse")
  1801. proto.RegisterType((*VolumeEcBlobDeleteRequest)(nil), "volume_server_pb.VolumeEcBlobDeleteRequest")
  1802. proto.RegisterType((*VolumeEcBlobDeleteResponse)(nil), "volume_server_pb.VolumeEcBlobDeleteResponse")
  1803. proto.RegisterType((*VolumeEcShardsToVolumeRequest)(nil), "volume_server_pb.VolumeEcShardsToVolumeRequest")
  1804. proto.RegisterType((*VolumeEcShardsToVolumeResponse)(nil), "volume_server_pb.VolumeEcShardsToVolumeResponse")
  1805. proto.RegisterType((*ReadVolumeFileStatusRequest)(nil), "volume_server_pb.ReadVolumeFileStatusRequest")
  1806. proto.RegisterType((*ReadVolumeFileStatusResponse)(nil), "volume_server_pb.ReadVolumeFileStatusResponse")
  1807. proto.RegisterType((*DiskStatus)(nil), "volume_server_pb.DiskStatus")
  1808. proto.RegisterType((*MemStatus)(nil), "volume_server_pb.MemStatus")
  1809. proto.RegisterType((*RemoteFile)(nil), "volume_server_pb.RemoteFile")
  1810. proto.RegisterType((*VolumeInfo)(nil), "volume_server_pb.VolumeInfo")
  1811. proto.RegisterType((*VolumeTierMoveDatToRemoteRequest)(nil), "volume_server_pb.VolumeTierMoveDatToRemoteRequest")
  1812. proto.RegisterType((*VolumeTierMoveDatToRemoteResponse)(nil), "volume_server_pb.VolumeTierMoveDatToRemoteResponse")
  1813. proto.RegisterType((*VolumeTierMoveDatFromRemoteRequest)(nil), "volume_server_pb.VolumeTierMoveDatFromRemoteRequest")
  1814. proto.RegisterType((*VolumeTierMoveDatFromRemoteResponse)(nil), "volume_server_pb.VolumeTierMoveDatFromRemoteResponse")
  1815. proto.RegisterType((*QueryRequest)(nil), "volume_server_pb.QueryRequest")
  1816. proto.RegisterType((*QueryRequest_Filter)(nil), "volume_server_pb.QueryRequest.Filter")
  1817. proto.RegisterType((*QueryRequest_InputSerialization)(nil), "volume_server_pb.QueryRequest.InputSerialization")
  1818. proto.RegisterType((*QueryRequest_InputSerialization_CSVInput)(nil), "volume_server_pb.QueryRequest.InputSerialization.CSVInput")
  1819. proto.RegisterType((*QueryRequest_InputSerialization_JSONInput)(nil), "volume_server_pb.QueryRequest.InputSerialization.JSONInput")
  1820. proto.RegisterType((*QueryRequest_InputSerialization_ParquetInput)(nil), "volume_server_pb.QueryRequest.InputSerialization.ParquetInput")
  1821. proto.RegisterType((*QueryRequest_OutputSerialization)(nil), "volume_server_pb.QueryRequest.OutputSerialization")
  1822. proto.RegisterType((*QueryRequest_OutputSerialization_CSVOutput)(nil), "volume_server_pb.QueryRequest.OutputSerialization.CSVOutput")
  1823. proto.RegisterType((*QueryRequest_OutputSerialization_JSONOutput)(nil), "volume_server_pb.QueryRequest.OutputSerialization.JSONOutput")
  1824. proto.RegisterType((*QueriedStripe)(nil), "volume_server_pb.QueriedStripe")
  1825. }
  1826. // Reference imports to suppress errors if they are not otherwise used.
  1827. var _ context.Context
  1828. var _ grpc.ClientConn
  1829. // This is a compile-time assertion to ensure that this generated file
  1830. // is compatible with the grpc package it is being compiled against.
  1831. const _ = grpc.SupportPackageIsVersion4
  1832. // Client API for VolumeServer service
  1833. type VolumeServerClient interface {
  1834. // Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
  1835. BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error)
  1836. VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error)
  1837. VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (*VacuumVolumeCompactResponse, error)
  1838. VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error)
  1839. VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error)
  1840. DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
  1841. AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error)
  1842. VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error)
  1843. VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error)
  1844. VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error)
  1845. VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error)
  1846. VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error)
  1847. VolumeMarkReadonly(ctx context.Context, in *VolumeMarkReadonlyRequest, opts ...grpc.CallOption) (*VolumeMarkReadonlyResponse, error)
  1848. VolumeConfigure(ctx context.Context, in *VolumeConfigureRequest, opts ...grpc.CallOption) (*VolumeConfigureResponse, error)
  1849. // copy the .idx .dat files, and mount this volume
  1850. VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (*VolumeCopyResponse, error)
  1851. ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error)
  1852. CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error)
  1853. VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error)
  1854. VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error)
  1855. // erasure coding
  1856. VolumeEcShardsGenerate(ctx context.Context, in *VolumeEcShardsGenerateRequest, opts ...grpc.CallOption) (*VolumeEcShardsGenerateResponse, error)
  1857. VolumeEcShardsRebuild(ctx context.Context, in *VolumeEcShardsRebuildRequest, opts ...grpc.CallOption) (*VolumeEcShardsRebuildResponse, error)
  1858. VolumeEcShardsCopy(ctx context.Context, in *VolumeEcShardsCopyRequest, opts ...grpc.CallOption) (*VolumeEcShardsCopyResponse, error)
  1859. VolumeEcShardsDelete(ctx context.Context, in *VolumeEcShardsDeleteRequest, opts ...grpc.CallOption) (*VolumeEcShardsDeleteResponse, error)
  1860. VolumeEcShardsMount(ctx context.Context, in *VolumeEcShardsMountRequest, opts ...grpc.CallOption) (*VolumeEcShardsMountResponse, error)
  1861. VolumeEcShardsUnmount(ctx context.Context, in *VolumeEcShardsUnmountRequest, opts ...grpc.CallOption) (*VolumeEcShardsUnmountResponse, error)
  1862. VolumeEcShardRead(ctx context.Context, in *VolumeEcShardReadRequest, opts ...grpc.CallOption) (VolumeServer_VolumeEcShardReadClient, error)
  1863. VolumeEcBlobDelete(ctx context.Context, in *VolumeEcBlobDeleteRequest, opts ...grpc.CallOption) (*VolumeEcBlobDeleteResponse, error)
  1864. VolumeEcShardsToVolume(ctx context.Context, in *VolumeEcShardsToVolumeRequest, opts ...grpc.CallOption) (*VolumeEcShardsToVolumeResponse, error)
  1865. // tiered storage
  1866. VolumeTierMoveDatToRemote(ctx context.Context, in *VolumeTierMoveDatToRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatToRemoteClient, error)
  1867. VolumeTierMoveDatFromRemote(ctx context.Context, in *VolumeTierMoveDatFromRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatFromRemoteClient, error)
  1868. // query
  1869. Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (VolumeServer_QueryClient, error)
  1870. }
  1871. type volumeServerClient struct {
  1872. cc *grpc.ClientConn
  1873. }
  1874. func NewVolumeServerClient(cc *grpc.ClientConn) VolumeServerClient {
  1875. return &volumeServerClient{cc}
  1876. }
  1877. func (c *volumeServerClient) BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error) {
  1878. out := new(BatchDeleteResponse)
  1879. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/BatchDelete", in, out, c.cc, opts...)
  1880. if err != nil {
  1881. return nil, err
  1882. }
  1883. return out, nil
  1884. }
  1885. func (c *volumeServerClient) VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error) {
  1886. out := new(VacuumVolumeCheckResponse)
  1887. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCheck", in, out, c.cc, opts...)
  1888. if err != nil {
  1889. return nil, err
  1890. }
  1891. return out, nil
  1892. }
  1893. func (c *volumeServerClient) VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (*VacuumVolumeCompactResponse, error) {
  1894. out := new(VacuumVolumeCompactResponse)
  1895. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCompact", in, out, c.cc, opts...)
  1896. if err != nil {
  1897. return nil, err
  1898. }
  1899. return out, nil
  1900. }
  1901. func (c *volumeServerClient) VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error) {
  1902. out := new(VacuumVolumeCommitResponse)
  1903. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCommit", in, out, c.cc, opts...)
  1904. if err != nil {
  1905. return nil, err
  1906. }
  1907. return out, nil
  1908. }
  1909. func (c *volumeServerClient) VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error) {
  1910. out := new(VacuumVolumeCleanupResponse)
  1911. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCleanup", in, out, c.cc, opts...)
  1912. if err != nil {
  1913. return nil, err
  1914. }
  1915. return out, nil
  1916. }
  1917. func (c *volumeServerClient) DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) {
  1918. out := new(DeleteCollectionResponse)
  1919. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/DeleteCollection", in, out, c.cc, opts...)
  1920. if err != nil {
  1921. return nil, err
  1922. }
  1923. return out, nil
  1924. }
  1925. func (c *volumeServerClient) AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error) {
  1926. out := new(AllocateVolumeResponse)
  1927. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/AllocateVolume", in, out, c.cc, opts...)
  1928. if err != nil {
  1929. return nil, err
  1930. }
  1931. return out, nil
  1932. }
  1933. func (c *volumeServerClient) VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error) {
  1934. out := new(VolumeSyncStatusResponse)
  1935. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeSyncStatus", in, out, c.cc, opts...)
  1936. if err != nil {
  1937. return nil, err
  1938. }
  1939. return out, nil
  1940. }
  1941. func (c *volumeServerClient) VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error) {
  1942. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[0], c.cc, "/volume_server_pb.VolumeServer/VolumeIncrementalCopy", opts...)
  1943. if err != nil {
  1944. return nil, err
  1945. }
  1946. x := &volumeServerVolumeIncrementalCopyClient{stream}
  1947. if err := x.ClientStream.SendMsg(in); err != nil {
  1948. return nil, err
  1949. }
  1950. if err := x.ClientStream.CloseSend(); err != nil {
  1951. return nil, err
  1952. }
  1953. return x, nil
  1954. }
  1955. type VolumeServer_VolumeIncrementalCopyClient interface {
  1956. Recv() (*VolumeIncrementalCopyResponse, error)
  1957. grpc.ClientStream
  1958. }
  1959. type volumeServerVolumeIncrementalCopyClient struct {
  1960. grpc.ClientStream
  1961. }
  1962. func (x *volumeServerVolumeIncrementalCopyClient) Recv() (*VolumeIncrementalCopyResponse, error) {
  1963. m := new(VolumeIncrementalCopyResponse)
  1964. if err := x.ClientStream.RecvMsg(m); err != nil {
  1965. return nil, err
  1966. }
  1967. return m, nil
  1968. }
  1969. func (c *volumeServerClient) VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error) {
  1970. out := new(VolumeMountResponse)
  1971. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeMount", in, out, c.cc, opts...)
  1972. if err != nil {
  1973. return nil, err
  1974. }
  1975. return out, nil
  1976. }
  1977. func (c *volumeServerClient) VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error) {
  1978. out := new(VolumeUnmountResponse)
  1979. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeUnmount", in, out, c.cc, opts...)
  1980. if err != nil {
  1981. return nil, err
  1982. }
  1983. return out, nil
  1984. }
  1985. func (c *volumeServerClient) VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error) {
  1986. out := new(VolumeDeleteResponse)
  1987. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeDelete", in, out, c.cc, opts...)
  1988. if err != nil {
  1989. return nil, err
  1990. }
  1991. return out, nil
  1992. }
  1993. func (c *volumeServerClient) VolumeMarkReadonly(ctx context.Context, in *VolumeMarkReadonlyRequest, opts ...grpc.CallOption) (*VolumeMarkReadonlyResponse, error) {
  1994. out := new(VolumeMarkReadonlyResponse)
  1995. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeMarkReadonly", in, out, c.cc, opts...)
  1996. if err != nil {
  1997. return nil, err
  1998. }
  1999. return out, nil
  2000. }
  2001. func (c *volumeServerClient) VolumeConfigure(ctx context.Context, in *VolumeConfigureRequest, opts ...grpc.CallOption) (*VolumeConfigureResponse, error) {
  2002. out := new(VolumeConfigureResponse)
  2003. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeConfigure", in, out, c.cc, opts...)
  2004. if err != nil {
  2005. return nil, err
  2006. }
  2007. return out, nil
  2008. }
  2009. func (c *volumeServerClient) VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (*VolumeCopyResponse, error) {
  2010. out := new(VolumeCopyResponse)
  2011. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeCopy", in, out, c.cc, opts...)
  2012. if err != nil {
  2013. return nil, err
  2014. }
  2015. return out, nil
  2016. }
  2017. func (c *volumeServerClient) ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error) {
  2018. out := new(ReadVolumeFileStatusResponse)
  2019. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/ReadVolumeFileStatus", in, out, c.cc, opts...)
  2020. if err != nil {
  2021. return nil, err
  2022. }
  2023. return out, nil
  2024. }
  2025. func (c *volumeServerClient) CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error) {
  2026. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[1], c.cc, "/volume_server_pb.VolumeServer/CopyFile", opts...)
  2027. if err != nil {
  2028. return nil, err
  2029. }
  2030. x := &volumeServerCopyFileClient{stream}
  2031. if err := x.ClientStream.SendMsg(in); err != nil {
  2032. return nil, err
  2033. }
  2034. if err := x.ClientStream.CloseSend(); err != nil {
  2035. return nil, err
  2036. }
  2037. return x, nil
  2038. }
  2039. type VolumeServer_CopyFileClient interface {
  2040. Recv() (*CopyFileResponse, error)
  2041. grpc.ClientStream
  2042. }
  2043. type volumeServerCopyFileClient struct {
  2044. grpc.ClientStream
  2045. }
  2046. func (x *volumeServerCopyFileClient) Recv() (*CopyFileResponse, error) {
  2047. m := new(CopyFileResponse)
  2048. if err := x.ClientStream.RecvMsg(m); err != nil {
  2049. return nil, err
  2050. }
  2051. return m, nil
  2052. }
  2053. func (c *volumeServerClient) VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error) {
  2054. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[2], c.cc, "/volume_server_pb.VolumeServer/VolumeTailSender", opts...)
  2055. if err != nil {
  2056. return nil, err
  2057. }
  2058. x := &volumeServerVolumeTailSenderClient{stream}
  2059. if err := x.ClientStream.SendMsg(in); err != nil {
  2060. return nil, err
  2061. }
  2062. if err := x.ClientStream.CloseSend(); err != nil {
  2063. return nil, err
  2064. }
  2065. return x, nil
  2066. }
  2067. type VolumeServer_VolumeTailSenderClient interface {
  2068. Recv() (*VolumeTailSenderResponse, error)
  2069. grpc.ClientStream
  2070. }
  2071. type volumeServerVolumeTailSenderClient struct {
  2072. grpc.ClientStream
  2073. }
  2074. func (x *volumeServerVolumeTailSenderClient) Recv() (*VolumeTailSenderResponse, error) {
  2075. m := new(VolumeTailSenderResponse)
  2076. if err := x.ClientStream.RecvMsg(m); err != nil {
  2077. return nil, err
  2078. }
  2079. return m, nil
  2080. }
  2081. func (c *volumeServerClient) VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error) {
  2082. out := new(VolumeTailReceiverResponse)
  2083. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeTailReceiver", in, out, c.cc, opts...)
  2084. if err != nil {
  2085. return nil, err
  2086. }
  2087. return out, nil
  2088. }
  2089. func (c *volumeServerClient) VolumeEcShardsGenerate(ctx context.Context, in *VolumeEcShardsGenerateRequest, opts ...grpc.CallOption) (*VolumeEcShardsGenerateResponse, error) {
  2090. out := new(VolumeEcShardsGenerateResponse)
  2091. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsGenerate", in, out, c.cc, opts...)
  2092. if err != nil {
  2093. return nil, err
  2094. }
  2095. return out, nil
  2096. }
  2097. func (c *volumeServerClient) VolumeEcShardsRebuild(ctx context.Context, in *VolumeEcShardsRebuildRequest, opts ...grpc.CallOption) (*VolumeEcShardsRebuildResponse, error) {
  2098. out := new(VolumeEcShardsRebuildResponse)
  2099. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsRebuild", in, out, c.cc, opts...)
  2100. if err != nil {
  2101. return nil, err
  2102. }
  2103. return out, nil
  2104. }
  2105. func (c *volumeServerClient) VolumeEcShardsCopy(ctx context.Context, in *VolumeEcShardsCopyRequest, opts ...grpc.CallOption) (*VolumeEcShardsCopyResponse, error) {
  2106. out := new(VolumeEcShardsCopyResponse)
  2107. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsCopy", in, out, c.cc, opts...)
  2108. if err != nil {
  2109. return nil, err
  2110. }
  2111. return out, nil
  2112. }
  2113. func (c *volumeServerClient) VolumeEcShardsDelete(ctx context.Context, in *VolumeEcShardsDeleteRequest, opts ...grpc.CallOption) (*VolumeEcShardsDeleteResponse, error) {
  2114. out := new(VolumeEcShardsDeleteResponse)
  2115. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsDelete", in, out, c.cc, opts...)
  2116. if err != nil {
  2117. return nil, err
  2118. }
  2119. return out, nil
  2120. }
  2121. func (c *volumeServerClient) VolumeEcShardsMount(ctx context.Context, in *VolumeEcShardsMountRequest, opts ...grpc.CallOption) (*VolumeEcShardsMountResponse, error) {
  2122. out := new(VolumeEcShardsMountResponse)
  2123. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsMount", in, out, c.cc, opts...)
  2124. if err != nil {
  2125. return nil, err
  2126. }
  2127. return out, nil
  2128. }
  2129. func (c *volumeServerClient) VolumeEcShardsUnmount(ctx context.Context, in *VolumeEcShardsUnmountRequest, opts ...grpc.CallOption) (*VolumeEcShardsUnmountResponse, error) {
  2130. out := new(VolumeEcShardsUnmountResponse)
  2131. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsUnmount", in, out, c.cc, opts...)
  2132. if err != nil {
  2133. return nil, err
  2134. }
  2135. return out, nil
  2136. }
  2137. func (c *volumeServerClient) VolumeEcShardRead(ctx context.Context, in *VolumeEcShardReadRequest, opts ...grpc.CallOption) (VolumeServer_VolumeEcShardReadClient, error) {
  2138. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[3], c.cc, "/volume_server_pb.VolumeServer/VolumeEcShardRead", opts...)
  2139. if err != nil {
  2140. return nil, err
  2141. }
  2142. x := &volumeServerVolumeEcShardReadClient{stream}
  2143. if err := x.ClientStream.SendMsg(in); err != nil {
  2144. return nil, err
  2145. }
  2146. if err := x.ClientStream.CloseSend(); err != nil {
  2147. return nil, err
  2148. }
  2149. return x, nil
  2150. }
  2151. type VolumeServer_VolumeEcShardReadClient interface {
  2152. Recv() (*VolumeEcShardReadResponse, error)
  2153. grpc.ClientStream
  2154. }
  2155. type volumeServerVolumeEcShardReadClient struct {
  2156. grpc.ClientStream
  2157. }
  2158. func (x *volumeServerVolumeEcShardReadClient) Recv() (*VolumeEcShardReadResponse, error) {
  2159. m := new(VolumeEcShardReadResponse)
  2160. if err := x.ClientStream.RecvMsg(m); err != nil {
  2161. return nil, err
  2162. }
  2163. return m, nil
  2164. }
  2165. func (c *volumeServerClient) VolumeEcBlobDelete(ctx context.Context, in *VolumeEcBlobDeleteRequest, opts ...grpc.CallOption) (*VolumeEcBlobDeleteResponse, error) {
  2166. out := new(VolumeEcBlobDeleteResponse)
  2167. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcBlobDelete", in, out, c.cc, opts...)
  2168. if err != nil {
  2169. return nil, err
  2170. }
  2171. return out, nil
  2172. }
  2173. func (c *volumeServerClient) VolumeEcShardsToVolume(ctx context.Context, in *VolumeEcShardsToVolumeRequest, opts ...grpc.CallOption) (*VolumeEcShardsToVolumeResponse, error) {
  2174. out := new(VolumeEcShardsToVolumeResponse)
  2175. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsToVolume", in, out, c.cc, opts...)
  2176. if err != nil {
  2177. return nil, err
  2178. }
  2179. return out, nil
  2180. }
  2181. func (c *volumeServerClient) VolumeTierMoveDatToRemote(ctx context.Context, in *VolumeTierMoveDatToRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatToRemoteClient, error) {
  2182. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[4], c.cc, "/volume_server_pb.VolumeServer/VolumeTierMoveDatToRemote", opts...)
  2183. if err != nil {
  2184. return nil, err
  2185. }
  2186. x := &volumeServerVolumeTierMoveDatToRemoteClient{stream}
  2187. if err := x.ClientStream.SendMsg(in); err != nil {
  2188. return nil, err
  2189. }
  2190. if err := x.ClientStream.CloseSend(); err != nil {
  2191. return nil, err
  2192. }
  2193. return x, nil
  2194. }
  2195. type VolumeServer_VolumeTierMoveDatToRemoteClient interface {
  2196. Recv() (*VolumeTierMoveDatToRemoteResponse, error)
  2197. grpc.ClientStream
  2198. }
  2199. type volumeServerVolumeTierMoveDatToRemoteClient struct {
  2200. grpc.ClientStream
  2201. }
  2202. func (x *volumeServerVolumeTierMoveDatToRemoteClient) Recv() (*VolumeTierMoveDatToRemoteResponse, error) {
  2203. m := new(VolumeTierMoveDatToRemoteResponse)
  2204. if err := x.ClientStream.RecvMsg(m); err != nil {
  2205. return nil, err
  2206. }
  2207. return m, nil
  2208. }
  2209. func (c *volumeServerClient) VolumeTierMoveDatFromRemote(ctx context.Context, in *VolumeTierMoveDatFromRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatFromRemoteClient, error) {
  2210. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[5], c.cc, "/volume_server_pb.VolumeServer/VolumeTierMoveDatFromRemote", opts...)
  2211. if err != nil {
  2212. return nil, err
  2213. }
  2214. x := &volumeServerVolumeTierMoveDatFromRemoteClient{stream}
  2215. if err := x.ClientStream.SendMsg(in); err != nil {
  2216. return nil, err
  2217. }
  2218. if err := x.ClientStream.CloseSend(); err != nil {
  2219. return nil, err
  2220. }
  2221. return x, nil
  2222. }
  2223. type VolumeServer_VolumeTierMoveDatFromRemoteClient interface {
  2224. Recv() (*VolumeTierMoveDatFromRemoteResponse, error)
  2225. grpc.ClientStream
  2226. }
  2227. type volumeServerVolumeTierMoveDatFromRemoteClient struct {
  2228. grpc.ClientStream
  2229. }
  2230. func (x *volumeServerVolumeTierMoveDatFromRemoteClient) Recv() (*VolumeTierMoveDatFromRemoteResponse, error) {
  2231. m := new(VolumeTierMoveDatFromRemoteResponse)
  2232. if err := x.ClientStream.RecvMsg(m); err != nil {
  2233. return nil, err
  2234. }
  2235. return m, nil
  2236. }
  2237. func (c *volumeServerClient) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (VolumeServer_QueryClient, error) {
  2238. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[6], c.cc, "/volume_server_pb.VolumeServer/Query", opts...)
  2239. if err != nil {
  2240. return nil, err
  2241. }
  2242. x := &volumeServerQueryClient{stream}
  2243. if err := x.ClientStream.SendMsg(in); err != nil {
  2244. return nil, err
  2245. }
  2246. if err := x.ClientStream.CloseSend(); err != nil {
  2247. return nil, err
  2248. }
  2249. return x, nil
  2250. }
  2251. type VolumeServer_QueryClient interface {
  2252. Recv() (*QueriedStripe, error)
  2253. grpc.ClientStream
  2254. }
  2255. type volumeServerQueryClient struct {
  2256. grpc.ClientStream
  2257. }
  2258. func (x *volumeServerQueryClient) Recv() (*QueriedStripe, error) {
  2259. m := new(QueriedStripe)
  2260. if err := x.ClientStream.RecvMsg(m); err != nil {
  2261. return nil, err
  2262. }
  2263. return m, nil
  2264. }
  2265. // Server API for VolumeServer service
  2266. type VolumeServerServer interface {
  2267. // Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
  2268. BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)
  2269. VacuumVolumeCheck(context.Context, *VacuumVolumeCheckRequest) (*VacuumVolumeCheckResponse, error)
  2270. VacuumVolumeCompact(context.Context, *VacuumVolumeCompactRequest) (*VacuumVolumeCompactResponse, error)
  2271. VacuumVolumeCommit(context.Context, *VacuumVolumeCommitRequest) (*VacuumVolumeCommitResponse, error)
  2272. VacuumVolumeCleanup(context.Context, *VacuumVolumeCleanupRequest) (*VacuumVolumeCleanupResponse, error)
  2273. DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
  2274. AllocateVolume(context.Context, *AllocateVolumeRequest) (*AllocateVolumeResponse, error)
  2275. VolumeSyncStatus(context.Context, *VolumeSyncStatusRequest) (*VolumeSyncStatusResponse, error)
  2276. VolumeIncrementalCopy(*VolumeIncrementalCopyRequest, VolumeServer_VolumeIncrementalCopyServer) error
  2277. VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error)
  2278. VolumeUnmount(context.Context, *VolumeUnmountRequest) (*VolumeUnmountResponse, error)
  2279. VolumeDelete(context.Context, *VolumeDeleteRequest) (*VolumeDeleteResponse, error)
  2280. VolumeMarkReadonly(context.Context, *VolumeMarkReadonlyRequest) (*VolumeMarkReadonlyResponse, error)
  2281. VolumeConfigure(context.Context, *VolumeConfigureRequest) (*VolumeConfigureResponse, error)
  2282. // copy the .idx .dat files, and mount this volume
  2283. VolumeCopy(context.Context, *VolumeCopyRequest) (*VolumeCopyResponse, error)
  2284. ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error)
  2285. CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error
  2286. VolumeTailSender(*VolumeTailSenderRequest, VolumeServer_VolumeTailSenderServer) error
  2287. VolumeTailReceiver(context.Context, *VolumeTailReceiverRequest) (*VolumeTailReceiverResponse, error)
  2288. // erasure coding
  2289. VolumeEcShardsGenerate(context.Context, *VolumeEcShardsGenerateRequest) (*VolumeEcShardsGenerateResponse, error)
  2290. VolumeEcShardsRebuild(context.Context, *VolumeEcShardsRebuildRequest) (*VolumeEcShardsRebuildResponse, error)
  2291. VolumeEcShardsCopy(context.Context, *VolumeEcShardsCopyRequest) (*VolumeEcShardsCopyResponse, error)
  2292. VolumeEcShardsDelete(context.Context, *VolumeEcShardsDeleteRequest) (*VolumeEcShardsDeleteResponse, error)
  2293. VolumeEcShardsMount(context.Context, *VolumeEcShardsMountRequest) (*VolumeEcShardsMountResponse, error)
  2294. VolumeEcShardsUnmount(context.Context, *VolumeEcShardsUnmountRequest) (*VolumeEcShardsUnmountResponse, error)
  2295. VolumeEcShardRead(*VolumeEcShardReadRequest, VolumeServer_VolumeEcShardReadServer) error
  2296. VolumeEcBlobDelete(context.Context, *VolumeEcBlobDeleteRequest) (*VolumeEcBlobDeleteResponse, error)
  2297. VolumeEcShardsToVolume(context.Context, *VolumeEcShardsToVolumeRequest) (*VolumeEcShardsToVolumeResponse, error)
  2298. // tiered storage
  2299. VolumeTierMoveDatToRemote(*VolumeTierMoveDatToRemoteRequest, VolumeServer_VolumeTierMoveDatToRemoteServer) error
  2300. VolumeTierMoveDatFromRemote(*VolumeTierMoveDatFromRemoteRequest, VolumeServer_VolumeTierMoveDatFromRemoteServer) error
  2301. // query
  2302. Query(*QueryRequest, VolumeServer_QueryServer) error
  2303. }
  2304. func RegisterVolumeServerServer(s *grpc.Server, srv VolumeServerServer) {
  2305. s.RegisterService(&_VolumeServer_serviceDesc, srv)
  2306. }
  2307. func _VolumeServer_BatchDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2308. in := new(BatchDeleteRequest)
  2309. if err := dec(in); err != nil {
  2310. return nil, err
  2311. }
  2312. if interceptor == nil {
  2313. return srv.(VolumeServerServer).BatchDelete(ctx, in)
  2314. }
  2315. info := &grpc.UnaryServerInfo{
  2316. Server: srv,
  2317. FullMethod: "/volume_server_pb.VolumeServer/BatchDelete",
  2318. }
  2319. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2320. return srv.(VolumeServerServer).BatchDelete(ctx, req.(*BatchDeleteRequest))
  2321. }
  2322. return interceptor(ctx, in, info, handler)
  2323. }
  2324. func _VolumeServer_VacuumVolumeCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2325. in := new(VacuumVolumeCheckRequest)
  2326. if err := dec(in); err != nil {
  2327. return nil, err
  2328. }
  2329. if interceptor == nil {
  2330. return srv.(VolumeServerServer).VacuumVolumeCheck(ctx, in)
  2331. }
  2332. info := &grpc.UnaryServerInfo{
  2333. Server: srv,
  2334. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCheck",
  2335. }
  2336. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2337. return srv.(VolumeServerServer).VacuumVolumeCheck(ctx, req.(*VacuumVolumeCheckRequest))
  2338. }
  2339. return interceptor(ctx, in, info, handler)
  2340. }
  2341. func _VolumeServer_VacuumVolumeCompact_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2342. in := new(VacuumVolumeCompactRequest)
  2343. if err := dec(in); err != nil {
  2344. return nil, err
  2345. }
  2346. if interceptor == nil {
  2347. return srv.(VolumeServerServer).VacuumVolumeCompact(ctx, in)
  2348. }
  2349. info := &grpc.UnaryServerInfo{
  2350. Server: srv,
  2351. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCompact",
  2352. }
  2353. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2354. return srv.(VolumeServerServer).VacuumVolumeCompact(ctx, req.(*VacuumVolumeCompactRequest))
  2355. }
  2356. return interceptor(ctx, in, info, handler)
  2357. }
  2358. func _VolumeServer_VacuumVolumeCommit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2359. in := new(VacuumVolumeCommitRequest)
  2360. if err := dec(in); err != nil {
  2361. return nil, err
  2362. }
  2363. if interceptor == nil {
  2364. return srv.(VolumeServerServer).VacuumVolumeCommit(ctx, in)
  2365. }
  2366. info := &grpc.UnaryServerInfo{
  2367. Server: srv,
  2368. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCommit",
  2369. }
  2370. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2371. return srv.(VolumeServerServer).VacuumVolumeCommit(ctx, req.(*VacuumVolumeCommitRequest))
  2372. }
  2373. return interceptor(ctx, in, info, handler)
  2374. }
  2375. func _VolumeServer_VacuumVolumeCleanup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2376. in := new(VacuumVolumeCleanupRequest)
  2377. if err := dec(in); err != nil {
  2378. return nil, err
  2379. }
  2380. if interceptor == nil {
  2381. return srv.(VolumeServerServer).VacuumVolumeCleanup(ctx, in)
  2382. }
  2383. info := &grpc.UnaryServerInfo{
  2384. Server: srv,
  2385. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCleanup",
  2386. }
  2387. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2388. return srv.(VolumeServerServer).VacuumVolumeCleanup(ctx, req.(*VacuumVolumeCleanupRequest))
  2389. }
  2390. return interceptor(ctx, in, info, handler)
  2391. }
  2392. func _VolumeServer_DeleteCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2393. in := new(DeleteCollectionRequest)
  2394. if err := dec(in); err != nil {
  2395. return nil, err
  2396. }
  2397. if interceptor == nil {
  2398. return srv.(VolumeServerServer).DeleteCollection(ctx, in)
  2399. }
  2400. info := &grpc.UnaryServerInfo{
  2401. Server: srv,
  2402. FullMethod: "/volume_server_pb.VolumeServer/DeleteCollection",
  2403. }
  2404. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2405. return srv.(VolumeServerServer).DeleteCollection(ctx, req.(*DeleteCollectionRequest))
  2406. }
  2407. return interceptor(ctx, in, info, handler)
  2408. }
  2409. func _VolumeServer_AllocateVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2410. in := new(AllocateVolumeRequest)
  2411. if err := dec(in); err != nil {
  2412. return nil, err
  2413. }
  2414. if interceptor == nil {
  2415. return srv.(VolumeServerServer).AllocateVolume(ctx, in)
  2416. }
  2417. info := &grpc.UnaryServerInfo{
  2418. Server: srv,
  2419. FullMethod: "/volume_server_pb.VolumeServer/AllocateVolume",
  2420. }
  2421. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2422. return srv.(VolumeServerServer).AllocateVolume(ctx, req.(*AllocateVolumeRequest))
  2423. }
  2424. return interceptor(ctx, in, info, handler)
  2425. }
  2426. func _VolumeServer_VolumeSyncStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2427. in := new(VolumeSyncStatusRequest)
  2428. if err := dec(in); err != nil {
  2429. return nil, err
  2430. }
  2431. if interceptor == nil {
  2432. return srv.(VolumeServerServer).VolumeSyncStatus(ctx, in)
  2433. }
  2434. info := &grpc.UnaryServerInfo{
  2435. Server: srv,
  2436. FullMethod: "/volume_server_pb.VolumeServer/VolumeSyncStatus",
  2437. }
  2438. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2439. return srv.(VolumeServerServer).VolumeSyncStatus(ctx, req.(*VolumeSyncStatusRequest))
  2440. }
  2441. return interceptor(ctx, in, info, handler)
  2442. }
  2443. func _VolumeServer_VolumeIncrementalCopy_Handler(srv interface{}, stream grpc.ServerStream) error {
  2444. m := new(VolumeIncrementalCopyRequest)
  2445. if err := stream.RecvMsg(m); err != nil {
  2446. return err
  2447. }
  2448. return srv.(VolumeServerServer).VolumeIncrementalCopy(m, &volumeServerVolumeIncrementalCopyServer{stream})
  2449. }
  2450. type VolumeServer_VolumeIncrementalCopyServer interface {
  2451. Send(*VolumeIncrementalCopyResponse) error
  2452. grpc.ServerStream
  2453. }
  2454. type volumeServerVolumeIncrementalCopyServer struct {
  2455. grpc.ServerStream
  2456. }
  2457. func (x *volumeServerVolumeIncrementalCopyServer) Send(m *VolumeIncrementalCopyResponse) error {
  2458. return x.ServerStream.SendMsg(m)
  2459. }
  2460. func _VolumeServer_VolumeMount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2461. in := new(VolumeMountRequest)
  2462. if err := dec(in); err != nil {
  2463. return nil, err
  2464. }
  2465. if interceptor == nil {
  2466. return srv.(VolumeServerServer).VolumeMount(ctx, in)
  2467. }
  2468. info := &grpc.UnaryServerInfo{
  2469. Server: srv,
  2470. FullMethod: "/volume_server_pb.VolumeServer/VolumeMount",
  2471. }
  2472. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2473. return srv.(VolumeServerServer).VolumeMount(ctx, req.(*VolumeMountRequest))
  2474. }
  2475. return interceptor(ctx, in, info, handler)
  2476. }
  2477. func _VolumeServer_VolumeUnmount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2478. in := new(VolumeUnmountRequest)
  2479. if err := dec(in); err != nil {
  2480. return nil, err
  2481. }
  2482. if interceptor == nil {
  2483. return srv.(VolumeServerServer).VolumeUnmount(ctx, in)
  2484. }
  2485. info := &grpc.UnaryServerInfo{
  2486. Server: srv,
  2487. FullMethod: "/volume_server_pb.VolumeServer/VolumeUnmount",
  2488. }
  2489. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2490. return srv.(VolumeServerServer).VolumeUnmount(ctx, req.(*VolumeUnmountRequest))
  2491. }
  2492. return interceptor(ctx, in, info, handler)
  2493. }
  2494. func _VolumeServer_VolumeDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2495. in := new(VolumeDeleteRequest)
  2496. if err := dec(in); err != nil {
  2497. return nil, err
  2498. }
  2499. if interceptor == nil {
  2500. return srv.(VolumeServerServer).VolumeDelete(ctx, in)
  2501. }
  2502. info := &grpc.UnaryServerInfo{
  2503. Server: srv,
  2504. FullMethod: "/volume_server_pb.VolumeServer/VolumeDelete",
  2505. }
  2506. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2507. return srv.(VolumeServerServer).VolumeDelete(ctx, req.(*VolumeDeleteRequest))
  2508. }
  2509. return interceptor(ctx, in, info, handler)
  2510. }
  2511. func _VolumeServer_VolumeMarkReadonly_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2512. in := new(VolumeMarkReadonlyRequest)
  2513. if err := dec(in); err != nil {
  2514. return nil, err
  2515. }
  2516. if interceptor == nil {
  2517. return srv.(VolumeServerServer).VolumeMarkReadonly(ctx, in)
  2518. }
  2519. info := &grpc.UnaryServerInfo{
  2520. Server: srv,
  2521. FullMethod: "/volume_server_pb.VolumeServer/VolumeMarkReadonly",
  2522. }
  2523. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2524. return srv.(VolumeServerServer).VolumeMarkReadonly(ctx, req.(*VolumeMarkReadonlyRequest))
  2525. }
  2526. return interceptor(ctx, in, info, handler)
  2527. }
  2528. func _VolumeServer_VolumeConfigure_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2529. in := new(VolumeConfigureRequest)
  2530. if err := dec(in); err != nil {
  2531. return nil, err
  2532. }
  2533. if interceptor == nil {
  2534. return srv.(VolumeServerServer).VolumeConfigure(ctx, in)
  2535. }
  2536. info := &grpc.UnaryServerInfo{
  2537. Server: srv,
  2538. FullMethod: "/volume_server_pb.VolumeServer/VolumeConfigure",
  2539. }
  2540. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2541. return srv.(VolumeServerServer).VolumeConfigure(ctx, req.(*VolumeConfigureRequest))
  2542. }
  2543. return interceptor(ctx, in, info, handler)
  2544. }
  2545. func _VolumeServer_VolumeCopy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2546. in := new(VolumeCopyRequest)
  2547. if err := dec(in); err != nil {
  2548. return nil, err
  2549. }
  2550. if interceptor == nil {
  2551. return srv.(VolumeServerServer).VolumeCopy(ctx, in)
  2552. }
  2553. info := &grpc.UnaryServerInfo{
  2554. Server: srv,
  2555. FullMethod: "/volume_server_pb.VolumeServer/VolumeCopy",
  2556. }
  2557. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2558. return srv.(VolumeServerServer).VolumeCopy(ctx, req.(*VolumeCopyRequest))
  2559. }
  2560. return interceptor(ctx, in, info, handler)
  2561. }
  2562. func _VolumeServer_ReadVolumeFileStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2563. in := new(ReadVolumeFileStatusRequest)
  2564. if err := dec(in); err != nil {
  2565. return nil, err
  2566. }
  2567. if interceptor == nil {
  2568. return srv.(VolumeServerServer).ReadVolumeFileStatus(ctx, in)
  2569. }
  2570. info := &grpc.UnaryServerInfo{
  2571. Server: srv,
  2572. FullMethod: "/volume_server_pb.VolumeServer/ReadVolumeFileStatus",
  2573. }
  2574. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2575. return srv.(VolumeServerServer).ReadVolumeFileStatus(ctx, req.(*ReadVolumeFileStatusRequest))
  2576. }
  2577. return interceptor(ctx, in, info, handler)
  2578. }
  2579. func _VolumeServer_CopyFile_Handler(srv interface{}, stream grpc.ServerStream) error {
  2580. m := new(CopyFileRequest)
  2581. if err := stream.RecvMsg(m); err != nil {
  2582. return err
  2583. }
  2584. return srv.(VolumeServerServer).CopyFile(m, &volumeServerCopyFileServer{stream})
  2585. }
  2586. type VolumeServer_CopyFileServer interface {
  2587. Send(*CopyFileResponse) error
  2588. grpc.ServerStream
  2589. }
  2590. type volumeServerCopyFileServer struct {
  2591. grpc.ServerStream
  2592. }
  2593. func (x *volumeServerCopyFileServer) Send(m *CopyFileResponse) error {
  2594. return x.ServerStream.SendMsg(m)
  2595. }
  2596. func _VolumeServer_VolumeTailSender_Handler(srv interface{}, stream grpc.ServerStream) error {
  2597. m := new(VolumeTailSenderRequest)
  2598. if err := stream.RecvMsg(m); err != nil {
  2599. return err
  2600. }
  2601. return srv.(VolumeServerServer).VolumeTailSender(m, &volumeServerVolumeTailSenderServer{stream})
  2602. }
  2603. type VolumeServer_VolumeTailSenderServer interface {
  2604. Send(*VolumeTailSenderResponse) error
  2605. grpc.ServerStream
  2606. }
  2607. type volumeServerVolumeTailSenderServer struct {
  2608. grpc.ServerStream
  2609. }
  2610. func (x *volumeServerVolumeTailSenderServer) Send(m *VolumeTailSenderResponse) error {
  2611. return x.ServerStream.SendMsg(m)
  2612. }
  2613. func _VolumeServer_VolumeTailReceiver_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2614. in := new(VolumeTailReceiverRequest)
  2615. if err := dec(in); err != nil {
  2616. return nil, err
  2617. }
  2618. if interceptor == nil {
  2619. return srv.(VolumeServerServer).VolumeTailReceiver(ctx, in)
  2620. }
  2621. info := &grpc.UnaryServerInfo{
  2622. Server: srv,
  2623. FullMethod: "/volume_server_pb.VolumeServer/VolumeTailReceiver",
  2624. }
  2625. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2626. return srv.(VolumeServerServer).VolumeTailReceiver(ctx, req.(*VolumeTailReceiverRequest))
  2627. }
  2628. return interceptor(ctx, in, info, handler)
  2629. }
  2630. func _VolumeServer_VolumeEcShardsGenerate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2631. in := new(VolumeEcShardsGenerateRequest)
  2632. if err := dec(in); err != nil {
  2633. return nil, err
  2634. }
  2635. if interceptor == nil {
  2636. return srv.(VolumeServerServer).VolumeEcShardsGenerate(ctx, in)
  2637. }
  2638. info := &grpc.UnaryServerInfo{
  2639. Server: srv,
  2640. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsGenerate",
  2641. }
  2642. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2643. return srv.(VolumeServerServer).VolumeEcShardsGenerate(ctx, req.(*VolumeEcShardsGenerateRequest))
  2644. }
  2645. return interceptor(ctx, in, info, handler)
  2646. }
  2647. func _VolumeServer_VolumeEcShardsRebuild_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2648. in := new(VolumeEcShardsRebuildRequest)
  2649. if err := dec(in); err != nil {
  2650. return nil, err
  2651. }
  2652. if interceptor == nil {
  2653. return srv.(VolumeServerServer).VolumeEcShardsRebuild(ctx, in)
  2654. }
  2655. info := &grpc.UnaryServerInfo{
  2656. Server: srv,
  2657. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsRebuild",
  2658. }
  2659. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2660. return srv.(VolumeServerServer).VolumeEcShardsRebuild(ctx, req.(*VolumeEcShardsRebuildRequest))
  2661. }
  2662. return interceptor(ctx, in, info, handler)
  2663. }
  2664. func _VolumeServer_VolumeEcShardsCopy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2665. in := new(VolumeEcShardsCopyRequest)
  2666. if err := dec(in); err != nil {
  2667. return nil, err
  2668. }
  2669. if interceptor == nil {
  2670. return srv.(VolumeServerServer).VolumeEcShardsCopy(ctx, in)
  2671. }
  2672. info := &grpc.UnaryServerInfo{
  2673. Server: srv,
  2674. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsCopy",
  2675. }
  2676. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2677. return srv.(VolumeServerServer).VolumeEcShardsCopy(ctx, req.(*VolumeEcShardsCopyRequest))
  2678. }
  2679. return interceptor(ctx, in, info, handler)
  2680. }
  2681. func _VolumeServer_VolumeEcShardsDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2682. in := new(VolumeEcShardsDeleteRequest)
  2683. if err := dec(in); err != nil {
  2684. return nil, err
  2685. }
  2686. if interceptor == nil {
  2687. return srv.(VolumeServerServer).VolumeEcShardsDelete(ctx, in)
  2688. }
  2689. info := &grpc.UnaryServerInfo{
  2690. Server: srv,
  2691. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsDelete",
  2692. }
  2693. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2694. return srv.(VolumeServerServer).VolumeEcShardsDelete(ctx, req.(*VolumeEcShardsDeleteRequest))
  2695. }
  2696. return interceptor(ctx, in, info, handler)
  2697. }
  2698. func _VolumeServer_VolumeEcShardsMount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2699. in := new(VolumeEcShardsMountRequest)
  2700. if err := dec(in); err != nil {
  2701. return nil, err
  2702. }
  2703. if interceptor == nil {
  2704. return srv.(VolumeServerServer).VolumeEcShardsMount(ctx, in)
  2705. }
  2706. info := &grpc.UnaryServerInfo{
  2707. Server: srv,
  2708. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsMount",
  2709. }
  2710. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2711. return srv.(VolumeServerServer).VolumeEcShardsMount(ctx, req.(*VolumeEcShardsMountRequest))
  2712. }
  2713. return interceptor(ctx, in, info, handler)
  2714. }
  2715. func _VolumeServer_VolumeEcShardsUnmount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2716. in := new(VolumeEcShardsUnmountRequest)
  2717. if err := dec(in); err != nil {
  2718. return nil, err
  2719. }
  2720. if interceptor == nil {
  2721. return srv.(VolumeServerServer).VolumeEcShardsUnmount(ctx, in)
  2722. }
  2723. info := &grpc.UnaryServerInfo{
  2724. Server: srv,
  2725. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsUnmount",
  2726. }
  2727. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2728. return srv.(VolumeServerServer).VolumeEcShardsUnmount(ctx, req.(*VolumeEcShardsUnmountRequest))
  2729. }
  2730. return interceptor(ctx, in, info, handler)
  2731. }
  2732. func _VolumeServer_VolumeEcShardRead_Handler(srv interface{}, stream grpc.ServerStream) error {
  2733. m := new(VolumeEcShardReadRequest)
  2734. if err := stream.RecvMsg(m); err != nil {
  2735. return err
  2736. }
  2737. return srv.(VolumeServerServer).VolumeEcShardRead(m, &volumeServerVolumeEcShardReadServer{stream})
  2738. }
  2739. type VolumeServer_VolumeEcShardReadServer interface {
  2740. Send(*VolumeEcShardReadResponse) error
  2741. grpc.ServerStream
  2742. }
  2743. type volumeServerVolumeEcShardReadServer struct {
  2744. grpc.ServerStream
  2745. }
  2746. func (x *volumeServerVolumeEcShardReadServer) Send(m *VolumeEcShardReadResponse) error {
  2747. return x.ServerStream.SendMsg(m)
  2748. }
  2749. func _VolumeServer_VolumeEcBlobDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2750. in := new(VolumeEcBlobDeleteRequest)
  2751. if err := dec(in); err != nil {
  2752. return nil, err
  2753. }
  2754. if interceptor == nil {
  2755. return srv.(VolumeServerServer).VolumeEcBlobDelete(ctx, in)
  2756. }
  2757. info := &grpc.UnaryServerInfo{
  2758. Server: srv,
  2759. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcBlobDelete",
  2760. }
  2761. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2762. return srv.(VolumeServerServer).VolumeEcBlobDelete(ctx, req.(*VolumeEcBlobDeleteRequest))
  2763. }
  2764. return interceptor(ctx, in, info, handler)
  2765. }
  2766. func _VolumeServer_VolumeEcShardsToVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2767. in := new(VolumeEcShardsToVolumeRequest)
  2768. if err := dec(in); err != nil {
  2769. return nil, err
  2770. }
  2771. if interceptor == nil {
  2772. return srv.(VolumeServerServer).VolumeEcShardsToVolume(ctx, in)
  2773. }
  2774. info := &grpc.UnaryServerInfo{
  2775. Server: srv,
  2776. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsToVolume",
  2777. }
  2778. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2779. return srv.(VolumeServerServer).VolumeEcShardsToVolume(ctx, req.(*VolumeEcShardsToVolumeRequest))
  2780. }
  2781. return interceptor(ctx, in, info, handler)
  2782. }
  2783. func _VolumeServer_VolumeTierMoveDatToRemote_Handler(srv interface{}, stream grpc.ServerStream) error {
  2784. m := new(VolumeTierMoveDatToRemoteRequest)
  2785. if err := stream.RecvMsg(m); err != nil {
  2786. return err
  2787. }
  2788. return srv.(VolumeServerServer).VolumeTierMoveDatToRemote(m, &volumeServerVolumeTierMoveDatToRemoteServer{stream})
  2789. }
  2790. type VolumeServer_VolumeTierMoveDatToRemoteServer interface {
  2791. Send(*VolumeTierMoveDatToRemoteResponse) error
  2792. grpc.ServerStream
  2793. }
  2794. type volumeServerVolumeTierMoveDatToRemoteServer struct {
  2795. grpc.ServerStream
  2796. }
  2797. func (x *volumeServerVolumeTierMoveDatToRemoteServer) Send(m *VolumeTierMoveDatToRemoteResponse) error {
  2798. return x.ServerStream.SendMsg(m)
  2799. }
  2800. func _VolumeServer_VolumeTierMoveDatFromRemote_Handler(srv interface{}, stream grpc.ServerStream) error {
  2801. m := new(VolumeTierMoveDatFromRemoteRequest)
  2802. if err := stream.RecvMsg(m); err != nil {
  2803. return err
  2804. }
  2805. return srv.(VolumeServerServer).VolumeTierMoveDatFromRemote(m, &volumeServerVolumeTierMoveDatFromRemoteServer{stream})
  2806. }
  2807. type VolumeServer_VolumeTierMoveDatFromRemoteServer interface {
  2808. Send(*VolumeTierMoveDatFromRemoteResponse) error
  2809. grpc.ServerStream
  2810. }
  2811. type volumeServerVolumeTierMoveDatFromRemoteServer struct {
  2812. grpc.ServerStream
  2813. }
  2814. func (x *volumeServerVolumeTierMoveDatFromRemoteServer) Send(m *VolumeTierMoveDatFromRemoteResponse) error {
  2815. return x.ServerStream.SendMsg(m)
  2816. }
  2817. func _VolumeServer_Query_Handler(srv interface{}, stream grpc.ServerStream) error {
  2818. m := new(QueryRequest)
  2819. if err := stream.RecvMsg(m); err != nil {
  2820. return err
  2821. }
  2822. return srv.(VolumeServerServer).Query(m, &volumeServerQueryServer{stream})
  2823. }
  2824. type VolumeServer_QueryServer interface {
  2825. Send(*QueriedStripe) error
  2826. grpc.ServerStream
  2827. }
  2828. type volumeServerQueryServer struct {
  2829. grpc.ServerStream
  2830. }
  2831. func (x *volumeServerQueryServer) Send(m *QueriedStripe) error {
  2832. return x.ServerStream.SendMsg(m)
  2833. }
  2834. var _VolumeServer_serviceDesc = grpc.ServiceDesc{
  2835. ServiceName: "volume_server_pb.VolumeServer",
  2836. HandlerType: (*VolumeServerServer)(nil),
  2837. Methods: []grpc.MethodDesc{
  2838. {
  2839. MethodName: "BatchDelete",
  2840. Handler: _VolumeServer_BatchDelete_Handler,
  2841. },
  2842. {
  2843. MethodName: "VacuumVolumeCheck",
  2844. Handler: _VolumeServer_VacuumVolumeCheck_Handler,
  2845. },
  2846. {
  2847. MethodName: "VacuumVolumeCompact",
  2848. Handler: _VolumeServer_VacuumVolumeCompact_Handler,
  2849. },
  2850. {
  2851. MethodName: "VacuumVolumeCommit",
  2852. Handler: _VolumeServer_VacuumVolumeCommit_Handler,
  2853. },
  2854. {
  2855. MethodName: "VacuumVolumeCleanup",
  2856. Handler: _VolumeServer_VacuumVolumeCleanup_Handler,
  2857. },
  2858. {
  2859. MethodName: "DeleteCollection",
  2860. Handler: _VolumeServer_DeleteCollection_Handler,
  2861. },
  2862. {
  2863. MethodName: "AllocateVolume",
  2864. Handler: _VolumeServer_AllocateVolume_Handler,
  2865. },
  2866. {
  2867. MethodName: "VolumeSyncStatus",
  2868. Handler: _VolumeServer_VolumeSyncStatus_Handler,
  2869. },
  2870. {
  2871. MethodName: "VolumeMount",
  2872. Handler: _VolumeServer_VolumeMount_Handler,
  2873. },
  2874. {
  2875. MethodName: "VolumeUnmount",
  2876. Handler: _VolumeServer_VolumeUnmount_Handler,
  2877. },
  2878. {
  2879. MethodName: "VolumeDelete",
  2880. Handler: _VolumeServer_VolumeDelete_Handler,
  2881. },
  2882. {
  2883. MethodName: "VolumeMarkReadonly",
  2884. Handler: _VolumeServer_VolumeMarkReadonly_Handler,
  2885. },
  2886. {
  2887. MethodName: "VolumeConfigure",
  2888. Handler: _VolumeServer_VolumeConfigure_Handler,
  2889. },
  2890. {
  2891. MethodName: "VolumeCopy",
  2892. Handler: _VolumeServer_VolumeCopy_Handler,
  2893. },
  2894. {
  2895. MethodName: "ReadVolumeFileStatus",
  2896. Handler: _VolumeServer_ReadVolumeFileStatus_Handler,
  2897. },
  2898. {
  2899. MethodName: "VolumeTailReceiver",
  2900. Handler: _VolumeServer_VolumeTailReceiver_Handler,
  2901. },
  2902. {
  2903. MethodName: "VolumeEcShardsGenerate",
  2904. Handler: _VolumeServer_VolumeEcShardsGenerate_Handler,
  2905. },
  2906. {
  2907. MethodName: "VolumeEcShardsRebuild",
  2908. Handler: _VolumeServer_VolumeEcShardsRebuild_Handler,
  2909. },
  2910. {
  2911. MethodName: "VolumeEcShardsCopy",
  2912. Handler: _VolumeServer_VolumeEcShardsCopy_Handler,
  2913. },
  2914. {
  2915. MethodName: "VolumeEcShardsDelete",
  2916. Handler: _VolumeServer_VolumeEcShardsDelete_Handler,
  2917. },
  2918. {
  2919. MethodName: "VolumeEcShardsMount",
  2920. Handler: _VolumeServer_VolumeEcShardsMount_Handler,
  2921. },
  2922. {
  2923. MethodName: "VolumeEcShardsUnmount",
  2924. Handler: _VolumeServer_VolumeEcShardsUnmount_Handler,
  2925. },
  2926. {
  2927. MethodName: "VolumeEcBlobDelete",
  2928. Handler: _VolumeServer_VolumeEcBlobDelete_Handler,
  2929. },
  2930. {
  2931. MethodName: "VolumeEcShardsToVolume",
  2932. Handler: _VolumeServer_VolumeEcShardsToVolume_Handler,
  2933. },
  2934. },
  2935. Streams: []grpc.StreamDesc{
  2936. {
  2937. StreamName: "VolumeIncrementalCopy",
  2938. Handler: _VolumeServer_VolumeIncrementalCopy_Handler,
  2939. ServerStreams: true,
  2940. },
  2941. {
  2942. StreamName: "CopyFile",
  2943. Handler: _VolumeServer_CopyFile_Handler,
  2944. ServerStreams: true,
  2945. },
  2946. {
  2947. StreamName: "VolumeTailSender",
  2948. Handler: _VolumeServer_VolumeTailSender_Handler,
  2949. ServerStreams: true,
  2950. },
  2951. {
  2952. StreamName: "VolumeEcShardRead",
  2953. Handler: _VolumeServer_VolumeEcShardRead_Handler,
  2954. ServerStreams: true,
  2955. },
  2956. {
  2957. StreamName: "VolumeTierMoveDatToRemote",
  2958. Handler: _VolumeServer_VolumeTierMoveDatToRemote_Handler,
  2959. ServerStreams: true,
  2960. },
  2961. {
  2962. StreamName: "VolumeTierMoveDatFromRemote",
  2963. Handler: _VolumeServer_VolumeTierMoveDatFromRemote_Handler,
  2964. ServerStreams: true,
  2965. },
  2966. {
  2967. StreamName: "Query",
  2968. Handler: _VolumeServer_Query_Handler,
  2969. ServerStreams: true,
  2970. },
  2971. },
  2972. Metadata: "volume_server.proto",
  2973. }
  2974. func init() { proto.RegisterFile("volume_server.proto", fileDescriptor0) }
  2975. var fileDescriptor0 = []byte{
  2976. // 2959 bytes of a gzipped FileDescriptorProto
  2977. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xd4, 0x5a, 0x4b, 0x73, 0xdc, 0xc6,
  2978. 0x11, 0xe6, 0x72, 0xf9, 0xd8, 0xed, 0x5d, 0x8a, 0xd4, 0x90, 0xa6, 0xd6, 0x20, 0x25, 0xd1, 0x90,
  2979. 0x1f, 0xa4, 0x6c, 0x91, 0x32, 0x6d, 0xc7, 0x8e, 0x1d, 0x3b, 0x91, 0x28, 0x29, 0x51, 0x6c, 0x51,
  2980. 0x36, 0x28, 0xcb, 0x4e, 0xec, 0x0a, 0x0a, 0x04, 0x66, 0x45, 0x98, 0x00, 0x06, 0x02, 0x66, 0x69,
  2981. 0xae, 0xca, 0x39, 0x39, 0x87, 0x54, 0xa5, 0x92, 0x43, 0x2a, 0x97, 0x9c, 0x73, 0xf7, 0x35, 0x7f,
  2982. 0xc1, 0x7f, 0x20, 0x55, 0x39, 0xe5, 0x92, 0x73, 0x0e, 0xb9, 0xa5, 0x2a, 0x97, 0xd4, 0xbc, 0xb0,
  2983. 0x78, 0x72, 0x41, 0x8b, 0xa9, 0x54, 0x6e, 0x83, 0x9e, 0x9e, 0xee, 0x99, 0x9e, 0xee, 0x9e, 0xe9,
  2984. 0xf9, 0x00, 0x8b, 0x47, 0xc4, 0x1b, 0xf8, 0xd8, 0x8c, 0x71, 0x74, 0x84, 0xa3, 0xcd, 0x30, 0x22,
  2985. 0x94, 0xa0, 0x85, 0x0c, 0xd1, 0x0c, 0xf7, 0xf5, 0x2d, 0x40, 0x37, 0x2d, 0x6a, 0x1f, 0xdc, 0xc2,
  2986. 0x1e, 0xa6, 0xd8, 0xc0, 0x8f, 0x07, 0x38, 0xa6, 0xe8, 0x59, 0x68, 0xf5, 0x5d, 0x0f, 0x9b, 0xae,
  2987. 0x13, 0xf7, 0x1a, 0x6b, 0xcd, 0xf5, 0xb6, 0x31, 0xcb, 0xbe, 0xef, 0x3a, 0xb1, 0x7e, 0x1f, 0x16,
  2988. 0x33, 0x03, 0xe2, 0x90, 0x04, 0x31, 0x46, 0x6f, 0xc1, 0x6c, 0x84, 0xe3, 0x81, 0x47, 0xc5, 0x80,
  2989. 0xce, 0xf6, 0xa5, 0xcd, 0xbc, 0xae, 0xcd, 0x64, 0xc8, 0xc0, 0xa3, 0x86, 0x62, 0xd7, 0xbf, 0x6e,
  2990. 0x40, 0x37, 0xdd, 0x83, 0x2e, 0xc0, 0xac, 0x54, 0xde, 0x6b, 0xac, 0x35, 0xd6, 0xdb, 0xc6, 0x8c,
  2991. 0xd0, 0x8d, 0x96, 0x61, 0x26, 0xa6, 0x16, 0x1d, 0xc4, 0xbd, 0xc9, 0xb5, 0xc6, 0xfa, 0xb4, 0x21,
  2992. 0xbf, 0xd0, 0x12, 0x4c, 0xe3, 0x28, 0x22, 0x51, 0xaf, 0xc9, 0xd9, 0xc5, 0x07, 0x42, 0x30, 0x15,
  2993. 0xbb, 0x4f, 0x70, 0x6f, 0x6a, 0xad, 0xb1, 0x3e, 0x67, 0xf0, 0x36, 0xea, 0xc1, 0xec, 0x11, 0x8e,
  2994. 0x62, 0x97, 0x04, 0xbd, 0x69, 0x4e, 0x56, 0x9f, 0xfa, 0x2c, 0x4c, 0xdf, 0xf6, 0x43, 0x3a, 0xd4,
  2995. 0xdf, 0x84, 0xde, 0x43, 0xcb, 0x1e, 0x0c, 0xfc, 0x87, 0x7c, 0xfa, 0x3b, 0x07, 0xd8, 0x3e, 0x54,
  2996. 0x66, 0x59, 0x81, 0xb6, 0x5c, 0x94, 0x9c, 0xdb, 0x9c, 0xd1, 0x12, 0x84, 0xbb, 0x8e, 0xfe, 0x23,
  2997. 0x78, 0xb6, 0x64, 0xa0, 0x34, 0xcf, 0x15, 0x98, 0x7b, 0x64, 0x45, 0xfb, 0xd6, 0x23, 0x6c, 0x46,
  2998. 0x16, 0x75, 0x09, 0x1f, 0xdd, 0x30, 0xba, 0x92, 0x68, 0x30, 0x9a, 0xfe, 0x19, 0x68, 0x19, 0x09,
  2999. 0xc4, 0x0f, 0x2d, 0x9b, 0xd6, 0x51, 0x8e, 0xd6, 0xa0, 0x13, 0x46, 0xd8, 0xf2, 0x3c, 0x62, 0x5b,
  3000. 0x14, 0x73, 0xfb, 0x34, 0x8d, 0x34, 0x49, 0xbf, 0x08, 0x2b, 0xa5, 0xc2, 0xc5, 0x04, 0xf5, 0xb7,
  3001. 0x72, 0xb3, 0x27, 0xbe, 0xef, 0xd6, 0x52, 0xad, 0xaf, 0x16, 0x66, 0xcd, 0x47, 0x4a, 0xb9, 0xdf,
  3002. 0xcf, 0xf5, 0x7a, 0xd8, 0x0a, 0x06, 0x61, 0x2d, 0xc1, 0xf9, 0x19, 0xab, 0xa1, 0x89, 0xe4, 0x0b,
  3003. 0xc2, 0x6d, 0x76, 0x88, 0xe7, 0x61, 0x9b, 0xba, 0x24, 0x50, 0x62, 0x2f, 0x01, 0xd8, 0x09, 0x51,
  3004. 0x3a, 0x51, 0x8a, 0xa2, 0x6b, 0xd0, 0x2b, 0x0e, 0x95, 0x62, 0xff, 0xd6, 0x80, 0x67, 0x6e, 0x48,
  3005. 0xa3, 0x09, 0xc5, 0xb5, 0x36, 0x20, 0xab, 0x72, 0x32, 0xaf, 0x32, 0xbf, 0x41, 0xcd, 0xc2, 0x06,
  3006. 0x31, 0x8e, 0x08, 0x87, 0x9e, 0x6b, 0x5b, 0x5c, 0xc4, 0x14, 0x17, 0x91, 0x26, 0xa1, 0x05, 0x68,
  3007. 0x52, 0xea, 0x71, 0xcf, 0x6d, 0x1b, 0xac, 0x89, 0xb6, 0x61, 0xd9, 0xc7, 0x3e, 0x89, 0x86, 0xa6,
  3008. 0x6f, 0x85, 0xa6, 0x6f, 0x1d, 0x9b, 0xcc, 0xcd, 0x4d, 0x7f, 0xbf, 0x37, 0xc3, 0xe7, 0x87, 0x44,
  3009. 0xef, 0x3d, 0x2b, 0xbc, 0x67, 0x1d, 0xef, 0xb9, 0x4f, 0xf0, 0xbd, 0x7d, 0xbd, 0x07, 0xcb, 0xf9,
  3010. 0xf5, 0xc9, 0xa5, 0x7f, 0x0f, 0x2e, 0x08, 0xca, 0xde, 0x30, 0xb0, 0xf7, 0x78, 0x6c, 0xd5, 0xda,
  3011. 0xa8, 0x7f, 0x37, 0xa0, 0x57, 0x1c, 0x28, 0x3d, 0xff, 0x69, 0xad, 0x76, 0x6a, 0x9b, 0x5c, 0x86,
  3012. 0x0e, 0xb5, 0x5c, 0xcf, 0x24, 0xfd, 0x7e, 0x8c, 0x29, 0x37, 0xc4, 0x94, 0x01, 0x8c, 0x74, 0x9f,
  3013. 0x53, 0xd0, 0x06, 0x2c, 0xd8, 0xc2, 0xfb, 0xcd, 0x08, 0x1f, 0xb9, 0x3c, 0x1b, 0xcc, 0xf2, 0x89,
  3014. 0xcd, 0xdb, 0x2a, 0x2a, 0x04, 0x19, 0xe9, 0x30, 0xe7, 0x3a, 0xc7, 0x26, 0x4f, 0x47, 0x3c, 0x99,
  3015. 0xb4, 0xb8, 0xb4, 0x8e, 0xeb, 0x1c, 0xdf, 0x71, 0x3d, 0xcc, 0x2c, 0xaa, 0x3f, 0x84, 0x55, 0xb1,
  3016. 0xf8, 0xbb, 0x81, 0x1d, 0x61, 0x1f, 0x07, 0xd4, 0xf2, 0x76, 0x48, 0x38, 0xac, 0xe5, 0x36, 0xcf,
  3017. 0x42, 0x2b, 0x76, 0x03, 0x1b, 0x9b, 0x81, 0x48, 0x6a, 0x53, 0xc6, 0x2c, 0xff, 0xde, 0x8d, 0xf5,
  3018. 0x9b, 0x70, 0xb1, 0x42, 0xae, 0xb4, 0xec, 0x73, 0xd0, 0xe5, 0x13, 0xb3, 0x49, 0x40, 0x71, 0x40,
  3019. 0xb9, 0xec, 0xae, 0xd1, 0x61, 0xb4, 0x1d, 0x41, 0xd2, 0x5f, 0x05, 0x24, 0x64, 0xdc, 0x23, 0x83,
  3020. 0xa0, 0x5e, 0x38, 0x3f, 0x03, 0x8b, 0x99, 0x21, 0xd2, 0x37, 0x5e, 0x83, 0x25, 0x41, 0xfe, 0x38,
  3021. 0xf0, 0x6b, 0xcb, 0xba, 0x00, 0xcf, 0xe4, 0x06, 0x49, 0x69, 0xdb, 0x4a, 0x49, 0xf6, 0xd8, 0x39,
  3022. 0x51, 0xd8, 0xb2, 0x9a, 0x41, 0xf6, 0xe4, 0xe1, 0x99, 0x4b, 0x4c, 0xd8, 0x8a, 0x0e, 0x0d, 0x6c,
  3023. 0x39, 0x24, 0xf0, 0x86, 0xb5, 0x33, 0x57, 0xc9, 0x48, 0x29, 0xf7, 0x13, 0x58, 0x56, 0x19, 0x2d,
  3024. 0xe8, 0xbb, 0x8f, 0x06, 0x11, 0xae, 0x9b, 0x89, 0xd3, 0x2e, 0x3b, 0x59, 0x70, 0x59, 0x7d, 0x4b,
  3025. 0x85, 0x59, 0x4a, 0xb0, 0xdc, 0xd2, 0xe4, 0x24, 0x6b, 0xa4, 0x4e, 0x32, 0xfd, 0x9b, 0x06, 0x9c,
  3026. 0x57, 0x23, 0x6a, 0xfa, 0xd5, 0x29, 0x03, 0xab, 0x59, 0x19, 0x58, 0x53, 0xa3, 0xc0, 0x5a, 0x87,
  3027. 0x85, 0x98, 0x0c, 0x22, 0x1b, 0x9b, 0x8e, 0x45, 0x2d, 0x33, 0x20, 0x0e, 0x96, 0x71, 0x77, 0x4e,
  3028. 0xd0, 0x6f, 0x59, 0xd4, 0xda, 0x25, 0x0e, 0xd6, 0x7f, 0xa8, 0xdc, 0x2e, 0xe3, 0xaf, 0x1b, 0x70,
  3029. 0xde, 0xb3, 0x62, 0x6a, 0x5a, 0x61, 0x88, 0x03, 0xc7, 0xb4, 0x28, 0x73, 0xfa, 0x06, 0x77, 0xfa,
  3030. 0x73, 0xac, 0xe3, 0x06, 0xa7, 0xdf, 0xa0, 0xbb, 0xb1, 0xfe, 0x87, 0x49, 0x98, 0x67, 0x63, 0x59,
  3031. 0x90, 0xd5, 0x5a, 0xef, 0x02, 0x34, 0xf1, 0x31, 0x95, 0x0b, 0x65, 0x4d, 0xb4, 0x05, 0x8b, 0x32,
  3032. 0x9a, 0x5d, 0x12, 0x8c, 0x02, 0xbd, 0x29, 0xf2, 0xe2, 0xa8, 0x2b, 0x89, 0xf5, 0xcb, 0xd0, 0x89,
  3033. 0x29, 0x09, 0x55, 0xde, 0x98, 0x12, 0x79, 0x83, 0x91, 0x64, 0xde, 0xc8, 0xda, 0x74, 0xba, 0xc4,
  3034. 0xa6, 0x5d, 0x37, 0x36, 0xb1, 0x6d, 0x8a, 0x59, 0xf1, 0xcc, 0xd3, 0x32, 0xc0, 0x8d, 0x6f, 0xdb,
  3035. 0xc2, 0x1a, 0xe8, 0x3d, 0x58, 0x75, 0x1f, 0x05, 0x24, 0xc2, 0xa6, 0x34, 0x24, 0x8f, 0xdf, 0x80,
  3036. 0x50, 0xb3, 0x4f, 0x06, 0x81, 0xc3, 0xb3, 0x50, 0xcb, 0xe8, 0x09, 0x9e, 0x3d, 0xce, 0xc2, 0x2c,
  3037. 0xb0, 0x4b, 0xe8, 0x1d, 0xd6, 0xaf, 0xbf, 0x01, 0x0b, 0x23, 0xab, 0xd4, 0xcf, 0x02, 0x5f, 0x37,
  3038. 0x94, 0xc7, 0x3d, 0xb0, 0x5c, 0x6f, 0x0f, 0x07, 0x0e, 0x8e, 0x9e, 0x32, 0x3b, 0xa1, 0xeb, 0xb0,
  3039. 0xe4, 0x3a, 0x1e, 0x36, 0xa9, 0xeb, 0x63, 0x32, 0xa0, 0x66, 0x8c, 0x6d, 0x12, 0x38, 0xb1, 0xb2,
  3040. 0x2f, 0xeb, 0x7b, 0x20, 0xba, 0xf6, 0x44, 0x8f, 0xfe, 0xab, 0xe4, 0x94, 0x48, 0xcf, 0x62, 0x74,
  3041. 0x3f, 0x0a, 0x30, 0x66, 0x02, 0x0f, 0xb0, 0xe5, 0xe0, 0x48, 0x2e, 0xa3, 0x2b, 0x88, 0x3f, 0xe1,
  3042. 0x34, 0xb6, 0x43, 0x92, 0x69, 0x9f, 0x38, 0x43, 0x3e, 0xa3, 0xae, 0x01, 0x82, 0x74, 0x93, 0x38,
  3043. 0x43, 0x9e, 0xae, 0x63, 0x93, 0x3b, 0x99, 0x7d, 0x30, 0x08, 0x0e, 0xf9, 0x6c, 0x5a, 0x46, 0xc7,
  3044. 0x8d, 0x3f, 0xb0, 0x62, 0xba, 0xc3, 0x48, 0xfa, 0x9f, 0x1b, 0x2a, 0x5f, 0xb0, 0x69, 0x18, 0xd8,
  3045. 0xc6, 0xee, 0xd1, 0xff, 0xc0, 0x1c, 0x6c, 0x84, 0x74, 0x82, 0xcc, 0x3d, 0x59, 0x06, 0x1c, 0x12,
  3046. 0x7d, 0xf2, 0x54, 0xe5, 0x3d, 0xa3, 0x74, 0x95, 0x9d, 0xb8, 0x4c, 0x57, 0x9f, 0xab, 0xe3, 0xe2,
  3047. 0xb6, 0xbd, 0x77, 0x60, 0x45, 0x4e, 0xfc, 0x63, 0x1c, 0xe0, 0xc8, 0xa2, 0x67, 0x72, 0x7d, 0xd1,
  3048. 0xd7, 0xe0, 0x52, 0x95, 0x74, 0xa9, 0xff, 0x33, 0x75, 0x0c, 0x2a, 0x0e, 0x03, 0xef, 0x0f, 0x5c,
  3049. 0xcf, 0x39, 0x13, 0xf5, 0xef, 0xe7, 0x17, 0x97, 0x08, 0x97, 0xfe, 0x73, 0x15, 0xce, 0x47, 0x9c,
  3050. 0x44, 0xcd, 0x98, 0x31, 0x24, 0x95, 0xcb, 0x9c, 0x31, 0x2f, 0x3b, 0xf8, 0x40, 0x56, 0xc1, 0xfc,
  3051. 0x66, 0x52, 0x79, 0x80, 0x92, 0x76, 0x66, 0x69, 0x75, 0x05, 0xda, 0x23, 0xf5, 0x4d, 0xae, 0xbe,
  3052. 0x15, 0x4b, 0xbd, 0xcc, 0x3b, 0x6d, 0x12, 0x0e, 0x4d, 0x6c, 0x8b, 0x1b, 0x05, 0xdf, 0xea, 0x96,
  3053. 0xd1, 0x61, 0xc4, 0xdb, 0x36, 0xbf, 0x50, 0xd4, 0xcf, 0xb1, 0x29, 0x69, 0x5f, 0x08, 0x69, 0x33,
  3054. 0x69, 0x69, 0x5f, 0x70, 0x69, 0x8a, 0xe7, 0xc8, 0xed, 0x0b, 0x9e, 0xd9, 0x11, 0xcf, 0x43, 0xb7,
  3055. 0xcf, 0x78, 0x46, 0x5e, 0x95, 0x35, 0x86, 0xdc, 0xd5, 0x2f, 0x61, 0x25, 0xdb, 0x5b, 0xff, 0xc0,
  3056. 0x7e, 0x2a, 0x63, 0xe9, 0x97, 0xf2, 0xee, 0x94, 0x3b, 0xf5, 0x8f, 0xf2, 0xd3, 0xae, 0x7d, 0xc3,
  3057. 0x79, 0xba, 0x79, 0x5d, 0xcc, 0x1b, 0x24, 0x7b, 0x4d, 0xfa, 0x34, 0x3f, 0xed, 0x53, 0x5c, 0x97,
  3058. 0x4e, 0x56, 0x7c, 0x39, 0x1f, 0x02, 0xf9, 0x3b, 0xd5, 0x1f, 0x93, 0xfc, 0x2a, 0x39, 0xd8, 0x8d,
  3059. 0xa6, 0x76, 0x5e, 0x93, 0x7a, 0xb9, 0x39, 0xe6, 0x8c, 0x59, 0xa9, 0x96, 0x95, 0xdc, 0xf2, 0x3c,
  3060. 0x14, 0x15, 0x8b, 0xfc, 0xca, 0x14, 0xd7, 0x4d, 0x59, 0x5c, 0xab, 0x47, 0x83, 0x43, 0x3c, 0xe4,
  3061. 0x3e, 0x3b, 0x25, 0x1e, 0x0d, 0xde, 0xc7, 0x43, 0x7d, 0x37, 0x17, 0x71, 0x62, 0x6a, 0x32, 0x76,
  3062. 0x11, 0x4c, 0x31, 0x67, 0x97, 0x29, 0x9f, 0xb7, 0xd1, 0x45, 0x00, 0x37, 0x36, 0x1d, 0xbe, 0xe7,
  3063. 0x62, 0x52, 0x2d, 0xa3, 0xed, 0x4a, 0x27, 0x70, 0xf4, 0xdf, 0x36, 0x46, 0x02, 0x6f, 0x7a, 0x64,
  3064. 0xff, 0x0c, 0xbd, 0x32, 0xbd, 0x8a, 0x66, 0x66, 0x15, 0xe9, 0xd7, 0x83, 0xa9, 0xec, 0xeb, 0x41,
  3065. 0x2a, 0x88, 0xd2, 0xd3, 0xa9, 0x4a, 0xcd, 0x0f, 0xc8, 0xd9, 0x55, 0x96, 0xc5, 0xd4, 0x3c, 0x92,
  3066. 0x2e, 0xf5, 0xbf, 0x0d, 0x2b, 0xcc, 0xe0, 0x82, 0xca, 0xeb, 0x96, 0xfa, 0xb5, 0xdd, 0x3f, 0x26,
  3067. 0x61, 0xb5, 0x7c, 0x70, 0x9d, 0xfa, 0xee, 0x1d, 0xd0, 0x92, 0xfa, 0x89, 0x1d, 0x8d, 0x31, 0xb5,
  3068. 0xfc, 0x30, 0x39, 0x1c, 0xc5, 0x19, 0x7a, 0x41, 0x16, 0x53, 0x0f, 0x54, 0xbf, 0x3a, 0x21, 0x0b,
  3069. 0xc5, 0x57, 0xb3, 0x50, 0x7c, 0x31, 0x05, 0x8e, 0x45, 0xab, 0x14, 0x88, 0x3b, 0xdc, 0x05, 0xc7,
  3070. 0xa2, 0x55, 0x0a, 0x92, 0xc1, 0x5c, 0x81, 0xf0, 0xda, 0x8e, 0xe4, 0xe7, 0x0a, 0x2e, 0x02, 0xc8,
  3071. 0xeb, 0xd5, 0x20, 0x50, 0xc5, 0x64, 0x5b, 0x5c, 0xae, 0x06, 0x41, 0xe5, 0x2d, 0x73, 0xb6, 0xf2,
  3072. 0x96, 0x99, 0xdd, 0xcd, 0x56, 0x61, 0x37, 0x3f, 0x05, 0xb8, 0xe5, 0xc6, 0x87, 0xc2, 0xc8, 0xec,
  3073. 0x5a, 0xeb, 0xb8, 0xaa, 0x1a, 0x60, 0x4d, 0x46, 0xb1, 0x3c, 0x4f, 0x9a, 0x8e, 0x35, 0x59, 0xf8,
  3074. 0x0c, 0x62, 0xec, 0x48, 0xeb, 0xf0, 0x36, 0xa3, 0xf5, 0x23, 0x8c, 0xa5, 0x01, 0x78, 0x5b, 0xff,
  3075. 0x53, 0x03, 0xda, 0xf7, 0xb0, 0x2f, 0x25, 0x5f, 0x02, 0x78, 0x44, 0x22, 0x32, 0xa0, 0x6e, 0x80,
  3076. 0xc5, 0x2d, 0x7c, 0xda, 0x48, 0x51, 0xbe, 0xbb, 0x1e, 0x9e, 0x1a, 0xb0, 0xd7, 0x97, 0xc6, 0xe4,
  3077. 0x6d, 0x46, 0x3b, 0xc0, 0x56, 0x28, 0xed, 0xc7, 0xdb, 0xac, 0xd6, 0x89, 0xa9, 0x65, 0x1f, 0x72,
  3078. 0x63, 0x4d, 0x19, 0xe2, 0x43, 0xff, 0x6b, 0x03, 0xc0, 0xc0, 0x3e, 0xa1, 0xdc, 0xd7, 0xd8, 0xed,
  3079. 0x76, 0xdf, 0xb2, 0x0f, 0x59, 0xbd, 0x40, 0x87, 0x21, 0x96, 0x96, 0xe8, 0x48, 0xda, 0x83, 0x61,
  3080. 0xc8, 0x77, 0x48, 0xb1, 0xc8, 0xfc, 0xd5, 0x36, 0xda, 0x92, 0x22, 0x2a, 0x03, 0x15, 0xca, 0x6d,
  3081. 0x83, 0x35, 0x53, 0x39, 0x4d, 0x4c, 0x5b, 0xe5, 0xb4, 0x15, 0x68, 0xe7, 0x5d, 0x81, 0xa7, 0x02,
  3082. 0xee, 0x07, 0x57, 0x60, 0xce, 0x27, 0x8e, 0xdb, 0x77, 0xb1, 0xc3, 0x1d, 0x4d, 0x2e, 0xa5, 0xab,
  3083. 0x88, 0xcc, 0xb9, 0xd0, 0x2a, 0xb4, 0xf1, 0x31, 0xc5, 0x41, 0xe2, 0x03, 0x6d, 0x63, 0x44, 0xd0,
  3084. 0xbf, 0x02, 0x50, 0x05, 0x7d, 0x9f, 0xa0, 0x6d, 0x98, 0x66, 0xc2, 0xd5, 0x73, 0xe9, 0x6a, 0xf1,
  3085. 0xb9, 0x74, 0x64, 0x06, 0x43, 0xb0, 0xa6, 0x13, 0xd0, 0x64, 0x26, 0x01, 0x8d, 0xaf, 0xe7, 0xf4,
  3086. 0x6f, 0x1b, 0xb0, 0x26, 0xaf, 0x8f, 0x2e, 0x8e, 0xee, 0x91, 0x23, 0x76, 0x95, 0x78, 0x40, 0x84,
  3087. 0x92, 0x33, 0xc9, 0x9c, 0x6f, 0x41, 0xcf, 0xc1, 0x31, 0x75, 0x03, 0xae, 0xd0, 0x54, 0x9b, 0x12,
  3088. 0x58, 0x3e, 0x96, 0x13, 0x5a, 0x4e, 0xf5, 0xdf, 0x14, 0xdd, 0xbb, 0x96, 0x8f, 0xd1, 0x35, 0x58,
  3089. 0x3c, 0xc4, 0x38, 0x34, 0x3d, 0x62, 0x5b, 0x9e, 0xa9, 0x62, 0x52, 0xde, 0x8f, 0x16, 0x58, 0xd7,
  3090. 0x07, 0xac, 0xe7, 0x96, 0x88, 0x4b, 0x3d, 0x86, 0xe7, 0x4e, 0x58, 0x89, 0xcc, 0x4b, 0xab, 0xd0,
  3091. 0x0e, 0x23, 0x62, 0xe3, 0x98, 0xf9, 0x6c, 0x83, 0x1f, 0x53, 0x23, 0x02, 0xba, 0x0e, 0x8b, 0xc9,
  3092. 0xc7, 0x87, 0x38, 0xb2, 0x71, 0x40, 0xad, 0x47, 0xe2, 0xdd, 0x74, 0xd2, 0x28, 0xeb, 0xd2, 0x7f,
  3093. 0xdf, 0x00, 0xbd, 0xa0, 0xf5, 0x4e, 0x44, 0xfc, 0x33, 0xb4, 0xe0, 0x16, 0x2c, 0x71, 0x3b, 0x44,
  3094. 0x5c, 0xe4, 0xc8, 0x10, 0xa2, 0x8c, 0x39, 0xcf, 0xfa, 0x84, 0x36, 0x65, 0x89, 0x01, 0x5c, 0x39,
  3095. 0x71, 0x4e, 0xff, 0x25, 0x5b, 0xfc, 0xab, 0x0b, 0xdd, 0x8f, 0x06, 0x38, 0x1a, 0xa6, 0x1e, 0x5c,
  3096. 0x63, 0x2c, 0x57, 0xa1, 0x10, 0x83, 0x14, 0x85, 0x65, 0xda, 0x7e, 0x44, 0x7c, 0x33, 0x01, 0x15,
  3097. 0x26, 0x39, 0x4b, 0x87, 0x11, 0xef, 0x08, 0x60, 0x01, 0xbd, 0x0b, 0x33, 0x7d, 0xd7, 0xa3, 0x58,
  3098. 0x3c, 0xe3, 0x77, 0xb6, 0x5f, 0x28, 0x46, 0x44, 0x5a, 0xe7, 0xe6, 0x1d, 0xce, 0x6c, 0xc8, 0x41,
  3099. 0x68, 0x1f, 0x16, 0xdd, 0x20, 0xe4, 0xa5, 0x57, 0xe4, 0x5a, 0x9e, 0xfb, 0x64, 0xf4, 0x64, 0xd8,
  3100. 0xd9, 0x7e, 0x75, 0x8c, 0xac, 0xbb, 0x6c, 0xe4, 0x5e, 0x7a, 0xa0, 0x81, 0xdc, 0x02, 0x0d, 0x61,
  3101. 0x58, 0x22, 0x03, 0x5a, 0x54, 0x32, 0xcd, 0x95, 0x6c, 0x8f, 0x51, 0x72, 0x9f, 0x0f, 0xcd, 0x6a,
  3102. 0x59, 0x24, 0x45, 0xa2, 0xb6, 0x0b, 0x33, 0x62, 0x71, 0x2c, 0x47, 0xf6, 0x5d, 0xec, 0x29, 0x20,
  3103. 0x44, 0x7c, 0xb0, 0x34, 0x40, 0x42, 0x1c, 0x59, 0x81, 0x4a, 0x77, 0xea, 0x93, 0xf1, 0x1f, 0x59,
  3104. 0xde, 0x40, 0xc5, 0x9b, 0xf8, 0xd0, 0xfe, 0x32, 0x0d, 0xa8, 0xb8, 0x42, 0xf5, 0x0e, 0x1a, 0xe1,
  3105. 0x98, 0xa5, 0x90, 0x74, 0x7e, 0x9d, 0x4f, 0xd1, 0x79, 0x8e, 0xfd, 0x04, 0xda, 0x76, 0x7c, 0x64,
  3106. 0x72, 0x93, 0x70, 0x9d, 0x9d, 0xed, 0xb7, 0x4f, 0x6d, 0xd2, 0xcd, 0x9d, 0xbd, 0x87, 0x9c, 0x6a,
  3107. 0xb4, 0xec, 0xf8, 0x88, 0xb7, 0xd0, 0xcf, 0x01, 0xbe, 0x88, 0x49, 0x20, 0x25, 0x8b, 0x8d, 0x7f,
  3108. 0xe7, 0xf4, 0x92, 0x7f, 0xba, 0x77, 0x7f, 0x57, 0x88, 0x6e, 0x33, 0x71, 0x42, 0xb6, 0x0d, 0x73,
  3109. 0xa1, 0x15, 0x3d, 0x1e, 0x60, 0x2a, 0xc5, 0x0b, 0x5f, 0x78, 0xef, 0xf4, 0xe2, 0x3f, 0x14, 0x62,
  3110. 0x84, 0x86, 0x6e, 0x98, 0xfa, 0xd2, 0xbe, 0x9d, 0x84, 0x96, 0x5a, 0x17, 0xab, 0xde, 0xb8, 0x87,
  3111. 0x8b, 0x37, 0x0c, 0xd3, 0x0d, 0xfa, 0x44, 0x5a, 0xf4, 0x1c, 0xa3, 0x8b, 0x67, 0x0c, 0x9e, 0xfd,
  3112. 0x37, 0x60, 0x21, 0xc2, 0x36, 0x89, 0x1c, 0x76, 0xc7, 0x75, 0x7d, 0x97, 0xb9, 0xbd, 0xd8, 0xcb,
  3113. 0x79, 0x41, 0xbf, 0xa5, 0xc8, 0xe8, 0x25, 0x98, 0xe7, 0xdb, 0x9e, 0xe2, 0x6c, 0x2a, 0x99, 0xd8,
  3114. 0x4b, 0x31, 0x6e, 0xc0, 0xc2, 0xe3, 0x01, 0xcb, 0x1b, 0xf6, 0x81, 0x15, 0x59, 0x36, 0x25, 0xc9,
  3115. 0x6b, 0xc2, 0x3c, 0xa7, 0xef, 0x24, 0x64, 0xf4, 0x3a, 0x2c, 0x0b, 0x56, 0x1c, 0xdb, 0x56, 0x98,
  3116. 0x8c, 0xc0, 0x91, 0x2c, 0x36, 0x97, 0x78, 0xef, 0x6d, 0xde, 0xb9, 0xa3, 0xfa, 0x90, 0x06, 0x2d,
  3117. 0x9b, 0xf8, 0x3e, 0x0e, 0x68, 0xcc, 0x8f, 0xbf, 0xb6, 0x91, 0x7c, 0xa3, 0x1b, 0x70, 0xd1, 0xf2,
  3118. 0x3c, 0xf2, 0xa5, 0xc9, 0x47, 0x3a, 0x66, 0x61, 0x75, 0xa2, 0xf4, 0xd4, 0x38, 0xd3, 0x47, 0x9c,
  3119. 0xc7, 0xc8, 0x2e, 0x54, 0xbb, 0x0c, 0xed, 0x64, 0x1f, 0xd9, 0x8d, 0x21, 0xe5, 0x90, 0xbc, 0xad,
  3120. 0x9d, 0x83, 0x6e, 0x7a, 0x27, 0xb4, 0x7f, 0x36, 0x61, 0xb1, 0x24, 0xa8, 0xd0, 0x67, 0x00, 0xcc,
  3121. 0x5b, 0x45, 0x68, 0x49, 0x77, 0xfd, 0xc1, 0xe9, 0x83, 0x93, 0xf9, 0xab, 0x20, 0x1b, 0xcc, 0xfb,
  3122. 0x45, 0x13, 0xfd, 0x02, 0x3a, 0xdc, 0x63, 0xa5, 0x74, 0xe1, 0xb2, 0xef, 0x7e, 0x07, 0xe9, 0x6c,
  3123. 0xad, 0x52, 0x3c, 0x8f, 0x01, 0xd1, 0xd6, 0xfe, 0xde, 0x80, 0x76, 0xa2, 0x98, 0xdd, 0x7f, 0xc4,
  3124. 0x46, 0xf1, 0xbd, 0x8e, 0xd5, 0xfd, 0x87, 0xd3, 0xee, 0x70, 0xd2, 0xff, 0xa5, 0x2b, 0x69, 0x6f,
  3125. 0x02, 0x8c, 0xd6, 0x5f, 0xba, 0x84, 0x46, 0xe9, 0x12, 0xf4, 0x0d, 0x98, 0x63, 0x96, 0x75, 0xb1,
  3126. 0xb3, 0x47, 0x23, 0x37, 0xe4, 0x90, 0xae, 0xe0, 0x89, 0x65, 0x01, 0xa9, 0x3e, 0xb7, 0xbf, 0x59,
  3127. 0x81, 0x6e, 0xfa, 0x01, 0x0d, 0x7d, 0x0e, 0x9d, 0x14, 0x74, 0x8d, 0x9e, 0x2f, 0x6e, 0x5a, 0x11,
  3128. 0x0a, 0xd7, 0x5e, 0x18, 0xc3, 0x25, 0x6b, 0xac, 0x09, 0x14, 0xc0, 0xf9, 0x02, 0xfe, 0x8b, 0xae,
  3129. 0x16, 0x47, 0x57, 0xa1, 0xcb, 0xda, 0xcb, 0xb5, 0x78, 0x13, 0x7d, 0x14, 0x16, 0x4b, 0x00, 0x5d,
  3130. 0xf4, 0xca, 0x18, 0x29, 0x19, 0x50, 0x59, 0xbb, 0x56, 0x93, 0x3b, 0xd1, 0xfa, 0x18, 0x50, 0x11,
  3131. 0xed, 0x45, 0x2f, 0x8f, 0x15, 0x33, 0x42, 0x93, 0xb5, 0x57, 0xea, 0x31, 0x57, 0x2e, 0x54, 0xe0,
  3132. 0xc0, 0x63, 0x17, 0x9a, 0x41, 0x9a, 0xc7, 0x2e, 0x34, 0x07, 0x2e, 0x4f, 0xa0, 0x43, 0x58, 0xc8,
  3133. 0x63, 0xc4, 0x68, 0xa3, 0xea, 0x9f, 0x86, 0x02, 0x04, 0xad, 0x5d, 0xad, 0xc3, 0x9a, 0x28, 0xc3,
  3134. 0x70, 0x2e, 0x8b, 0xc9, 0xa2, 0x97, 0x8a, 0xe3, 0x4b, 0x51, 0x69, 0x6d, 0x7d, 0x3c, 0x63, 0x7a,
  3135. 0x4d, 0x79, 0x9c, 0xb6, 0x6c, 0x4d, 0x15, 0x20, 0x70, 0xd9, 0x9a, 0xaa, 0x60, 0x5f, 0x7d, 0x02,
  3136. 0x7d, 0xa5, 0xc0, 0xbf, 0x1c, 0x7e, 0x89, 0x36, 0xab, 0xc4, 0x94, 0x03, 0xa8, 0xda, 0x56, 0x6d,
  3137. 0x7e, 0xa5, 0xfb, 0x7a, 0x83, 0xc5, 0x7a, 0x0a, 0xc6, 0x2c, 0x8b, 0xf5, 0x22, 0x30, 0x5a, 0x16,
  3138. 0xeb, 0x65, 0x58, 0xe8, 0x04, 0xda, 0x87, 0xb9, 0x0c, 0xb0, 0x89, 0x5e, 0xac, 0x1a, 0x99, 0x7d,
  3139. 0xff, 0xd3, 0x5e, 0x1a, 0xcb, 0x97, 0xe8, 0x30, 0x55, 0xf6, 0x92, 0xe9, 0xaa, 0x72, 0x72, 0xd9,
  3140. 0x7c, 0xf5, 0xe2, 0x38, 0xb6, 0x4c, 0x28, 0x17, 0xe0, 0xcf, 0xd2, 0x50, 0xae, 0x82, 0x57, 0x4b,
  3141. 0x43, 0xb9, 0x1a, 0x51, 0x9d, 0x40, 0x07, 0x30, 0x9f, 0x83, 0x3e, 0xd1, 0x7a, 0x95, 0x88, 0x3c,
  3142. 0xec, 0xaa, 0x6d, 0xd4, 0xe0, 0x4c, 0x34, 0xfd, 0x4c, 0x15, 0xdb, 0xdc, 0xe5, 0xae, 0x54, 0x0f,
  3143. 0x1d, 0xf9, 0xd9, 0xf3, 0x27, 0x33, 0x25, 0xa2, 0xbf, 0x84, 0xa5, 0xb2, 0x17, 0x31, 0x74, 0xad,
  3144. 0xac, 0x84, 0xaf, 0x7c, 0x76, 0xd3, 0x36, 0xeb, 0xb2, 0x27, 0x8a, 0x3f, 0x86, 0x96, 0x82, 0xff,
  3145. 0xd0, 0x73, 0xc5, 0xd1, 0x39, 0xc0, 0x54, 0xd3, 0x4f, 0x62, 0x49, 0x85, 0x8a, 0xaf, 0xb2, 0xc2,
  3146. 0x08, 0x97, 0xab, 0xce, 0x0a, 0x05, 0x04, 0xb1, 0x3a, 0x2b, 0x14, 0x61, 0x3e, 0xae, 0x2e, 0x71,
  3147. 0xbb, 0x34, 0x8c, 0x55, 0xed, 0x76, 0x25, 0x28, 0x5d, 0xb5, 0xdb, 0x95, 0x22, 0x63, 0x13, 0xe8,
  3148. 0x97, 0x0a, 0xca, 0xcf, 0xa3, 0x57, 0xa8, 0x32, 0xb7, 0x54, 0xa0, 0x68, 0xda, 0xf5, 0xfa, 0x03,
  3149. 0x12, 0xf5, 0x4f, 0x54, 0x26, 0xcc, 0xa1, 0x57, 0xd5, 0x99, 0xb0, 0x1c, 0x43, 0xd3, 0xb6, 0x6a,
  3150. 0xf3, 0x17, 0x83, 0x3c, 0x0d, 0xef, 0x54, 0x5b, 0xbb, 0x04, 0x11, 0xab, 0xb6, 0x76, 0x29, 0x62,
  3151. 0xc4, 0xe3, 0xa3, 0x0c, 0xba, 0x29, 0x8b, 0x8f, 0x13, 0xb0, 0x25, 0x6d, 0xb3, 0x2e, 0x7b, 0xe6,
  3152. 0xa2, 0x50, 0xc4, 0x66, 0xd0, 0xd8, 0xf9, 0x67, 0xce, 0x80, 0x6b, 0x35, 0xb9, 0xab, 0x77, 0x57,
  3153. 0x9d, 0x09, 0x63, 0x17, 0x90, 0x3b, 0x1b, 0xb6, 0x6a, 0xf3, 0x27, 0xba, 0x43, 0xf5, 0x63, 0x48,
  3154. 0x0a, 0x57, 0x41, 0x57, 0xc7, 0xc8, 0x49, 0xe1, 0x42, 0xda, 0xcb, 0xb5, 0x78, 0xcb, 0xa2, 0x37,
  3155. 0x8d, 0x74, 0x9c, 0xe4, 0x4f, 0x05, 0x78, 0xe6, 0x24, 0x7f, 0x2a, 0x01, 0x4f, 0x4a, 0xa2, 0x57,
  3156. 0x01, 0x1c, 0xe3, 0xa3, 0x37, 0x07, 0xb4, 0x8c, 0x8f, 0xde, 0x02, 0x76, 0x32, 0x81, 0x7e, 0x3d,
  3157. 0xfa, 0x61, 0xa0, 0xf8, 0xdc, 0x88, 0xb6, 0x2b, 0x53, 0x51, 0xe5, 0x2b, 0xab, 0xf6, 0xda, 0xa9,
  3158. 0xc6, 0xa4, 0x8c, 0xff, 0xbb, 0x86, 0x42, 0x1f, 0x4b, 0xdf, 0xfb, 0xd0, 0xeb, 0x35, 0x04, 0x17,
  3159. 0x9e, 0x2c, 0xb5, 0x37, 0x4e, 0x39, 0x2a, 0x35, 0xa1, 0x0f, 0x60, 0x9a, 0xd7, 0xb9, 0xe8, 0xd2,
  3160. 0xc9, 0x05, 0xb0, 0x76, 0xb9, 0xbc, 0x3f, 0x29, 0xe3, 0x98, 0xb4, 0xfd, 0x19, 0xfe, 0x93, 0xf2,
  3161. 0x6b, 0xff, 0x09, 0x00, 0x00, 0xff, 0xff, 0x66, 0x23, 0x9f, 0xad, 0xbb, 0x2c, 0x00, 0x00,
  3162. }