volume_server_grpc.pb.go 74 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. // versions:
  3. // - protoc-gen-go-grpc v1.2.0
  4. // - protoc v4.23.3
  5. // source: volume_server.proto
  6. package volume_server_pb
  7. import (
  8. context "context"
  9. grpc "google.golang.org/grpc"
  10. codes "google.golang.org/grpc/codes"
  11. status "google.golang.org/grpc/status"
  12. )
  13. // This is a compile-time assertion to ensure that this generated file
  14. // is compatible with the grpc package it is being compiled against.
  15. // Requires gRPC-Go v1.32.0 or later.
  16. const _ = grpc.SupportPackageIsVersion7
  17. // VolumeServerClient is the client API for VolumeServer service.
  18. //
  19. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
  20. type VolumeServerClient interface {
  21. // Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
  22. BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error)
  23. VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error)
  24. VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (VolumeServer_VacuumVolumeCompactClient, error)
  25. VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error)
  26. VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error)
  27. DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
  28. AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error)
  29. VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error)
  30. VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error)
  31. VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error)
  32. VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error)
  33. VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error)
  34. VolumeMarkReadonly(ctx context.Context, in *VolumeMarkReadonlyRequest, opts ...grpc.CallOption) (*VolumeMarkReadonlyResponse, error)
  35. VolumeMarkWritable(ctx context.Context, in *VolumeMarkWritableRequest, opts ...grpc.CallOption) (*VolumeMarkWritableResponse, error)
  36. VolumeConfigure(ctx context.Context, in *VolumeConfigureRequest, opts ...grpc.CallOption) (*VolumeConfigureResponse, error)
  37. VolumeStatus(ctx context.Context, in *VolumeStatusRequest, opts ...grpc.CallOption) (*VolumeStatusResponse, error)
  38. // copy the .idx .dat files, and mount this volume
  39. VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeCopyClient, error)
  40. ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error)
  41. CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error)
  42. ReadNeedleBlob(ctx context.Context, in *ReadNeedleBlobRequest, opts ...grpc.CallOption) (*ReadNeedleBlobResponse, error)
  43. ReadNeedleMeta(ctx context.Context, in *ReadNeedleMetaRequest, opts ...grpc.CallOption) (*ReadNeedleMetaResponse, error)
  44. WriteNeedleBlob(ctx context.Context, in *WriteNeedleBlobRequest, opts ...grpc.CallOption) (*WriteNeedleBlobResponse, error)
  45. ReadAllNeedles(ctx context.Context, in *ReadAllNeedlesRequest, opts ...grpc.CallOption) (VolumeServer_ReadAllNeedlesClient, error)
  46. VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error)
  47. VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error)
  48. // erasure coding
  49. VolumeEcShardsGenerate(ctx context.Context, in *VolumeEcShardsGenerateRequest, opts ...grpc.CallOption) (*VolumeEcShardsGenerateResponse, error)
  50. VolumeEcShardsRebuild(ctx context.Context, in *VolumeEcShardsRebuildRequest, opts ...grpc.CallOption) (*VolumeEcShardsRebuildResponse, error)
  51. VolumeEcShardsCopy(ctx context.Context, in *VolumeEcShardsCopyRequest, opts ...grpc.CallOption) (*VolumeEcShardsCopyResponse, error)
  52. VolumeEcShardsDelete(ctx context.Context, in *VolumeEcShardsDeleteRequest, opts ...grpc.CallOption) (*VolumeEcShardsDeleteResponse, error)
  53. VolumeEcShardsMount(ctx context.Context, in *VolumeEcShardsMountRequest, opts ...grpc.CallOption) (*VolumeEcShardsMountResponse, error)
  54. VolumeEcShardsUnmount(ctx context.Context, in *VolumeEcShardsUnmountRequest, opts ...grpc.CallOption) (*VolumeEcShardsUnmountResponse, error)
  55. VolumeEcShardRead(ctx context.Context, in *VolumeEcShardReadRequest, opts ...grpc.CallOption) (VolumeServer_VolumeEcShardReadClient, error)
  56. VolumeEcBlobDelete(ctx context.Context, in *VolumeEcBlobDeleteRequest, opts ...grpc.CallOption) (*VolumeEcBlobDeleteResponse, error)
  57. VolumeEcShardsToVolume(ctx context.Context, in *VolumeEcShardsToVolumeRequest, opts ...grpc.CallOption) (*VolumeEcShardsToVolumeResponse, error)
  58. // tiered storage
  59. VolumeTierMoveDatToRemote(ctx context.Context, in *VolumeTierMoveDatToRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatToRemoteClient, error)
  60. VolumeTierMoveDatFromRemote(ctx context.Context, in *VolumeTierMoveDatFromRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatFromRemoteClient, error)
  61. VolumeServerStatus(ctx context.Context, in *VolumeServerStatusRequest, opts ...grpc.CallOption) (*VolumeServerStatusResponse, error)
  62. VolumeServerLeave(ctx context.Context, in *VolumeServerLeaveRequest, opts ...grpc.CallOption) (*VolumeServerLeaveResponse, error)
  63. // remote storage
  64. FetchAndWriteNeedle(ctx context.Context, in *FetchAndWriteNeedleRequest, opts ...grpc.CallOption) (*FetchAndWriteNeedleResponse, error)
  65. // <experimental> query
  66. Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (VolumeServer_QueryClient, error)
  67. VolumeNeedleStatus(ctx context.Context, in *VolumeNeedleStatusRequest, opts ...grpc.CallOption) (*VolumeNeedleStatusResponse, error)
  68. Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
  69. }
  70. type volumeServerClient struct {
  71. cc grpc.ClientConnInterface
  72. }
  73. func NewVolumeServerClient(cc grpc.ClientConnInterface) VolumeServerClient {
  74. return &volumeServerClient{cc}
  75. }
  76. func (c *volumeServerClient) BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error) {
  77. out := new(BatchDeleteResponse)
  78. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/BatchDelete", in, out, opts...)
  79. if err != nil {
  80. return nil, err
  81. }
  82. return out, nil
  83. }
  84. func (c *volumeServerClient) VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error) {
  85. out := new(VacuumVolumeCheckResponse)
  86. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCheck", in, out, opts...)
  87. if err != nil {
  88. return nil, err
  89. }
  90. return out, nil
  91. }
  92. func (c *volumeServerClient) VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (VolumeServer_VacuumVolumeCompactClient, error) {
  93. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[0], "/volume_server_pb.VolumeServer/VacuumVolumeCompact", opts...)
  94. if err != nil {
  95. return nil, err
  96. }
  97. x := &volumeServerVacuumVolumeCompactClient{stream}
  98. if err := x.ClientStream.SendMsg(in); err != nil {
  99. return nil, err
  100. }
  101. if err := x.ClientStream.CloseSend(); err != nil {
  102. return nil, err
  103. }
  104. return x, nil
  105. }
  106. type VolumeServer_VacuumVolumeCompactClient interface {
  107. Recv() (*VacuumVolumeCompactResponse, error)
  108. grpc.ClientStream
  109. }
  110. type volumeServerVacuumVolumeCompactClient struct {
  111. grpc.ClientStream
  112. }
  113. func (x *volumeServerVacuumVolumeCompactClient) Recv() (*VacuumVolumeCompactResponse, error) {
  114. m := new(VacuumVolumeCompactResponse)
  115. if err := x.ClientStream.RecvMsg(m); err != nil {
  116. return nil, err
  117. }
  118. return m, nil
  119. }
  120. func (c *volumeServerClient) VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error) {
  121. out := new(VacuumVolumeCommitResponse)
  122. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCommit", in, out, opts...)
  123. if err != nil {
  124. return nil, err
  125. }
  126. return out, nil
  127. }
  128. func (c *volumeServerClient) VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error) {
  129. out := new(VacuumVolumeCleanupResponse)
  130. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCleanup", in, out, opts...)
  131. if err != nil {
  132. return nil, err
  133. }
  134. return out, nil
  135. }
  136. func (c *volumeServerClient) DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) {
  137. out := new(DeleteCollectionResponse)
  138. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/DeleteCollection", in, out, opts...)
  139. if err != nil {
  140. return nil, err
  141. }
  142. return out, nil
  143. }
  144. func (c *volumeServerClient) AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error) {
  145. out := new(AllocateVolumeResponse)
  146. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/AllocateVolume", in, out, opts...)
  147. if err != nil {
  148. return nil, err
  149. }
  150. return out, nil
  151. }
  152. func (c *volumeServerClient) VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error) {
  153. out := new(VolumeSyncStatusResponse)
  154. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeSyncStatus", in, out, opts...)
  155. if err != nil {
  156. return nil, err
  157. }
  158. return out, nil
  159. }
  160. func (c *volumeServerClient) VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error) {
  161. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[1], "/volume_server_pb.VolumeServer/VolumeIncrementalCopy", opts...)
  162. if err != nil {
  163. return nil, err
  164. }
  165. x := &volumeServerVolumeIncrementalCopyClient{stream}
  166. if err := x.ClientStream.SendMsg(in); err != nil {
  167. return nil, err
  168. }
  169. if err := x.ClientStream.CloseSend(); err != nil {
  170. return nil, err
  171. }
  172. return x, nil
  173. }
  174. type VolumeServer_VolumeIncrementalCopyClient interface {
  175. Recv() (*VolumeIncrementalCopyResponse, error)
  176. grpc.ClientStream
  177. }
  178. type volumeServerVolumeIncrementalCopyClient struct {
  179. grpc.ClientStream
  180. }
  181. func (x *volumeServerVolumeIncrementalCopyClient) Recv() (*VolumeIncrementalCopyResponse, error) {
  182. m := new(VolumeIncrementalCopyResponse)
  183. if err := x.ClientStream.RecvMsg(m); err != nil {
  184. return nil, err
  185. }
  186. return m, nil
  187. }
  188. func (c *volumeServerClient) VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error) {
  189. out := new(VolumeMountResponse)
  190. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeMount", in, out, opts...)
  191. if err != nil {
  192. return nil, err
  193. }
  194. return out, nil
  195. }
  196. func (c *volumeServerClient) VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error) {
  197. out := new(VolumeUnmountResponse)
  198. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeUnmount", in, out, opts...)
  199. if err != nil {
  200. return nil, err
  201. }
  202. return out, nil
  203. }
  204. func (c *volumeServerClient) VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error) {
  205. out := new(VolumeDeleteResponse)
  206. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeDelete", in, out, opts...)
  207. if err != nil {
  208. return nil, err
  209. }
  210. return out, nil
  211. }
  212. func (c *volumeServerClient) VolumeMarkReadonly(ctx context.Context, in *VolumeMarkReadonlyRequest, opts ...grpc.CallOption) (*VolumeMarkReadonlyResponse, error) {
  213. out := new(VolumeMarkReadonlyResponse)
  214. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeMarkReadonly", in, out, opts...)
  215. if err != nil {
  216. return nil, err
  217. }
  218. return out, nil
  219. }
  220. func (c *volumeServerClient) VolumeMarkWritable(ctx context.Context, in *VolumeMarkWritableRequest, opts ...grpc.CallOption) (*VolumeMarkWritableResponse, error) {
  221. out := new(VolumeMarkWritableResponse)
  222. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeMarkWritable", in, out, opts...)
  223. if err != nil {
  224. return nil, err
  225. }
  226. return out, nil
  227. }
  228. func (c *volumeServerClient) VolumeConfigure(ctx context.Context, in *VolumeConfigureRequest, opts ...grpc.CallOption) (*VolumeConfigureResponse, error) {
  229. out := new(VolumeConfigureResponse)
  230. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeConfigure", in, out, opts...)
  231. if err != nil {
  232. return nil, err
  233. }
  234. return out, nil
  235. }
  236. func (c *volumeServerClient) VolumeStatus(ctx context.Context, in *VolumeStatusRequest, opts ...grpc.CallOption) (*VolumeStatusResponse, error) {
  237. out := new(VolumeStatusResponse)
  238. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeStatus", in, out, opts...)
  239. if err != nil {
  240. return nil, err
  241. }
  242. return out, nil
  243. }
  244. func (c *volumeServerClient) VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeCopyClient, error) {
  245. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[2], "/volume_server_pb.VolumeServer/VolumeCopy", opts...)
  246. if err != nil {
  247. return nil, err
  248. }
  249. x := &volumeServerVolumeCopyClient{stream}
  250. if err := x.ClientStream.SendMsg(in); err != nil {
  251. return nil, err
  252. }
  253. if err := x.ClientStream.CloseSend(); err != nil {
  254. return nil, err
  255. }
  256. return x, nil
  257. }
  258. type VolumeServer_VolumeCopyClient interface {
  259. Recv() (*VolumeCopyResponse, error)
  260. grpc.ClientStream
  261. }
  262. type volumeServerVolumeCopyClient struct {
  263. grpc.ClientStream
  264. }
  265. func (x *volumeServerVolumeCopyClient) Recv() (*VolumeCopyResponse, error) {
  266. m := new(VolumeCopyResponse)
  267. if err := x.ClientStream.RecvMsg(m); err != nil {
  268. return nil, err
  269. }
  270. return m, nil
  271. }
  272. func (c *volumeServerClient) ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error) {
  273. out := new(ReadVolumeFileStatusResponse)
  274. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/ReadVolumeFileStatus", in, out, opts...)
  275. if err != nil {
  276. return nil, err
  277. }
  278. return out, nil
  279. }
  280. func (c *volumeServerClient) CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error) {
  281. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[3], "/volume_server_pb.VolumeServer/CopyFile", opts...)
  282. if err != nil {
  283. return nil, err
  284. }
  285. x := &volumeServerCopyFileClient{stream}
  286. if err := x.ClientStream.SendMsg(in); err != nil {
  287. return nil, err
  288. }
  289. if err := x.ClientStream.CloseSend(); err != nil {
  290. return nil, err
  291. }
  292. return x, nil
  293. }
  294. type VolumeServer_CopyFileClient interface {
  295. Recv() (*CopyFileResponse, error)
  296. grpc.ClientStream
  297. }
  298. type volumeServerCopyFileClient struct {
  299. grpc.ClientStream
  300. }
  301. func (x *volumeServerCopyFileClient) Recv() (*CopyFileResponse, error) {
  302. m := new(CopyFileResponse)
  303. if err := x.ClientStream.RecvMsg(m); err != nil {
  304. return nil, err
  305. }
  306. return m, nil
  307. }
  308. func (c *volumeServerClient) ReadNeedleBlob(ctx context.Context, in *ReadNeedleBlobRequest, opts ...grpc.CallOption) (*ReadNeedleBlobResponse, error) {
  309. out := new(ReadNeedleBlobResponse)
  310. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/ReadNeedleBlob", in, out, opts...)
  311. if err != nil {
  312. return nil, err
  313. }
  314. return out, nil
  315. }
  316. func (c *volumeServerClient) ReadNeedleMeta(ctx context.Context, in *ReadNeedleMetaRequest, opts ...grpc.CallOption) (*ReadNeedleMetaResponse, error) {
  317. out := new(ReadNeedleMetaResponse)
  318. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/ReadNeedleMeta", in, out, opts...)
  319. if err != nil {
  320. return nil, err
  321. }
  322. return out, nil
  323. }
  324. func (c *volumeServerClient) WriteNeedleBlob(ctx context.Context, in *WriteNeedleBlobRequest, opts ...grpc.CallOption) (*WriteNeedleBlobResponse, error) {
  325. out := new(WriteNeedleBlobResponse)
  326. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/WriteNeedleBlob", in, out, opts...)
  327. if err != nil {
  328. return nil, err
  329. }
  330. return out, nil
  331. }
  332. func (c *volumeServerClient) ReadAllNeedles(ctx context.Context, in *ReadAllNeedlesRequest, opts ...grpc.CallOption) (VolumeServer_ReadAllNeedlesClient, error) {
  333. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[4], "/volume_server_pb.VolumeServer/ReadAllNeedles", opts...)
  334. if err != nil {
  335. return nil, err
  336. }
  337. x := &volumeServerReadAllNeedlesClient{stream}
  338. if err := x.ClientStream.SendMsg(in); err != nil {
  339. return nil, err
  340. }
  341. if err := x.ClientStream.CloseSend(); err != nil {
  342. return nil, err
  343. }
  344. return x, nil
  345. }
  346. type VolumeServer_ReadAllNeedlesClient interface {
  347. Recv() (*ReadAllNeedlesResponse, error)
  348. grpc.ClientStream
  349. }
  350. type volumeServerReadAllNeedlesClient struct {
  351. grpc.ClientStream
  352. }
  353. func (x *volumeServerReadAllNeedlesClient) Recv() (*ReadAllNeedlesResponse, error) {
  354. m := new(ReadAllNeedlesResponse)
  355. if err := x.ClientStream.RecvMsg(m); err != nil {
  356. return nil, err
  357. }
  358. return m, nil
  359. }
  360. func (c *volumeServerClient) VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error) {
  361. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[5], "/volume_server_pb.VolumeServer/VolumeTailSender", opts...)
  362. if err != nil {
  363. return nil, err
  364. }
  365. x := &volumeServerVolumeTailSenderClient{stream}
  366. if err := x.ClientStream.SendMsg(in); err != nil {
  367. return nil, err
  368. }
  369. if err := x.ClientStream.CloseSend(); err != nil {
  370. return nil, err
  371. }
  372. return x, nil
  373. }
  374. type VolumeServer_VolumeTailSenderClient interface {
  375. Recv() (*VolumeTailSenderResponse, error)
  376. grpc.ClientStream
  377. }
  378. type volumeServerVolumeTailSenderClient struct {
  379. grpc.ClientStream
  380. }
  381. func (x *volumeServerVolumeTailSenderClient) Recv() (*VolumeTailSenderResponse, error) {
  382. m := new(VolumeTailSenderResponse)
  383. if err := x.ClientStream.RecvMsg(m); err != nil {
  384. return nil, err
  385. }
  386. return m, nil
  387. }
  388. func (c *volumeServerClient) VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error) {
  389. out := new(VolumeTailReceiverResponse)
  390. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeTailReceiver", in, out, opts...)
  391. if err != nil {
  392. return nil, err
  393. }
  394. return out, nil
  395. }
  396. func (c *volumeServerClient) VolumeEcShardsGenerate(ctx context.Context, in *VolumeEcShardsGenerateRequest, opts ...grpc.CallOption) (*VolumeEcShardsGenerateResponse, error) {
  397. out := new(VolumeEcShardsGenerateResponse)
  398. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsGenerate", in, out, opts...)
  399. if err != nil {
  400. return nil, err
  401. }
  402. return out, nil
  403. }
  404. func (c *volumeServerClient) VolumeEcShardsRebuild(ctx context.Context, in *VolumeEcShardsRebuildRequest, opts ...grpc.CallOption) (*VolumeEcShardsRebuildResponse, error) {
  405. out := new(VolumeEcShardsRebuildResponse)
  406. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsRebuild", in, out, opts...)
  407. if err != nil {
  408. return nil, err
  409. }
  410. return out, nil
  411. }
  412. func (c *volumeServerClient) VolumeEcShardsCopy(ctx context.Context, in *VolumeEcShardsCopyRequest, opts ...grpc.CallOption) (*VolumeEcShardsCopyResponse, error) {
  413. out := new(VolumeEcShardsCopyResponse)
  414. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsCopy", in, out, opts...)
  415. if err != nil {
  416. return nil, err
  417. }
  418. return out, nil
  419. }
  420. func (c *volumeServerClient) VolumeEcShardsDelete(ctx context.Context, in *VolumeEcShardsDeleteRequest, opts ...grpc.CallOption) (*VolumeEcShardsDeleteResponse, error) {
  421. out := new(VolumeEcShardsDeleteResponse)
  422. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsDelete", in, out, opts...)
  423. if err != nil {
  424. return nil, err
  425. }
  426. return out, nil
  427. }
  428. func (c *volumeServerClient) VolumeEcShardsMount(ctx context.Context, in *VolumeEcShardsMountRequest, opts ...grpc.CallOption) (*VolumeEcShardsMountResponse, error) {
  429. out := new(VolumeEcShardsMountResponse)
  430. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsMount", in, out, opts...)
  431. if err != nil {
  432. return nil, err
  433. }
  434. return out, nil
  435. }
  436. func (c *volumeServerClient) VolumeEcShardsUnmount(ctx context.Context, in *VolumeEcShardsUnmountRequest, opts ...grpc.CallOption) (*VolumeEcShardsUnmountResponse, error) {
  437. out := new(VolumeEcShardsUnmountResponse)
  438. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsUnmount", in, out, opts...)
  439. if err != nil {
  440. return nil, err
  441. }
  442. return out, nil
  443. }
  444. func (c *volumeServerClient) VolumeEcShardRead(ctx context.Context, in *VolumeEcShardReadRequest, opts ...grpc.CallOption) (VolumeServer_VolumeEcShardReadClient, error) {
  445. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[6], "/volume_server_pb.VolumeServer/VolumeEcShardRead", opts...)
  446. if err != nil {
  447. return nil, err
  448. }
  449. x := &volumeServerVolumeEcShardReadClient{stream}
  450. if err := x.ClientStream.SendMsg(in); err != nil {
  451. return nil, err
  452. }
  453. if err := x.ClientStream.CloseSend(); err != nil {
  454. return nil, err
  455. }
  456. return x, nil
  457. }
  458. type VolumeServer_VolumeEcShardReadClient interface {
  459. Recv() (*VolumeEcShardReadResponse, error)
  460. grpc.ClientStream
  461. }
  462. type volumeServerVolumeEcShardReadClient struct {
  463. grpc.ClientStream
  464. }
  465. func (x *volumeServerVolumeEcShardReadClient) Recv() (*VolumeEcShardReadResponse, error) {
  466. m := new(VolumeEcShardReadResponse)
  467. if err := x.ClientStream.RecvMsg(m); err != nil {
  468. return nil, err
  469. }
  470. return m, nil
  471. }
  472. func (c *volumeServerClient) VolumeEcBlobDelete(ctx context.Context, in *VolumeEcBlobDeleteRequest, opts ...grpc.CallOption) (*VolumeEcBlobDeleteResponse, error) {
  473. out := new(VolumeEcBlobDeleteResponse)
  474. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcBlobDelete", in, out, opts...)
  475. if err != nil {
  476. return nil, err
  477. }
  478. return out, nil
  479. }
  480. func (c *volumeServerClient) VolumeEcShardsToVolume(ctx context.Context, in *VolumeEcShardsToVolumeRequest, opts ...grpc.CallOption) (*VolumeEcShardsToVolumeResponse, error) {
  481. out := new(VolumeEcShardsToVolumeResponse)
  482. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeEcShardsToVolume", in, out, opts...)
  483. if err != nil {
  484. return nil, err
  485. }
  486. return out, nil
  487. }
  488. func (c *volumeServerClient) VolumeTierMoveDatToRemote(ctx context.Context, in *VolumeTierMoveDatToRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatToRemoteClient, error) {
  489. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[7], "/volume_server_pb.VolumeServer/VolumeTierMoveDatToRemote", opts...)
  490. if err != nil {
  491. return nil, err
  492. }
  493. x := &volumeServerVolumeTierMoveDatToRemoteClient{stream}
  494. if err := x.ClientStream.SendMsg(in); err != nil {
  495. return nil, err
  496. }
  497. if err := x.ClientStream.CloseSend(); err != nil {
  498. return nil, err
  499. }
  500. return x, nil
  501. }
  502. type VolumeServer_VolumeTierMoveDatToRemoteClient interface {
  503. Recv() (*VolumeTierMoveDatToRemoteResponse, error)
  504. grpc.ClientStream
  505. }
  506. type volumeServerVolumeTierMoveDatToRemoteClient struct {
  507. grpc.ClientStream
  508. }
  509. func (x *volumeServerVolumeTierMoveDatToRemoteClient) Recv() (*VolumeTierMoveDatToRemoteResponse, error) {
  510. m := new(VolumeTierMoveDatToRemoteResponse)
  511. if err := x.ClientStream.RecvMsg(m); err != nil {
  512. return nil, err
  513. }
  514. return m, nil
  515. }
  516. func (c *volumeServerClient) VolumeTierMoveDatFromRemote(ctx context.Context, in *VolumeTierMoveDatFromRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatFromRemoteClient, error) {
  517. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[8], "/volume_server_pb.VolumeServer/VolumeTierMoveDatFromRemote", opts...)
  518. if err != nil {
  519. return nil, err
  520. }
  521. x := &volumeServerVolumeTierMoveDatFromRemoteClient{stream}
  522. if err := x.ClientStream.SendMsg(in); err != nil {
  523. return nil, err
  524. }
  525. if err := x.ClientStream.CloseSend(); err != nil {
  526. return nil, err
  527. }
  528. return x, nil
  529. }
  530. type VolumeServer_VolumeTierMoveDatFromRemoteClient interface {
  531. Recv() (*VolumeTierMoveDatFromRemoteResponse, error)
  532. grpc.ClientStream
  533. }
  534. type volumeServerVolumeTierMoveDatFromRemoteClient struct {
  535. grpc.ClientStream
  536. }
  537. func (x *volumeServerVolumeTierMoveDatFromRemoteClient) Recv() (*VolumeTierMoveDatFromRemoteResponse, error) {
  538. m := new(VolumeTierMoveDatFromRemoteResponse)
  539. if err := x.ClientStream.RecvMsg(m); err != nil {
  540. return nil, err
  541. }
  542. return m, nil
  543. }
  544. func (c *volumeServerClient) VolumeServerStatus(ctx context.Context, in *VolumeServerStatusRequest, opts ...grpc.CallOption) (*VolumeServerStatusResponse, error) {
  545. out := new(VolumeServerStatusResponse)
  546. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeServerStatus", in, out, opts...)
  547. if err != nil {
  548. return nil, err
  549. }
  550. return out, nil
  551. }
  552. func (c *volumeServerClient) VolumeServerLeave(ctx context.Context, in *VolumeServerLeaveRequest, opts ...grpc.CallOption) (*VolumeServerLeaveResponse, error) {
  553. out := new(VolumeServerLeaveResponse)
  554. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeServerLeave", in, out, opts...)
  555. if err != nil {
  556. return nil, err
  557. }
  558. return out, nil
  559. }
  560. func (c *volumeServerClient) FetchAndWriteNeedle(ctx context.Context, in *FetchAndWriteNeedleRequest, opts ...grpc.CallOption) (*FetchAndWriteNeedleResponse, error) {
  561. out := new(FetchAndWriteNeedleResponse)
  562. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/FetchAndWriteNeedle", in, out, opts...)
  563. if err != nil {
  564. return nil, err
  565. }
  566. return out, nil
  567. }
  568. func (c *volumeServerClient) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (VolumeServer_QueryClient, error) {
  569. stream, err := c.cc.NewStream(ctx, &VolumeServer_ServiceDesc.Streams[9], "/volume_server_pb.VolumeServer/Query", opts...)
  570. if err != nil {
  571. return nil, err
  572. }
  573. x := &volumeServerQueryClient{stream}
  574. if err := x.ClientStream.SendMsg(in); err != nil {
  575. return nil, err
  576. }
  577. if err := x.ClientStream.CloseSend(); err != nil {
  578. return nil, err
  579. }
  580. return x, nil
  581. }
  582. type VolumeServer_QueryClient interface {
  583. Recv() (*QueriedStripe, error)
  584. grpc.ClientStream
  585. }
  586. type volumeServerQueryClient struct {
  587. grpc.ClientStream
  588. }
  589. func (x *volumeServerQueryClient) Recv() (*QueriedStripe, error) {
  590. m := new(QueriedStripe)
  591. if err := x.ClientStream.RecvMsg(m); err != nil {
  592. return nil, err
  593. }
  594. return m, nil
  595. }
  596. func (c *volumeServerClient) VolumeNeedleStatus(ctx context.Context, in *VolumeNeedleStatusRequest, opts ...grpc.CallOption) (*VolumeNeedleStatusResponse, error) {
  597. out := new(VolumeNeedleStatusResponse)
  598. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeNeedleStatus", in, out, opts...)
  599. if err != nil {
  600. return nil, err
  601. }
  602. return out, nil
  603. }
  604. func (c *volumeServerClient) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) {
  605. out := new(PingResponse)
  606. err := c.cc.Invoke(ctx, "/volume_server_pb.VolumeServer/Ping", in, out, opts...)
  607. if err != nil {
  608. return nil, err
  609. }
  610. return out, nil
  611. }
  612. // VolumeServerServer is the server API for VolumeServer service.
  613. // All implementations must embed UnimplementedVolumeServerServer
  614. // for forward compatibility
  615. type VolumeServerServer interface {
  616. // Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
  617. BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)
  618. VacuumVolumeCheck(context.Context, *VacuumVolumeCheckRequest) (*VacuumVolumeCheckResponse, error)
  619. VacuumVolumeCompact(*VacuumVolumeCompactRequest, VolumeServer_VacuumVolumeCompactServer) error
  620. VacuumVolumeCommit(context.Context, *VacuumVolumeCommitRequest) (*VacuumVolumeCommitResponse, error)
  621. VacuumVolumeCleanup(context.Context, *VacuumVolumeCleanupRequest) (*VacuumVolumeCleanupResponse, error)
  622. DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
  623. AllocateVolume(context.Context, *AllocateVolumeRequest) (*AllocateVolumeResponse, error)
  624. VolumeSyncStatus(context.Context, *VolumeSyncStatusRequest) (*VolumeSyncStatusResponse, error)
  625. VolumeIncrementalCopy(*VolumeIncrementalCopyRequest, VolumeServer_VolumeIncrementalCopyServer) error
  626. VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error)
  627. VolumeUnmount(context.Context, *VolumeUnmountRequest) (*VolumeUnmountResponse, error)
  628. VolumeDelete(context.Context, *VolumeDeleteRequest) (*VolumeDeleteResponse, error)
  629. VolumeMarkReadonly(context.Context, *VolumeMarkReadonlyRequest) (*VolumeMarkReadonlyResponse, error)
  630. VolumeMarkWritable(context.Context, *VolumeMarkWritableRequest) (*VolumeMarkWritableResponse, error)
  631. VolumeConfigure(context.Context, *VolumeConfigureRequest) (*VolumeConfigureResponse, error)
  632. VolumeStatus(context.Context, *VolumeStatusRequest) (*VolumeStatusResponse, error)
  633. // copy the .idx .dat files, and mount this volume
  634. VolumeCopy(*VolumeCopyRequest, VolumeServer_VolumeCopyServer) error
  635. ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error)
  636. CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error
  637. ReadNeedleBlob(context.Context, *ReadNeedleBlobRequest) (*ReadNeedleBlobResponse, error)
  638. ReadNeedleMeta(context.Context, *ReadNeedleMetaRequest) (*ReadNeedleMetaResponse, error)
  639. WriteNeedleBlob(context.Context, *WriteNeedleBlobRequest) (*WriteNeedleBlobResponse, error)
  640. ReadAllNeedles(*ReadAllNeedlesRequest, VolumeServer_ReadAllNeedlesServer) error
  641. VolumeTailSender(*VolumeTailSenderRequest, VolumeServer_VolumeTailSenderServer) error
  642. VolumeTailReceiver(context.Context, *VolumeTailReceiverRequest) (*VolumeTailReceiverResponse, error)
  643. // erasure coding
  644. VolumeEcShardsGenerate(context.Context, *VolumeEcShardsGenerateRequest) (*VolumeEcShardsGenerateResponse, error)
  645. VolumeEcShardsRebuild(context.Context, *VolumeEcShardsRebuildRequest) (*VolumeEcShardsRebuildResponse, error)
  646. VolumeEcShardsCopy(context.Context, *VolumeEcShardsCopyRequest) (*VolumeEcShardsCopyResponse, error)
  647. VolumeEcShardsDelete(context.Context, *VolumeEcShardsDeleteRequest) (*VolumeEcShardsDeleteResponse, error)
  648. VolumeEcShardsMount(context.Context, *VolumeEcShardsMountRequest) (*VolumeEcShardsMountResponse, error)
  649. VolumeEcShardsUnmount(context.Context, *VolumeEcShardsUnmountRequest) (*VolumeEcShardsUnmountResponse, error)
  650. VolumeEcShardRead(*VolumeEcShardReadRequest, VolumeServer_VolumeEcShardReadServer) error
  651. VolumeEcBlobDelete(context.Context, *VolumeEcBlobDeleteRequest) (*VolumeEcBlobDeleteResponse, error)
  652. VolumeEcShardsToVolume(context.Context, *VolumeEcShardsToVolumeRequest) (*VolumeEcShardsToVolumeResponse, error)
  653. // tiered storage
  654. VolumeTierMoveDatToRemote(*VolumeTierMoveDatToRemoteRequest, VolumeServer_VolumeTierMoveDatToRemoteServer) error
  655. VolumeTierMoveDatFromRemote(*VolumeTierMoveDatFromRemoteRequest, VolumeServer_VolumeTierMoveDatFromRemoteServer) error
  656. VolumeServerStatus(context.Context, *VolumeServerStatusRequest) (*VolumeServerStatusResponse, error)
  657. VolumeServerLeave(context.Context, *VolumeServerLeaveRequest) (*VolumeServerLeaveResponse, error)
  658. // remote storage
  659. FetchAndWriteNeedle(context.Context, *FetchAndWriteNeedleRequest) (*FetchAndWriteNeedleResponse, error)
  660. // <experimental> query
  661. Query(*QueryRequest, VolumeServer_QueryServer) error
  662. VolumeNeedleStatus(context.Context, *VolumeNeedleStatusRequest) (*VolumeNeedleStatusResponse, error)
  663. Ping(context.Context, *PingRequest) (*PingResponse, error)
  664. mustEmbedUnimplementedVolumeServerServer()
  665. }
  666. // UnimplementedVolumeServerServer must be embedded to have forward compatible implementations.
  667. type UnimplementedVolumeServerServer struct {
  668. }
  669. func (UnimplementedVolumeServerServer) BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error) {
  670. return nil, status.Errorf(codes.Unimplemented, "method BatchDelete not implemented")
  671. }
  672. func (UnimplementedVolumeServerServer) VacuumVolumeCheck(context.Context, *VacuumVolumeCheckRequest) (*VacuumVolumeCheckResponse, error) {
  673. return nil, status.Errorf(codes.Unimplemented, "method VacuumVolumeCheck not implemented")
  674. }
  675. func (UnimplementedVolumeServerServer) VacuumVolumeCompact(*VacuumVolumeCompactRequest, VolumeServer_VacuumVolumeCompactServer) error {
  676. return status.Errorf(codes.Unimplemented, "method VacuumVolumeCompact not implemented")
  677. }
  678. func (UnimplementedVolumeServerServer) VacuumVolumeCommit(context.Context, *VacuumVolumeCommitRequest) (*VacuumVolumeCommitResponse, error) {
  679. return nil, status.Errorf(codes.Unimplemented, "method VacuumVolumeCommit not implemented")
  680. }
  681. func (UnimplementedVolumeServerServer) VacuumVolumeCleanup(context.Context, *VacuumVolumeCleanupRequest) (*VacuumVolumeCleanupResponse, error) {
  682. return nil, status.Errorf(codes.Unimplemented, "method VacuumVolumeCleanup not implemented")
  683. }
  684. func (UnimplementedVolumeServerServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error) {
  685. return nil, status.Errorf(codes.Unimplemented, "method DeleteCollection not implemented")
  686. }
  687. func (UnimplementedVolumeServerServer) AllocateVolume(context.Context, *AllocateVolumeRequest) (*AllocateVolumeResponse, error) {
  688. return nil, status.Errorf(codes.Unimplemented, "method AllocateVolume not implemented")
  689. }
  690. func (UnimplementedVolumeServerServer) VolumeSyncStatus(context.Context, *VolumeSyncStatusRequest) (*VolumeSyncStatusResponse, error) {
  691. return nil, status.Errorf(codes.Unimplemented, "method VolumeSyncStatus not implemented")
  692. }
  693. func (UnimplementedVolumeServerServer) VolumeIncrementalCopy(*VolumeIncrementalCopyRequest, VolumeServer_VolumeIncrementalCopyServer) error {
  694. return status.Errorf(codes.Unimplemented, "method VolumeIncrementalCopy not implemented")
  695. }
  696. func (UnimplementedVolumeServerServer) VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error) {
  697. return nil, status.Errorf(codes.Unimplemented, "method VolumeMount not implemented")
  698. }
  699. func (UnimplementedVolumeServerServer) VolumeUnmount(context.Context, *VolumeUnmountRequest) (*VolumeUnmountResponse, error) {
  700. return nil, status.Errorf(codes.Unimplemented, "method VolumeUnmount not implemented")
  701. }
  702. func (UnimplementedVolumeServerServer) VolumeDelete(context.Context, *VolumeDeleteRequest) (*VolumeDeleteResponse, error) {
  703. return nil, status.Errorf(codes.Unimplemented, "method VolumeDelete not implemented")
  704. }
  705. func (UnimplementedVolumeServerServer) VolumeMarkReadonly(context.Context, *VolumeMarkReadonlyRequest) (*VolumeMarkReadonlyResponse, error) {
  706. return nil, status.Errorf(codes.Unimplemented, "method VolumeMarkReadonly not implemented")
  707. }
  708. func (UnimplementedVolumeServerServer) VolumeMarkWritable(context.Context, *VolumeMarkWritableRequest) (*VolumeMarkWritableResponse, error) {
  709. return nil, status.Errorf(codes.Unimplemented, "method VolumeMarkWritable not implemented")
  710. }
  711. func (UnimplementedVolumeServerServer) VolumeConfigure(context.Context, *VolumeConfigureRequest) (*VolumeConfigureResponse, error) {
  712. return nil, status.Errorf(codes.Unimplemented, "method VolumeConfigure not implemented")
  713. }
  714. func (UnimplementedVolumeServerServer) VolumeStatus(context.Context, *VolumeStatusRequest) (*VolumeStatusResponse, error) {
  715. return nil, status.Errorf(codes.Unimplemented, "method VolumeStatus not implemented")
  716. }
  717. func (UnimplementedVolumeServerServer) VolumeCopy(*VolumeCopyRequest, VolumeServer_VolumeCopyServer) error {
  718. return status.Errorf(codes.Unimplemented, "method VolumeCopy not implemented")
  719. }
  720. func (UnimplementedVolumeServerServer) ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error) {
  721. return nil, status.Errorf(codes.Unimplemented, "method ReadVolumeFileStatus not implemented")
  722. }
  723. func (UnimplementedVolumeServerServer) CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error {
  724. return status.Errorf(codes.Unimplemented, "method CopyFile not implemented")
  725. }
  726. func (UnimplementedVolumeServerServer) ReadNeedleBlob(context.Context, *ReadNeedleBlobRequest) (*ReadNeedleBlobResponse, error) {
  727. return nil, status.Errorf(codes.Unimplemented, "method ReadNeedleBlob not implemented")
  728. }
  729. func (UnimplementedVolumeServerServer) ReadNeedleMeta(context.Context, *ReadNeedleMetaRequest) (*ReadNeedleMetaResponse, error) {
  730. return nil, status.Errorf(codes.Unimplemented, "method ReadNeedleMeta not implemented")
  731. }
  732. func (UnimplementedVolumeServerServer) WriteNeedleBlob(context.Context, *WriteNeedleBlobRequest) (*WriteNeedleBlobResponse, error) {
  733. return nil, status.Errorf(codes.Unimplemented, "method WriteNeedleBlob not implemented")
  734. }
  735. func (UnimplementedVolumeServerServer) ReadAllNeedles(*ReadAllNeedlesRequest, VolumeServer_ReadAllNeedlesServer) error {
  736. return status.Errorf(codes.Unimplemented, "method ReadAllNeedles not implemented")
  737. }
  738. func (UnimplementedVolumeServerServer) VolumeTailSender(*VolumeTailSenderRequest, VolumeServer_VolumeTailSenderServer) error {
  739. return status.Errorf(codes.Unimplemented, "method VolumeTailSender not implemented")
  740. }
  741. func (UnimplementedVolumeServerServer) VolumeTailReceiver(context.Context, *VolumeTailReceiverRequest) (*VolumeTailReceiverResponse, error) {
  742. return nil, status.Errorf(codes.Unimplemented, "method VolumeTailReceiver not implemented")
  743. }
  744. func (UnimplementedVolumeServerServer) VolumeEcShardsGenerate(context.Context, *VolumeEcShardsGenerateRequest) (*VolumeEcShardsGenerateResponse, error) {
  745. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsGenerate not implemented")
  746. }
  747. func (UnimplementedVolumeServerServer) VolumeEcShardsRebuild(context.Context, *VolumeEcShardsRebuildRequest) (*VolumeEcShardsRebuildResponse, error) {
  748. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsRebuild not implemented")
  749. }
  750. func (UnimplementedVolumeServerServer) VolumeEcShardsCopy(context.Context, *VolumeEcShardsCopyRequest) (*VolumeEcShardsCopyResponse, error) {
  751. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsCopy not implemented")
  752. }
  753. func (UnimplementedVolumeServerServer) VolumeEcShardsDelete(context.Context, *VolumeEcShardsDeleteRequest) (*VolumeEcShardsDeleteResponse, error) {
  754. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsDelete not implemented")
  755. }
  756. func (UnimplementedVolumeServerServer) VolumeEcShardsMount(context.Context, *VolumeEcShardsMountRequest) (*VolumeEcShardsMountResponse, error) {
  757. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsMount not implemented")
  758. }
  759. func (UnimplementedVolumeServerServer) VolumeEcShardsUnmount(context.Context, *VolumeEcShardsUnmountRequest) (*VolumeEcShardsUnmountResponse, error) {
  760. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsUnmount not implemented")
  761. }
  762. func (UnimplementedVolumeServerServer) VolumeEcShardRead(*VolumeEcShardReadRequest, VolumeServer_VolumeEcShardReadServer) error {
  763. return status.Errorf(codes.Unimplemented, "method VolumeEcShardRead not implemented")
  764. }
  765. func (UnimplementedVolumeServerServer) VolumeEcBlobDelete(context.Context, *VolumeEcBlobDeleteRequest) (*VolumeEcBlobDeleteResponse, error) {
  766. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcBlobDelete not implemented")
  767. }
  768. func (UnimplementedVolumeServerServer) VolumeEcShardsToVolume(context.Context, *VolumeEcShardsToVolumeRequest) (*VolumeEcShardsToVolumeResponse, error) {
  769. return nil, status.Errorf(codes.Unimplemented, "method VolumeEcShardsToVolume not implemented")
  770. }
  771. func (UnimplementedVolumeServerServer) VolumeTierMoveDatToRemote(*VolumeTierMoveDatToRemoteRequest, VolumeServer_VolumeTierMoveDatToRemoteServer) error {
  772. return status.Errorf(codes.Unimplemented, "method VolumeTierMoveDatToRemote not implemented")
  773. }
  774. func (UnimplementedVolumeServerServer) VolumeTierMoveDatFromRemote(*VolumeTierMoveDatFromRemoteRequest, VolumeServer_VolumeTierMoveDatFromRemoteServer) error {
  775. return status.Errorf(codes.Unimplemented, "method VolumeTierMoveDatFromRemote not implemented")
  776. }
  777. func (UnimplementedVolumeServerServer) VolumeServerStatus(context.Context, *VolumeServerStatusRequest) (*VolumeServerStatusResponse, error) {
  778. return nil, status.Errorf(codes.Unimplemented, "method VolumeServerStatus not implemented")
  779. }
  780. func (UnimplementedVolumeServerServer) VolumeServerLeave(context.Context, *VolumeServerLeaveRequest) (*VolumeServerLeaveResponse, error) {
  781. return nil, status.Errorf(codes.Unimplemented, "method VolumeServerLeave not implemented")
  782. }
  783. func (UnimplementedVolumeServerServer) FetchAndWriteNeedle(context.Context, *FetchAndWriteNeedleRequest) (*FetchAndWriteNeedleResponse, error) {
  784. return nil, status.Errorf(codes.Unimplemented, "method FetchAndWriteNeedle not implemented")
  785. }
  786. func (UnimplementedVolumeServerServer) Query(*QueryRequest, VolumeServer_QueryServer) error {
  787. return status.Errorf(codes.Unimplemented, "method Query not implemented")
  788. }
  789. func (UnimplementedVolumeServerServer) VolumeNeedleStatus(context.Context, *VolumeNeedleStatusRequest) (*VolumeNeedleStatusResponse, error) {
  790. return nil, status.Errorf(codes.Unimplemented, "method VolumeNeedleStatus not implemented")
  791. }
  792. func (UnimplementedVolumeServerServer) Ping(context.Context, *PingRequest) (*PingResponse, error) {
  793. return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
  794. }
  795. func (UnimplementedVolumeServerServer) mustEmbedUnimplementedVolumeServerServer() {}
  796. // UnsafeVolumeServerServer may be embedded to opt out of forward compatibility for this service.
  797. // Use of this interface is not recommended, as added methods to VolumeServerServer will
  798. // result in compilation errors.
  799. type UnsafeVolumeServerServer interface {
  800. mustEmbedUnimplementedVolumeServerServer()
  801. }
  802. func RegisterVolumeServerServer(s grpc.ServiceRegistrar, srv VolumeServerServer) {
  803. s.RegisterService(&VolumeServer_ServiceDesc, srv)
  804. }
  805. func _VolumeServer_BatchDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  806. in := new(BatchDeleteRequest)
  807. if err := dec(in); err != nil {
  808. return nil, err
  809. }
  810. if interceptor == nil {
  811. return srv.(VolumeServerServer).BatchDelete(ctx, in)
  812. }
  813. info := &grpc.UnaryServerInfo{
  814. Server: srv,
  815. FullMethod: "/volume_server_pb.VolumeServer/BatchDelete",
  816. }
  817. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  818. return srv.(VolumeServerServer).BatchDelete(ctx, req.(*BatchDeleteRequest))
  819. }
  820. return interceptor(ctx, in, info, handler)
  821. }
  822. func _VolumeServer_VacuumVolumeCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  823. in := new(VacuumVolumeCheckRequest)
  824. if err := dec(in); err != nil {
  825. return nil, err
  826. }
  827. if interceptor == nil {
  828. return srv.(VolumeServerServer).VacuumVolumeCheck(ctx, in)
  829. }
  830. info := &grpc.UnaryServerInfo{
  831. Server: srv,
  832. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCheck",
  833. }
  834. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  835. return srv.(VolumeServerServer).VacuumVolumeCheck(ctx, req.(*VacuumVolumeCheckRequest))
  836. }
  837. return interceptor(ctx, in, info, handler)
  838. }
  839. func _VolumeServer_VacuumVolumeCompact_Handler(srv interface{}, stream grpc.ServerStream) error {
  840. m := new(VacuumVolumeCompactRequest)
  841. if err := stream.RecvMsg(m); err != nil {
  842. return err
  843. }
  844. return srv.(VolumeServerServer).VacuumVolumeCompact(m, &volumeServerVacuumVolumeCompactServer{stream})
  845. }
  846. type VolumeServer_VacuumVolumeCompactServer interface {
  847. Send(*VacuumVolumeCompactResponse) error
  848. grpc.ServerStream
  849. }
  850. type volumeServerVacuumVolumeCompactServer struct {
  851. grpc.ServerStream
  852. }
  853. func (x *volumeServerVacuumVolumeCompactServer) Send(m *VacuumVolumeCompactResponse) error {
  854. return x.ServerStream.SendMsg(m)
  855. }
  856. func _VolumeServer_VacuumVolumeCommit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  857. in := new(VacuumVolumeCommitRequest)
  858. if err := dec(in); err != nil {
  859. return nil, err
  860. }
  861. if interceptor == nil {
  862. return srv.(VolumeServerServer).VacuumVolumeCommit(ctx, in)
  863. }
  864. info := &grpc.UnaryServerInfo{
  865. Server: srv,
  866. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCommit",
  867. }
  868. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  869. return srv.(VolumeServerServer).VacuumVolumeCommit(ctx, req.(*VacuumVolumeCommitRequest))
  870. }
  871. return interceptor(ctx, in, info, handler)
  872. }
  873. func _VolumeServer_VacuumVolumeCleanup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  874. in := new(VacuumVolumeCleanupRequest)
  875. if err := dec(in); err != nil {
  876. return nil, err
  877. }
  878. if interceptor == nil {
  879. return srv.(VolumeServerServer).VacuumVolumeCleanup(ctx, in)
  880. }
  881. info := &grpc.UnaryServerInfo{
  882. Server: srv,
  883. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCleanup",
  884. }
  885. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  886. return srv.(VolumeServerServer).VacuumVolumeCleanup(ctx, req.(*VacuumVolumeCleanupRequest))
  887. }
  888. return interceptor(ctx, in, info, handler)
  889. }
  890. func _VolumeServer_DeleteCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  891. in := new(DeleteCollectionRequest)
  892. if err := dec(in); err != nil {
  893. return nil, err
  894. }
  895. if interceptor == nil {
  896. return srv.(VolumeServerServer).DeleteCollection(ctx, in)
  897. }
  898. info := &grpc.UnaryServerInfo{
  899. Server: srv,
  900. FullMethod: "/volume_server_pb.VolumeServer/DeleteCollection",
  901. }
  902. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  903. return srv.(VolumeServerServer).DeleteCollection(ctx, req.(*DeleteCollectionRequest))
  904. }
  905. return interceptor(ctx, in, info, handler)
  906. }
  907. func _VolumeServer_AllocateVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  908. in := new(AllocateVolumeRequest)
  909. if err := dec(in); err != nil {
  910. return nil, err
  911. }
  912. if interceptor == nil {
  913. return srv.(VolumeServerServer).AllocateVolume(ctx, in)
  914. }
  915. info := &grpc.UnaryServerInfo{
  916. Server: srv,
  917. FullMethod: "/volume_server_pb.VolumeServer/AllocateVolume",
  918. }
  919. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  920. return srv.(VolumeServerServer).AllocateVolume(ctx, req.(*AllocateVolumeRequest))
  921. }
  922. return interceptor(ctx, in, info, handler)
  923. }
  924. func _VolumeServer_VolumeSyncStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  925. in := new(VolumeSyncStatusRequest)
  926. if err := dec(in); err != nil {
  927. return nil, err
  928. }
  929. if interceptor == nil {
  930. return srv.(VolumeServerServer).VolumeSyncStatus(ctx, in)
  931. }
  932. info := &grpc.UnaryServerInfo{
  933. Server: srv,
  934. FullMethod: "/volume_server_pb.VolumeServer/VolumeSyncStatus",
  935. }
  936. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  937. return srv.(VolumeServerServer).VolumeSyncStatus(ctx, req.(*VolumeSyncStatusRequest))
  938. }
  939. return interceptor(ctx, in, info, handler)
  940. }
  941. func _VolumeServer_VolumeIncrementalCopy_Handler(srv interface{}, stream grpc.ServerStream) error {
  942. m := new(VolumeIncrementalCopyRequest)
  943. if err := stream.RecvMsg(m); err != nil {
  944. return err
  945. }
  946. return srv.(VolumeServerServer).VolumeIncrementalCopy(m, &volumeServerVolumeIncrementalCopyServer{stream})
  947. }
  948. type VolumeServer_VolumeIncrementalCopyServer interface {
  949. Send(*VolumeIncrementalCopyResponse) error
  950. grpc.ServerStream
  951. }
  952. type volumeServerVolumeIncrementalCopyServer struct {
  953. grpc.ServerStream
  954. }
  955. func (x *volumeServerVolumeIncrementalCopyServer) Send(m *VolumeIncrementalCopyResponse) error {
  956. return x.ServerStream.SendMsg(m)
  957. }
  958. func _VolumeServer_VolumeMount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  959. in := new(VolumeMountRequest)
  960. if err := dec(in); err != nil {
  961. return nil, err
  962. }
  963. if interceptor == nil {
  964. return srv.(VolumeServerServer).VolumeMount(ctx, in)
  965. }
  966. info := &grpc.UnaryServerInfo{
  967. Server: srv,
  968. FullMethod: "/volume_server_pb.VolumeServer/VolumeMount",
  969. }
  970. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  971. return srv.(VolumeServerServer).VolumeMount(ctx, req.(*VolumeMountRequest))
  972. }
  973. return interceptor(ctx, in, info, handler)
  974. }
  975. func _VolumeServer_VolumeUnmount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  976. in := new(VolumeUnmountRequest)
  977. if err := dec(in); err != nil {
  978. return nil, err
  979. }
  980. if interceptor == nil {
  981. return srv.(VolumeServerServer).VolumeUnmount(ctx, in)
  982. }
  983. info := &grpc.UnaryServerInfo{
  984. Server: srv,
  985. FullMethod: "/volume_server_pb.VolumeServer/VolumeUnmount",
  986. }
  987. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  988. return srv.(VolumeServerServer).VolumeUnmount(ctx, req.(*VolumeUnmountRequest))
  989. }
  990. return interceptor(ctx, in, info, handler)
  991. }
  992. func _VolumeServer_VolumeDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  993. in := new(VolumeDeleteRequest)
  994. if err := dec(in); err != nil {
  995. return nil, err
  996. }
  997. if interceptor == nil {
  998. return srv.(VolumeServerServer).VolumeDelete(ctx, in)
  999. }
  1000. info := &grpc.UnaryServerInfo{
  1001. Server: srv,
  1002. FullMethod: "/volume_server_pb.VolumeServer/VolumeDelete",
  1003. }
  1004. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1005. return srv.(VolumeServerServer).VolumeDelete(ctx, req.(*VolumeDeleteRequest))
  1006. }
  1007. return interceptor(ctx, in, info, handler)
  1008. }
  1009. func _VolumeServer_VolumeMarkReadonly_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1010. in := new(VolumeMarkReadonlyRequest)
  1011. if err := dec(in); err != nil {
  1012. return nil, err
  1013. }
  1014. if interceptor == nil {
  1015. return srv.(VolumeServerServer).VolumeMarkReadonly(ctx, in)
  1016. }
  1017. info := &grpc.UnaryServerInfo{
  1018. Server: srv,
  1019. FullMethod: "/volume_server_pb.VolumeServer/VolumeMarkReadonly",
  1020. }
  1021. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1022. return srv.(VolumeServerServer).VolumeMarkReadonly(ctx, req.(*VolumeMarkReadonlyRequest))
  1023. }
  1024. return interceptor(ctx, in, info, handler)
  1025. }
  1026. func _VolumeServer_VolumeMarkWritable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1027. in := new(VolumeMarkWritableRequest)
  1028. if err := dec(in); err != nil {
  1029. return nil, err
  1030. }
  1031. if interceptor == nil {
  1032. return srv.(VolumeServerServer).VolumeMarkWritable(ctx, in)
  1033. }
  1034. info := &grpc.UnaryServerInfo{
  1035. Server: srv,
  1036. FullMethod: "/volume_server_pb.VolumeServer/VolumeMarkWritable",
  1037. }
  1038. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1039. return srv.(VolumeServerServer).VolumeMarkWritable(ctx, req.(*VolumeMarkWritableRequest))
  1040. }
  1041. return interceptor(ctx, in, info, handler)
  1042. }
  1043. func _VolumeServer_VolumeConfigure_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1044. in := new(VolumeConfigureRequest)
  1045. if err := dec(in); err != nil {
  1046. return nil, err
  1047. }
  1048. if interceptor == nil {
  1049. return srv.(VolumeServerServer).VolumeConfigure(ctx, in)
  1050. }
  1051. info := &grpc.UnaryServerInfo{
  1052. Server: srv,
  1053. FullMethod: "/volume_server_pb.VolumeServer/VolumeConfigure",
  1054. }
  1055. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1056. return srv.(VolumeServerServer).VolumeConfigure(ctx, req.(*VolumeConfigureRequest))
  1057. }
  1058. return interceptor(ctx, in, info, handler)
  1059. }
  1060. func _VolumeServer_VolumeStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1061. in := new(VolumeStatusRequest)
  1062. if err := dec(in); err != nil {
  1063. return nil, err
  1064. }
  1065. if interceptor == nil {
  1066. return srv.(VolumeServerServer).VolumeStatus(ctx, in)
  1067. }
  1068. info := &grpc.UnaryServerInfo{
  1069. Server: srv,
  1070. FullMethod: "/volume_server_pb.VolumeServer/VolumeStatus",
  1071. }
  1072. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1073. return srv.(VolumeServerServer).VolumeStatus(ctx, req.(*VolumeStatusRequest))
  1074. }
  1075. return interceptor(ctx, in, info, handler)
  1076. }
  1077. func _VolumeServer_VolumeCopy_Handler(srv interface{}, stream grpc.ServerStream) error {
  1078. m := new(VolumeCopyRequest)
  1079. if err := stream.RecvMsg(m); err != nil {
  1080. return err
  1081. }
  1082. return srv.(VolumeServerServer).VolumeCopy(m, &volumeServerVolumeCopyServer{stream})
  1083. }
  1084. type VolumeServer_VolumeCopyServer interface {
  1085. Send(*VolumeCopyResponse) error
  1086. grpc.ServerStream
  1087. }
  1088. type volumeServerVolumeCopyServer struct {
  1089. grpc.ServerStream
  1090. }
  1091. func (x *volumeServerVolumeCopyServer) Send(m *VolumeCopyResponse) error {
  1092. return x.ServerStream.SendMsg(m)
  1093. }
  1094. func _VolumeServer_ReadVolumeFileStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1095. in := new(ReadVolumeFileStatusRequest)
  1096. if err := dec(in); err != nil {
  1097. return nil, err
  1098. }
  1099. if interceptor == nil {
  1100. return srv.(VolumeServerServer).ReadVolumeFileStatus(ctx, in)
  1101. }
  1102. info := &grpc.UnaryServerInfo{
  1103. Server: srv,
  1104. FullMethod: "/volume_server_pb.VolumeServer/ReadVolumeFileStatus",
  1105. }
  1106. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1107. return srv.(VolumeServerServer).ReadVolumeFileStatus(ctx, req.(*ReadVolumeFileStatusRequest))
  1108. }
  1109. return interceptor(ctx, in, info, handler)
  1110. }
  1111. func _VolumeServer_CopyFile_Handler(srv interface{}, stream grpc.ServerStream) error {
  1112. m := new(CopyFileRequest)
  1113. if err := stream.RecvMsg(m); err != nil {
  1114. return err
  1115. }
  1116. return srv.(VolumeServerServer).CopyFile(m, &volumeServerCopyFileServer{stream})
  1117. }
  1118. type VolumeServer_CopyFileServer interface {
  1119. Send(*CopyFileResponse) error
  1120. grpc.ServerStream
  1121. }
  1122. type volumeServerCopyFileServer struct {
  1123. grpc.ServerStream
  1124. }
  1125. func (x *volumeServerCopyFileServer) Send(m *CopyFileResponse) error {
  1126. return x.ServerStream.SendMsg(m)
  1127. }
  1128. func _VolumeServer_ReadNeedleBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1129. in := new(ReadNeedleBlobRequest)
  1130. if err := dec(in); err != nil {
  1131. return nil, err
  1132. }
  1133. if interceptor == nil {
  1134. return srv.(VolumeServerServer).ReadNeedleBlob(ctx, in)
  1135. }
  1136. info := &grpc.UnaryServerInfo{
  1137. Server: srv,
  1138. FullMethod: "/volume_server_pb.VolumeServer/ReadNeedleBlob",
  1139. }
  1140. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1141. return srv.(VolumeServerServer).ReadNeedleBlob(ctx, req.(*ReadNeedleBlobRequest))
  1142. }
  1143. return interceptor(ctx, in, info, handler)
  1144. }
  1145. func _VolumeServer_ReadNeedleMeta_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1146. in := new(ReadNeedleMetaRequest)
  1147. if err := dec(in); err != nil {
  1148. return nil, err
  1149. }
  1150. if interceptor == nil {
  1151. return srv.(VolumeServerServer).ReadNeedleMeta(ctx, in)
  1152. }
  1153. info := &grpc.UnaryServerInfo{
  1154. Server: srv,
  1155. FullMethod: "/volume_server_pb.VolumeServer/ReadNeedleMeta",
  1156. }
  1157. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1158. return srv.(VolumeServerServer).ReadNeedleMeta(ctx, req.(*ReadNeedleMetaRequest))
  1159. }
  1160. return interceptor(ctx, in, info, handler)
  1161. }
  1162. func _VolumeServer_WriteNeedleBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1163. in := new(WriteNeedleBlobRequest)
  1164. if err := dec(in); err != nil {
  1165. return nil, err
  1166. }
  1167. if interceptor == nil {
  1168. return srv.(VolumeServerServer).WriteNeedleBlob(ctx, in)
  1169. }
  1170. info := &grpc.UnaryServerInfo{
  1171. Server: srv,
  1172. FullMethod: "/volume_server_pb.VolumeServer/WriteNeedleBlob",
  1173. }
  1174. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1175. return srv.(VolumeServerServer).WriteNeedleBlob(ctx, req.(*WriteNeedleBlobRequest))
  1176. }
  1177. return interceptor(ctx, in, info, handler)
  1178. }
  1179. func _VolumeServer_ReadAllNeedles_Handler(srv interface{}, stream grpc.ServerStream) error {
  1180. m := new(ReadAllNeedlesRequest)
  1181. if err := stream.RecvMsg(m); err != nil {
  1182. return err
  1183. }
  1184. return srv.(VolumeServerServer).ReadAllNeedles(m, &volumeServerReadAllNeedlesServer{stream})
  1185. }
  1186. type VolumeServer_ReadAllNeedlesServer interface {
  1187. Send(*ReadAllNeedlesResponse) error
  1188. grpc.ServerStream
  1189. }
  1190. type volumeServerReadAllNeedlesServer struct {
  1191. grpc.ServerStream
  1192. }
  1193. func (x *volumeServerReadAllNeedlesServer) Send(m *ReadAllNeedlesResponse) error {
  1194. return x.ServerStream.SendMsg(m)
  1195. }
  1196. func _VolumeServer_VolumeTailSender_Handler(srv interface{}, stream grpc.ServerStream) error {
  1197. m := new(VolumeTailSenderRequest)
  1198. if err := stream.RecvMsg(m); err != nil {
  1199. return err
  1200. }
  1201. return srv.(VolumeServerServer).VolumeTailSender(m, &volumeServerVolumeTailSenderServer{stream})
  1202. }
  1203. type VolumeServer_VolumeTailSenderServer interface {
  1204. Send(*VolumeTailSenderResponse) error
  1205. grpc.ServerStream
  1206. }
  1207. type volumeServerVolumeTailSenderServer struct {
  1208. grpc.ServerStream
  1209. }
  1210. func (x *volumeServerVolumeTailSenderServer) Send(m *VolumeTailSenderResponse) error {
  1211. return x.ServerStream.SendMsg(m)
  1212. }
  1213. func _VolumeServer_VolumeTailReceiver_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1214. in := new(VolumeTailReceiverRequest)
  1215. if err := dec(in); err != nil {
  1216. return nil, err
  1217. }
  1218. if interceptor == nil {
  1219. return srv.(VolumeServerServer).VolumeTailReceiver(ctx, in)
  1220. }
  1221. info := &grpc.UnaryServerInfo{
  1222. Server: srv,
  1223. FullMethod: "/volume_server_pb.VolumeServer/VolumeTailReceiver",
  1224. }
  1225. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1226. return srv.(VolumeServerServer).VolumeTailReceiver(ctx, req.(*VolumeTailReceiverRequest))
  1227. }
  1228. return interceptor(ctx, in, info, handler)
  1229. }
  1230. func _VolumeServer_VolumeEcShardsGenerate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1231. in := new(VolumeEcShardsGenerateRequest)
  1232. if err := dec(in); err != nil {
  1233. return nil, err
  1234. }
  1235. if interceptor == nil {
  1236. return srv.(VolumeServerServer).VolumeEcShardsGenerate(ctx, in)
  1237. }
  1238. info := &grpc.UnaryServerInfo{
  1239. Server: srv,
  1240. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsGenerate",
  1241. }
  1242. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1243. return srv.(VolumeServerServer).VolumeEcShardsGenerate(ctx, req.(*VolumeEcShardsGenerateRequest))
  1244. }
  1245. return interceptor(ctx, in, info, handler)
  1246. }
  1247. func _VolumeServer_VolumeEcShardsRebuild_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1248. in := new(VolumeEcShardsRebuildRequest)
  1249. if err := dec(in); err != nil {
  1250. return nil, err
  1251. }
  1252. if interceptor == nil {
  1253. return srv.(VolumeServerServer).VolumeEcShardsRebuild(ctx, in)
  1254. }
  1255. info := &grpc.UnaryServerInfo{
  1256. Server: srv,
  1257. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsRebuild",
  1258. }
  1259. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1260. return srv.(VolumeServerServer).VolumeEcShardsRebuild(ctx, req.(*VolumeEcShardsRebuildRequest))
  1261. }
  1262. return interceptor(ctx, in, info, handler)
  1263. }
  1264. func _VolumeServer_VolumeEcShardsCopy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1265. in := new(VolumeEcShardsCopyRequest)
  1266. if err := dec(in); err != nil {
  1267. return nil, err
  1268. }
  1269. if interceptor == nil {
  1270. return srv.(VolumeServerServer).VolumeEcShardsCopy(ctx, in)
  1271. }
  1272. info := &grpc.UnaryServerInfo{
  1273. Server: srv,
  1274. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsCopy",
  1275. }
  1276. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1277. return srv.(VolumeServerServer).VolumeEcShardsCopy(ctx, req.(*VolumeEcShardsCopyRequest))
  1278. }
  1279. return interceptor(ctx, in, info, handler)
  1280. }
  1281. func _VolumeServer_VolumeEcShardsDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1282. in := new(VolumeEcShardsDeleteRequest)
  1283. if err := dec(in); err != nil {
  1284. return nil, err
  1285. }
  1286. if interceptor == nil {
  1287. return srv.(VolumeServerServer).VolumeEcShardsDelete(ctx, in)
  1288. }
  1289. info := &grpc.UnaryServerInfo{
  1290. Server: srv,
  1291. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsDelete",
  1292. }
  1293. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1294. return srv.(VolumeServerServer).VolumeEcShardsDelete(ctx, req.(*VolumeEcShardsDeleteRequest))
  1295. }
  1296. return interceptor(ctx, in, info, handler)
  1297. }
  1298. func _VolumeServer_VolumeEcShardsMount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1299. in := new(VolumeEcShardsMountRequest)
  1300. if err := dec(in); err != nil {
  1301. return nil, err
  1302. }
  1303. if interceptor == nil {
  1304. return srv.(VolumeServerServer).VolumeEcShardsMount(ctx, in)
  1305. }
  1306. info := &grpc.UnaryServerInfo{
  1307. Server: srv,
  1308. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsMount",
  1309. }
  1310. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1311. return srv.(VolumeServerServer).VolumeEcShardsMount(ctx, req.(*VolumeEcShardsMountRequest))
  1312. }
  1313. return interceptor(ctx, in, info, handler)
  1314. }
  1315. func _VolumeServer_VolumeEcShardsUnmount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1316. in := new(VolumeEcShardsUnmountRequest)
  1317. if err := dec(in); err != nil {
  1318. return nil, err
  1319. }
  1320. if interceptor == nil {
  1321. return srv.(VolumeServerServer).VolumeEcShardsUnmount(ctx, in)
  1322. }
  1323. info := &grpc.UnaryServerInfo{
  1324. Server: srv,
  1325. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsUnmount",
  1326. }
  1327. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1328. return srv.(VolumeServerServer).VolumeEcShardsUnmount(ctx, req.(*VolumeEcShardsUnmountRequest))
  1329. }
  1330. return interceptor(ctx, in, info, handler)
  1331. }
  1332. func _VolumeServer_VolumeEcShardRead_Handler(srv interface{}, stream grpc.ServerStream) error {
  1333. m := new(VolumeEcShardReadRequest)
  1334. if err := stream.RecvMsg(m); err != nil {
  1335. return err
  1336. }
  1337. return srv.(VolumeServerServer).VolumeEcShardRead(m, &volumeServerVolumeEcShardReadServer{stream})
  1338. }
  1339. type VolumeServer_VolumeEcShardReadServer interface {
  1340. Send(*VolumeEcShardReadResponse) error
  1341. grpc.ServerStream
  1342. }
  1343. type volumeServerVolumeEcShardReadServer struct {
  1344. grpc.ServerStream
  1345. }
  1346. func (x *volumeServerVolumeEcShardReadServer) Send(m *VolumeEcShardReadResponse) error {
  1347. return x.ServerStream.SendMsg(m)
  1348. }
  1349. func _VolumeServer_VolumeEcBlobDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1350. in := new(VolumeEcBlobDeleteRequest)
  1351. if err := dec(in); err != nil {
  1352. return nil, err
  1353. }
  1354. if interceptor == nil {
  1355. return srv.(VolumeServerServer).VolumeEcBlobDelete(ctx, in)
  1356. }
  1357. info := &grpc.UnaryServerInfo{
  1358. Server: srv,
  1359. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcBlobDelete",
  1360. }
  1361. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1362. return srv.(VolumeServerServer).VolumeEcBlobDelete(ctx, req.(*VolumeEcBlobDeleteRequest))
  1363. }
  1364. return interceptor(ctx, in, info, handler)
  1365. }
  1366. func _VolumeServer_VolumeEcShardsToVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1367. in := new(VolumeEcShardsToVolumeRequest)
  1368. if err := dec(in); err != nil {
  1369. return nil, err
  1370. }
  1371. if interceptor == nil {
  1372. return srv.(VolumeServerServer).VolumeEcShardsToVolume(ctx, in)
  1373. }
  1374. info := &grpc.UnaryServerInfo{
  1375. Server: srv,
  1376. FullMethod: "/volume_server_pb.VolumeServer/VolumeEcShardsToVolume",
  1377. }
  1378. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1379. return srv.(VolumeServerServer).VolumeEcShardsToVolume(ctx, req.(*VolumeEcShardsToVolumeRequest))
  1380. }
  1381. return interceptor(ctx, in, info, handler)
  1382. }
  1383. func _VolumeServer_VolumeTierMoveDatToRemote_Handler(srv interface{}, stream grpc.ServerStream) error {
  1384. m := new(VolumeTierMoveDatToRemoteRequest)
  1385. if err := stream.RecvMsg(m); err != nil {
  1386. return err
  1387. }
  1388. return srv.(VolumeServerServer).VolumeTierMoveDatToRemote(m, &volumeServerVolumeTierMoveDatToRemoteServer{stream})
  1389. }
  1390. type VolumeServer_VolumeTierMoveDatToRemoteServer interface {
  1391. Send(*VolumeTierMoveDatToRemoteResponse) error
  1392. grpc.ServerStream
  1393. }
  1394. type volumeServerVolumeTierMoveDatToRemoteServer struct {
  1395. grpc.ServerStream
  1396. }
  1397. func (x *volumeServerVolumeTierMoveDatToRemoteServer) Send(m *VolumeTierMoveDatToRemoteResponse) error {
  1398. return x.ServerStream.SendMsg(m)
  1399. }
  1400. func _VolumeServer_VolumeTierMoveDatFromRemote_Handler(srv interface{}, stream grpc.ServerStream) error {
  1401. m := new(VolumeTierMoveDatFromRemoteRequest)
  1402. if err := stream.RecvMsg(m); err != nil {
  1403. return err
  1404. }
  1405. return srv.(VolumeServerServer).VolumeTierMoveDatFromRemote(m, &volumeServerVolumeTierMoveDatFromRemoteServer{stream})
  1406. }
  1407. type VolumeServer_VolumeTierMoveDatFromRemoteServer interface {
  1408. Send(*VolumeTierMoveDatFromRemoteResponse) error
  1409. grpc.ServerStream
  1410. }
  1411. type volumeServerVolumeTierMoveDatFromRemoteServer struct {
  1412. grpc.ServerStream
  1413. }
  1414. func (x *volumeServerVolumeTierMoveDatFromRemoteServer) Send(m *VolumeTierMoveDatFromRemoteResponse) error {
  1415. return x.ServerStream.SendMsg(m)
  1416. }
  1417. func _VolumeServer_VolumeServerStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1418. in := new(VolumeServerStatusRequest)
  1419. if err := dec(in); err != nil {
  1420. return nil, err
  1421. }
  1422. if interceptor == nil {
  1423. return srv.(VolumeServerServer).VolumeServerStatus(ctx, in)
  1424. }
  1425. info := &grpc.UnaryServerInfo{
  1426. Server: srv,
  1427. FullMethod: "/volume_server_pb.VolumeServer/VolumeServerStatus",
  1428. }
  1429. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1430. return srv.(VolumeServerServer).VolumeServerStatus(ctx, req.(*VolumeServerStatusRequest))
  1431. }
  1432. return interceptor(ctx, in, info, handler)
  1433. }
  1434. func _VolumeServer_VolumeServerLeave_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1435. in := new(VolumeServerLeaveRequest)
  1436. if err := dec(in); err != nil {
  1437. return nil, err
  1438. }
  1439. if interceptor == nil {
  1440. return srv.(VolumeServerServer).VolumeServerLeave(ctx, in)
  1441. }
  1442. info := &grpc.UnaryServerInfo{
  1443. Server: srv,
  1444. FullMethod: "/volume_server_pb.VolumeServer/VolumeServerLeave",
  1445. }
  1446. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1447. return srv.(VolumeServerServer).VolumeServerLeave(ctx, req.(*VolumeServerLeaveRequest))
  1448. }
  1449. return interceptor(ctx, in, info, handler)
  1450. }
  1451. func _VolumeServer_FetchAndWriteNeedle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1452. in := new(FetchAndWriteNeedleRequest)
  1453. if err := dec(in); err != nil {
  1454. return nil, err
  1455. }
  1456. if interceptor == nil {
  1457. return srv.(VolumeServerServer).FetchAndWriteNeedle(ctx, in)
  1458. }
  1459. info := &grpc.UnaryServerInfo{
  1460. Server: srv,
  1461. FullMethod: "/volume_server_pb.VolumeServer/FetchAndWriteNeedle",
  1462. }
  1463. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1464. return srv.(VolumeServerServer).FetchAndWriteNeedle(ctx, req.(*FetchAndWriteNeedleRequest))
  1465. }
  1466. return interceptor(ctx, in, info, handler)
  1467. }
  1468. func _VolumeServer_Query_Handler(srv interface{}, stream grpc.ServerStream) error {
  1469. m := new(QueryRequest)
  1470. if err := stream.RecvMsg(m); err != nil {
  1471. return err
  1472. }
  1473. return srv.(VolumeServerServer).Query(m, &volumeServerQueryServer{stream})
  1474. }
  1475. type VolumeServer_QueryServer interface {
  1476. Send(*QueriedStripe) error
  1477. grpc.ServerStream
  1478. }
  1479. type volumeServerQueryServer struct {
  1480. grpc.ServerStream
  1481. }
  1482. func (x *volumeServerQueryServer) Send(m *QueriedStripe) error {
  1483. return x.ServerStream.SendMsg(m)
  1484. }
  1485. func _VolumeServer_VolumeNeedleStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1486. in := new(VolumeNeedleStatusRequest)
  1487. if err := dec(in); err != nil {
  1488. return nil, err
  1489. }
  1490. if interceptor == nil {
  1491. return srv.(VolumeServerServer).VolumeNeedleStatus(ctx, in)
  1492. }
  1493. info := &grpc.UnaryServerInfo{
  1494. Server: srv,
  1495. FullMethod: "/volume_server_pb.VolumeServer/VolumeNeedleStatus",
  1496. }
  1497. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1498. return srv.(VolumeServerServer).VolumeNeedleStatus(ctx, req.(*VolumeNeedleStatusRequest))
  1499. }
  1500. return interceptor(ctx, in, info, handler)
  1501. }
  1502. func _VolumeServer_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1503. in := new(PingRequest)
  1504. if err := dec(in); err != nil {
  1505. return nil, err
  1506. }
  1507. if interceptor == nil {
  1508. return srv.(VolumeServerServer).Ping(ctx, in)
  1509. }
  1510. info := &grpc.UnaryServerInfo{
  1511. Server: srv,
  1512. FullMethod: "/volume_server_pb.VolumeServer/Ping",
  1513. }
  1514. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1515. return srv.(VolumeServerServer).Ping(ctx, req.(*PingRequest))
  1516. }
  1517. return interceptor(ctx, in, info, handler)
  1518. }
  1519. // VolumeServer_ServiceDesc is the grpc.ServiceDesc for VolumeServer service.
  1520. // It's only intended for direct use with grpc.RegisterService,
  1521. // and not to be introspected or modified (even as a copy)
  1522. var VolumeServer_ServiceDesc = grpc.ServiceDesc{
  1523. ServiceName: "volume_server_pb.VolumeServer",
  1524. HandlerType: (*VolumeServerServer)(nil),
  1525. Methods: []grpc.MethodDesc{
  1526. {
  1527. MethodName: "BatchDelete",
  1528. Handler: _VolumeServer_BatchDelete_Handler,
  1529. },
  1530. {
  1531. MethodName: "VacuumVolumeCheck",
  1532. Handler: _VolumeServer_VacuumVolumeCheck_Handler,
  1533. },
  1534. {
  1535. MethodName: "VacuumVolumeCommit",
  1536. Handler: _VolumeServer_VacuumVolumeCommit_Handler,
  1537. },
  1538. {
  1539. MethodName: "VacuumVolumeCleanup",
  1540. Handler: _VolumeServer_VacuumVolumeCleanup_Handler,
  1541. },
  1542. {
  1543. MethodName: "DeleteCollection",
  1544. Handler: _VolumeServer_DeleteCollection_Handler,
  1545. },
  1546. {
  1547. MethodName: "AllocateVolume",
  1548. Handler: _VolumeServer_AllocateVolume_Handler,
  1549. },
  1550. {
  1551. MethodName: "VolumeSyncStatus",
  1552. Handler: _VolumeServer_VolumeSyncStatus_Handler,
  1553. },
  1554. {
  1555. MethodName: "VolumeMount",
  1556. Handler: _VolumeServer_VolumeMount_Handler,
  1557. },
  1558. {
  1559. MethodName: "VolumeUnmount",
  1560. Handler: _VolumeServer_VolumeUnmount_Handler,
  1561. },
  1562. {
  1563. MethodName: "VolumeDelete",
  1564. Handler: _VolumeServer_VolumeDelete_Handler,
  1565. },
  1566. {
  1567. MethodName: "VolumeMarkReadonly",
  1568. Handler: _VolumeServer_VolumeMarkReadonly_Handler,
  1569. },
  1570. {
  1571. MethodName: "VolumeMarkWritable",
  1572. Handler: _VolumeServer_VolumeMarkWritable_Handler,
  1573. },
  1574. {
  1575. MethodName: "VolumeConfigure",
  1576. Handler: _VolumeServer_VolumeConfigure_Handler,
  1577. },
  1578. {
  1579. MethodName: "VolumeStatus",
  1580. Handler: _VolumeServer_VolumeStatus_Handler,
  1581. },
  1582. {
  1583. MethodName: "ReadVolumeFileStatus",
  1584. Handler: _VolumeServer_ReadVolumeFileStatus_Handler,
  1585. },
  1586. {
  1587. MethodName: "ReadNeedleBlob",
  1588. Handler: _VolumeServer_ReadNeedleBlob_Handler,
  1589. },
  1590. {
  1591. MethodName: "ReadNeedleMeta",
  1592. Handler: _VolumeServer_ReadNeedleMeta_Handler,
  1593. },
  1594. {
  1595. MethodName: "WriteNeedleBlob",
  1596. Handler: _VolumeServer_WriteNeedleBlob_Handler,
  1597. },
  1598. {
  1599. MethodName: "VolumeTailReceiver",
  1600. Handler: _VolumeServer_VolumeTailReceiver_Handler,
  1601. },
  1602. {
  1603. MethodName: "VolumeEcShardsGenerate",
  1604. Handler: _VolumeServer_VolumeEcShardsGenerate_Handler,
  1605. },
  1606. {
  1607. MethodName: "VolumeEcShardsRebuild",
  1608. Handler: _VolumeServer_VolumeEcShardsRebuild_Handler,
  1609. },
  1610. {
  1611. MethodName: "VolumeEcShardsCopy",
  1612. Handler: _VolumeServer_VolumeEcShardsCopy_Handler,
  1613. },
  1614. {
  1615. MethodName: "VolumeEcShardsDelete",
  1616. Handler: _VolumeServer_VolumeEcShardsDelete_Handler,
  1617. },
  1618. {
  1619. MethodName: "VolumeEcShardsMount",
  1620. Handler: _VolumeServer_VolumeEcShardsMount_Handler,
  1621. },
  1622. {
  1623. MethodName: "VolumeEcShardsUnmount",
  1624. Handler: _VolumeServer_VolumeEcShardsUnmount_Handler,
  1625. },
  1626. {
  1627. MethodName: "VolumeEcBlobDelete",
  1628. Handler: _VolumeServer_VolumeEcBlobDelete_Handler,
  1629. },
  1630. {
  1631. MethodName: "VolumeEcShardsToVolume",
  1632. Handler: _VolumeServer_VolumeEcShardsToVolume_Handler,
  1633. },
  1634. {
  1635. MethodName: "VolumeServerStatus",
  1636. Handler: _VolumeServer_VolumeServerStatus_Handler,
  1637. },
  1638. {
  1639. MethodName: "VolumeServerLeave",
  1640. Handler: _VolumeServer_VolumeServerLeave_Handler,
  1641. },
  1642. {
  1643. MethodName: "FetchAndWriteNeedle",
  1644. Handler: _VolumeServer_FetchAndWriteNeedle_Handler,
  1645. },
  1646. {
  1647. MethodName: "VolumeNeedleStatus",
  1648. Handler: _VolumeServer_VolumeNeedleStatus_Handler,
  1649. },
  1650. {
  1651. MethodName: "Ping",
  1652. Handler: _VolumeServer_Ping_Handler,
  1653. },
  1654. },
  1655. Streams: []grpc.StreamDesc{
  1656. {
  1657. StreamName: "VacuumVolumeCompact",
  1658. Handler: _VolumeServer_VacuumVolumeCompact_Handler,
  1659. ServerStreams: true,
  1660. },
  1661. {
  1662. StreamName: "VolumeIncrementalCopy",
  1663. Handler: _VolumeServer_VolumeIncrementalCopy_Handler,
  1664. ServerStreams: true,
  1665. },
  1666. {
  1667. StreamName: "VolumeCopy",
  1668. Handler: _VolumeServer_VolumeCopy_Handler,
  1669. ServerStreams: true,
  1670. },
  1671. {
  1672. StreamName: "CopyFile",
  1673. Handler: _VolumeServer_CopyFile_Handler,
  1674. ServerStreams: true,
  1675. },
  1676. {
  1677. StreamName: "ReadAllNeedles",
  1678. Handler: _VolumeServer_ReadAllNeedles_Handler,
  1679. ServerStreams: true,
  1680. },
  1681. {
  1682. StreamName: "VolumeTailSender",
  1683. Handler: _VolumeServer_VolumeTailSender_Handler,
  1684. ServerStreams: true,
  1685. },
  1686. {
  1687. StreamName: "VolumeEcShardRead",
  1688. Handler: _VolumeServer_VolumeEcShardRead_Handler,
  1689. ServerStreams: true,
  1690. },
  1691. {
  1692. StreamName: "VolumeTierMoveDatToRemote",
  1693. Handler: _VolumeServer_VolumeTierMoveDatToRemote_Handler,
  1694. ServerStreams: true,
  1695. },
  1696. {
  1697. StreamName: "VolumeTierMoveDatFromRemote",
  1698. Handler: _VolumeServer_VolumeTierMoveDatFromRemote_Handler,
  1699. ServerStreams: true,
  1700. },
  1701. {
  1702. StreamName: "Query",
  1703. Handler: _VolumeServer_Query_Handler,
  1704. ServerStreams: true,
  1705. },
  1706. },
  1707. Metadata: "volume_server.proto",
  1708. }