You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

1909 lines
78 KiB

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