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.

1791 lines
69 KiB

6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
  1. // Code generated by protoc-gen-go.
  2. // source: volume_server.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package volume_server_pb is a generated protocol buffer package.
  6. It is generated from these files:
  7. volume_server.proto
  8. It has these top-level messages:
  9. BatchDeleteRequest
  10. BatchDeleteResponse
  11. DeleteResult
  12. Empty
  13. VacuumVolumeCheckRequest
  14. VacuumVolumeCheckResponse
  15. VacuumVolumeCompactRequest
  16. VacuumVolumeCompactResponse
  17. VacuumVolumeCommitRequest
  18. VacuumVolumeCommitResponse
  19. VacuumVolumeCleanupRequest
  20. VacuumVolumeCleanupResponse
  21. DeleteCollectionRequest
  22. DeleteCollectionResponse
  23. AllocateVolumeRequest
  24. AllocateVolumeResponse
  25. VolumeSyncStatusRequest
  26. VolumeSyncStatusResponse
  27. VolumeIncrementalCopyRequest
  28. VolumeIncrementalCopyResponse
  29. VolumeMountRequest
  30. VolumeMountResponse
  31. VolumeUnmountRequest
  32. VolumeUnmountResponse
  33. VolumeDeleteRequest
  34. VolumeDeleteResponse
  35. VolumeCopyRequest
  36. VolumeCopyResponse
  37. CopyFileRequest
  38. CopyFileResponse
  39. VolumeTailSenderRequest
  40. VolumeTailSenderResponse
  41. VolumeTailReceiverRequest
  42. VolumeTailReceiverResponse
  43. ReadVolumeFileStatusRequest
  44. ReadVolumeFileStatusResponse
  45. DiskStatus
  46. MemStatus
  47. */
  48. package volume_server_pb
  49. import proto "github.com/golang/protobuf/proto"
  50. import fmt "fmt"
  51. import math "math"
  52. import (
  53. context "golang.org/x/net/context"
  54. grpc "google.golang.org/grpc"
  55. )
  56. // Reference imports to suppress errors if they are not otherwise used.
  57. var _ = proto.Marshal
  58. var _ = fmt.Errorf
  59. var _ = math.Inf
  60. // This is a compile-time assertion to ensure that this generated file
  61. // is compatible with the proto package it is being compiled against.
  62. // A compilation error at this line likely means your copy of the
  63. // proto package needs to be updated.
  64. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  65. type BatchDeleteRequest struct {
  66. FileIds []string `protobuf:"bytes,1,rep,name=file_ids,json=fileIds" json:"file_ids,omitempty"`
  67. }
  68. func (m *BatchDeleteRequest) Reset() { *m = BatchDeleteRequest{} }
  69. func (m *BatchDeleteRequest) String() string { return proto.CompactTextString(m) }
  70. func (*BatchDeleteRequest) ProtoMessage() {}
  71. func (*BatchDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
  72. func (m *BatchDeleteRequest) GetFileIds() []string {
  73. if m != nil {
  74. return m.FileIds
  75. }
  76. return nil
  77. }
  78. type BatchDeleteResponse struct {
  79. Results []*DeleteResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
  80. }
  81. func (m *BatchDeleteResponse) Reset() { *m = BatchDeleteResponse{} }
  82. func (m *BatchDeleteResponse) String() string { return proto.CompactTextString(m) }
  83. func (*BatchDeleteResponse) ProtoMessage() {}
  84. func (*BatchDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
  85. func (m *BatchDeleteResponse) GetResults() []*DeleteResult {
  86. if m != nil {
  87. return m.Results
  88. }
  89. return nil
  90. }
  91. type DeleteResult struct {
  92. FileId string `protobuf:"bytes,1,opt,name=file_id,json=fileId" json:"file_id,omitempty"`
  93. Status int32 `protobuf:"varint,2,opt,name=status" json:"status,omitempty"`
  94. Error string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
  95. Size uint32 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
  96. }
  97. func (m *DeleteResult) Reset() { *m = DeleteResult{} }
  98. func (m *DeleteResult) String() string { return proto.CompactTextString(m) }
  99. func (*DeleteResult) ProtoMessage() {}
  100. func (*DeleteResult) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
  101. func (m *DeleteResult) GetFileId() string {
  102. if m != nil {
  103. return m.FileId
  104. }
  105. return ""
  106. }
  107. func (m *DeleteResult) GetStatus() int32 {
  108. if m != nil {
  109. return m.Status
  110. }
  111. return 0
  112. }
  113. func (m *DeleteResult) GetError() string {
  114. if m != nil {
  115. return m.Error
  116. }
  117. return ""
  118. }
  119. func (m *DeleteResult) GetSize() uint32 {
  120. if m != nil {
  121. return m.Size
  122. }
  123. return 0
  124. }
  125. type Empty struct {
  126. }
  127. func (m *Empty) Reset() { *m = Empty{} }
  128. func (m *Empty) String() string { return proto.CompactTextString(m) }
  129. func (*Empty) ProtoMessage() {}
  130. func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
  131. type VacuumVolumeCheckRequest struct {
  132. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  133. }
  134. func (m *VacuumVolumeCheckRequest) Reset() { *m = VacuumVolumeCheckRequest{} }
  135. func (m *VacuumVolumeCheckRequest) String() string { return proto.CompactTextString(m) }
  136. func (*VacuumVolumeCheckRequest) ProtoMessage() {}
  137. func (*VacuumVolumeCheckRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
  138. func (m *VacuumVolumeCheckRequest) GetVolumeId() uint32 {
  139. if m != nil {
  140. return m.VolumeId
  141. }
  142. return 0
  143. }
  144. type VacuumVolumeCheckResponse struct {
  145. GarbageRatio float64 `protobuf:"fixed64,1,opt,name=garbage_ratio,json=garbageRatio" json:"garbage_ratio,omitempty"`
  146. }
  147. func (m *VacuumVolumeCheckResponse) Reset() { *m = VacuumVolumeCheckResponse{} }
  148. func (m *VacuumVolumeCheckResponse) String() string { return proto.CompactTextString(m) }
  149. func (*VacuumVolumeCheckResponse) ProtoMessage() {}
  150. func (*VacuumVolumeCheckResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
  151. func (m *VacuumVolumeCheckResponse) GetGarbageRatio() float64 {
  152. if m != nil {
  153. return m.GarbageRatio
  154. }
  155. return 0
  156. }
  157. type VacuumVolumeCompactRequest struct {
  158. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  159. Preallocate int64 `protobuf:"varint,2,opt,name=preallocate" json:"preallocate,omitempty"`
  160. }
  161. func (m *VacuumVolumeCompactRequest) Reset() { *m = VacuumVolumeCompactRequest{} }
  162. func (m *VacuumVolumeCompactRequest) String() string { return proto.CompactTextString(m) }
  163. func (*VacuumVolumeCompactRequest) ProtoMessage() {}
  164. func (*VacuumVolumeCompactRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
  165. func (m *VacuumVolumeCompactRequest) GetVolumeId() uint32 {
  166. if m != nil {
  167. return m.VolumeId
  168. }
  169. return 0
  170. }
  171. func (m *VacuumVolumeCompactRequest) GetPreallocate() int64 {
  172. if m != nil {
  173. return m.Preallocate
  174. }
  175. return 0
  176. }
  177. type VacuumVolumeCompactResponse struct {
  178. }
  179. func (m *VacuumVolumeCompactResponse) Reset() { *m = VacuumVolumeCompactResponse{} }
  180. func (m *VacuumVolumeCompactResponse) String() string { return proto.CompactTextString(m) }
  181. func (*VacuumVolumeCompactResponse) ProtoMessage() {}
  182. func (*VacuumVolumeCompactResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
  183. type VacuumVolumeCommitRequest struct {
  184. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  185. }
  186. func (m *VacuumVolumeCommitRequest) Reset() { *m = VacuumVolumeCommitRequest{} }
  187. func (m *VacuumVolumeCommitRequest) String() string { return proto.CompactTextString(m) }
  188. func (*VacuumVolumeCommitRequest) ProtoMessage() {}
  189. func (*VacuumVolumeCommitRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
  190. func (m *VacuumVolumeCommitRequest) GetVolumeId() uint32 {
  191. if m != nil {
  192. return m.VolumeId
  193. }
  194. return 0
  195. }
  196. type VacuumVolumeCommitResponse struct {
  197. }
  198. func (m *VacuumVolumeCommitResponse) Reset() { *m = VacuumVolumeCommitResponse{} }
  199. func (m *VacuumVolumeCommitResponse) String() string { return proto.CompactTextString(m) }
  200. func (*VacuumVolumeCommitResponse) ProtoMessage() {}
  201. func (*VacuumVolumeCommitResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
  202. type VacuumVolumeCleanupRequest struct {
  203. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  204. }
  205. func (m *VacuumVolumeCleanupRequest) Reset() { *m = VacuumVolumeCleanupRequest{} }
  206. func (m *VacuumVolumeCleanupRequest) String() string { return proto.CompactTextString(m) }
  207. func (*VacuumVolumeCleanupRequest) ProtoMessage() {}
  208. func (*VacuumVolumeCleanupRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
  209. func (m *VacuumVolumeCleanupRequest) GetVolumeId() uint32 {
  210. if m != nil {
  211. return m.VolumeId
  212. }
  213. return 0
  214. }
  215. type VacuumVolumeCleanupResponse struct {
  216. }
  217. func (m *VacuumVolumeCleanupResponse) Reset() { *m = VacuumVolumeCleanupResponse{} }
  218. func (m *VacuumVolumeCleanupResponse) String() string { return proto.CompactTextString(m) }
  219. func (*VacuumVolumeCleanupResponse) ProtoMessage() {}
  220. func (*VacuumVolumeCleanupResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
  221. type DeleteCollectionRequest struct {
  222. Collection string `protobuf:"bytes,1,opt,name=collection" json:"collection,omitempty"`
  223. }
  224. func (m *DeleteCollectionRequest) Reset() { *m = DeleteCollectionRequest{} }
  225. func (m *DeleteCollectionRequest) String() string { return proto.CompactTextString(m) }
  226. func (*DeleteCollectionRequest) ProtoMessage() {}
  227. func (*DeleteCollectionRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
  228. func (m *DeleteCollectionRequest) GetCollection() string {
  229. if m != nil {
  230. return m.Collection
  231. }
  232. return ""
  233. }
  234. type DeleteCollectionResponse struct {
  235. }
  236. func (m *DeleteCollectionResponse) Reset() { *m = DeleteCollectionResponse{} }
  237. func (m *DeleteCollectionResponse) String() string { return proto.CompactTextString(m) }
  238. func (*DeleteCollectionResponse) ProtoMessage() {}
  239. func (*DeleteCollectionResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
  240. type AllocateVolumeRequest struct {
  241. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  242. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  243. Preallocate int64 `protobuf:"varint,3,opt,name=preallocate" json:"preallocate,omitempty"`
  244. Replication string `protobuf:"bytes,4,opt,name=replication" json:"replication,omitempty"`
  245. Ttl string `protobuf:"bytes,5,opt,name=ttl" json:"ttl,omitempty"`
  246. }
  247. func (m *AllocateVolumeRequest) Reset() { *m = AllocateVolumeRequest{} }
  248. func (m *AllocateVolumeRequest) String() string { return proto.CompactTextString(m) }
  249. func (*AllocateVolumeRequest) ProtoMessage() {}
  250. func (*AllocateVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
  251. func (m *AllocateVolumeRequest) GetVolumeId() uint32 {
  252. if m != nil {
  253. return m.VolumeId
  254. }
  255. return 0
  256. }
  257. func (m *AllocateVolumeRequest) GetCollection() string {
  258. if m != nil {
  259. return m.Collection
  260. }
  261. return ""
  262. }
  263. func (m *AllocateVolumeRequest) GetPreallocate() int64 {
  264. if m != nil {
  265. return m.Preallocate
  266. }
  267. return 0
  268. }
  269. func (m *AllocateVolumeRequest) GetReplication() string {
  270. if m != nil {
  271. return m.Replication
  272. }
  273. return ""
  274. }
  275. func (m *AllocateVolumeRequest) GetTtl() string {
  276. if m != nil {
  277. return m.Ttl
  278. }
  279. return ""
  280. }
  281. type AllocateVolumeResponse struct {
  282. }
  283. func (m *AllocateVolumeResponse) Reset() { *m = AllocateVolumeResponse{} }
  284. func (m *AllocateVolumeResponse) String() string { return proto.CompactTextString(m) }
  285. func (*AllocateVolumeResponse) ProtoMessage() {}
  286. func (*AllocateVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
  287. type VolumeSyncStatusRequest struct {
  288. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  289. }
  290. func (m *VolumeSyncStatusRequest) Reset() { *m = VolumeSyncStatusRequest{} }
  291. func (m *VolumeSyncStatusRequest) String() string { return proto.CompactTextString(m) }
  292. func (*VolumeSyncStatusRequest) ProtoMessage() {}
  293. func (*VolumeSyncStatusRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
  294. func (m *VolumeSyncStatusRequest) GetVolumeId() uint32 {
  295. if m != nil {
  296. return m.VolumeId
  297. }
  298. return 0
  299. }
  300. type VolumeSyncStatusResponse struct {
  301. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  302. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  303. Replication string `protobuf:"bytes,4,opt,name=replication" json:"replication,omitempty"`
  304. Ttl string `protobuf:"bytes,5,opt,name=ttl" json:"ttl,omitempty"`
  305. TailOffset uint64 `protobuf:"varint,6,opt,name=tail_offset,json=tailOffset" json:"tail_offset,omitempty"`
  306. CompactRevision uint32 `protobuf:"varint,7,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
  307. IdxFileSize uint64 `protobuf:"varint,8,opt,name=idx_file_size,json=idxFileSize" json:"idx_file_size,omitempty"`
  308. }
  309. func (m *VolumeSyncStatusResponse) Reset() { *m = VolumeSyncStatusResponse{} }
  310. func (m *VolumeSyncStatusResponse) String() string { return proto.CompactTextString(m) }
  311. func (*VolumeSyncStatusResponse) ProtoMessage() {}
  312. func (*VolumeSyncStatusResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} }
  313. func (m *VolumeSyncStatusResponse) GetVolumeId() uint32 {
  314. if m != nil {
  315. return m.VolumeId
  316. }
  317. return 0
  318. }
  319. func (m *VolumeSyncStatusResponse) GetCollection() string {
  320. if m != nil {
  321. return m.Collection
  322. }
  323. return ""
  324. }
  325. func (m *VolumeSyncStatusResponse) GetReplication() string {
  326. if m != nil {
  327. return m.Replication
  328. }
  329. return ""
  330. }
  331. func (m *VolumeSyncStatusResponse) GetTtl() string {
  332. if m != nil {
  333. return m.Ttl
  334. }
  335. return ""
  336. }
  337. func (m *VolumeSyncStatusResponse) GetTailOffset() uint64 {
  338. if m != nil {
  339. return m.TailOffset
  340. }
  341. return 0
  342. }
  343. func (m *VolumeSyncStatusResponse) GetCompactRevision() uint32 {
  344. if m != nil {
  345. return m.CompactRevision
  346. }
  347. return 0
  348. }
  349. func (m *VolumeSyncStatusResponse) GetIdxFileSize() uint64 {
  350. if m != nil {
  351. return m.IdxFileSize
  352. }
  353. return 0
  354. }
  355. type VolumeIncrementalCopyRequest struct {
  356. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  357. SinceNs uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
  358. }
  359. func (m *VolumeIncrementalCopyRequest) Reset() { *m = VolumeIncrementalCopyRequest{} }
  360. func (m *VolumeIncrementalCopyRequest) String() string { return proto.CompactTextString(m) }
  361. func (*VolumeIncrementalCopyRequest) ProtoMessage() {}
  362. func (*VolumeIncrementalCopyRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{18} }
  363. func (m *VolumeIncrementalCopyRequest) GetVolumeId() uint32 {
  364. if m != nil {
  365. return m.VolumeId
  366. }
  367. return 0
  368. }
  369. func (m *VolumeIncrementalCopyRequest) GetSinceNs() uint64 {
  370. if m != nil {
  371. return m.SinceNs
  372. }
  373. return 0
  374. }
  375. type VolumeIncrementalCopyResponse struct {
  376. FileContent []byte `protobuf:"bytes,1,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
  377. }
  378. func (m *VolumeIncrementalCopyResponse) Reset() { *m = VolumeIncrementalCopyResponse{} }
  379. func (m *VolumeIncrementalCopyResponse) String() string { return proto.CompactTextString(m) }
  380. func (*VolumeIncrementalCopyResponse) ProtoMessage() {}
  381. func (*VolumeIncrementalCopyResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{19} }
  382. func (m *VolumeIncrementalCopyResponse) GetFileContent() []byte {
  383. if m != nil {
  384. return m.FileContent
  385. }
  386. return nil
  387. }
  388. type VolumeMountRequest struct {
  389. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  390. }
  391. func (m *VolumeMountRequest) Reset() { *m = VolumeMountRequest{} }
  392. func (m *VolumeMountRequest) String() string { return proto.CompactTextString(m) }
  393. func (*VolumeMountRequest) ProtoMessage() {}
  394. func (*VolumeMountRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{20} }
  395. func (m *VolumeMountRequest) GetVolumeId() uint32 {
  396. if m != nil {
  397. return m.VolumeId
  398. }
  399. return 0
  400. }
  401. type VolumeMountResponse struct {
  402. }
  403. func (m *VolumeMountResponse) Reset() { *m = VolumeMountResponse{} }
  404. func (m *VolumeMountResponse) String() string { return proto.CompactTextString(m) }
  405. func (*VolumeMountResponse) ProtoMessage() {}
  406. func (*VolumeMountResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{21} }
  407. type VolumeUnmountRequest struct {
  408. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  409. }
  410. func (m *VolumeUnmountRequest) Reset() { *m = VolumeUnmountRequest{} }
  411. func (m *VolumeUnmountRequest) String() string { return proto.CompactTextString(m) }
  412. func (*VolumeUnmountRequest) ProtoMessage() {}
  413. func (*VolumeUnmountRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{22} }
  414. func (m *VolumeUnmountRequest) GetVolumeId() uint32 {
  415. if m != nil {
  416. return m.VolumeId
  417. }
  418. return 0
  419. }
  420. type VolumeUnmountResponse struct {
  421. }
  422. func (m *VolumeUnmountResponse) Reset() { *m = VolumeUnmountResponse{} }
  423. func (m *VolumeUnmountResponse) String() string { return proto.CompactTextString(m) }
  424. func (*VolumeUnmountResponse) ProtoMessage() {}
  425. func (*VolumeUnmountResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{23} }
  426. type VolumeDeleteRequest struct {
  427. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  428. }
  429. func (m *VolumeDeleteRequest) Reset() { *m = VolumeDeleteRequest{} }
  430. func (m *VolumeDeleteRequest) String() string { return proto.CompactTextString(m) }
  431. func (*VolumeDeleteRequest) ProtoMessage() {}
  432. func (*VolumeDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{24} }
  433. func (m *VolumeDeleteRequest) GetVolumeId() uint32 {
  434. if m != nil {
  435. return m.VolumeId
  436. }
  437. return 0
  438. }
  439. type VolumeDeleteResponse struct {
  440. }
  441. func (m *VolumeDeleteResponse) Reset() { *m = VolumeDeleteResponse{} }
  442. func (m *VolumeDeleteResponse) String() string { return proto.CompactTextString(m) }
  443. func (*VolumeDeleteResponse) ProtoMessage() {}
  444. func (*VolumeDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{25} }
  445. type VolumeCopyRequest struct {
  446. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  447. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  448. Replication string `protobuf:"bytes,3,opt,name=replication" json:"replication,omitempty"`
  449. Ttl string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
  450. SourceDataNode string `protobuf:"bytes,5,opt,name=source_data_node,json=sourceDataNode" json:"source_data_node,omitempty"`
  451. }
  452. func (m *VolumeCopyRequest) Reset() { *m = VolumeCopyRequest{} }
  453. func (m *VolumeCopyRequest) String() string { return proto.CompactTextString(m) }
  454. func (*VolumeCopyRequest) ProtoMessage() {}
  455. func (*VolumeCopyRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{26} }
  456. func (m *VolumeCopyRequest) GetVolumeId() uint32 {
  457. if m != nil {
  458. return m.VolumeId
  459. }
  460. return 0
  461. }
  462. func (m *VolumeCopyRequest) GetCollection() string {
  463. if m != nil {
  464. return m.Collection
  465. }
  466. return ""
  467. }
  468. func (m *VolumeCopyRequest) GetReplication() string {
  469. if m != nil {
  470. return m.Replication
  471. }
  472. return ""
  473. }
  474. func (m *VolumeCopyRequest) GetTtl() string {
  475. if m != nil {
  476. return m.Ttl
  477. }
  478. return ""
  479. }
  480. func (m *VolumeCopyRequest) GetSourceDataNode() string {
  481. if m != nil {
  482. return m.SourceDataNode
  483. }
  484. return ""
  485. }
  486. type VolumeCopyResponse struct {
  487. LastAppendAtNs uint64 `protobuf:"varint,1,opt,name=last_append_at_ns,json=lastAppendAtNs" json:"last_append_at_ns,omitempty"`
  488. }
  489. func (m *VolumeCopyResponse) Reset() { *m = VolumeCopyResponse{} }
  490. func (m *VolumeCopyResponse) String() string { return proto.CompactTextString(m) }
  491. func (*VolumeCopyResponse) ProtoMessage() {}
  492. func (*VolumeCopyResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{27} }
  493. func (m *VolumeCopyResponse) GetLastAppendAtNs() uint64 {
  494. if m != nil {
  495. return m.LastAppendAtNs
  496. }
  497. return 0
  498. }
  499. type CopyFileRequest struct {
  500. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  501. IsIdxFile bool `protobuf:"varint,2,opt,name=is_idx_file,json=isIdxFile" json:"is_idx_file,omitempty"`
  502. IsDatFile bool `protobuf:"varint,3,opt,name=is_dat_file,json=isDatFile" json:"is_dat_file,omitempty"`
  503. CompactionRevision uint32 `protobuf:"varint,4,opt,name=compaction_revision,json=compactionRevision" json:"compaction_revision,omitempty"`
  504. StopOffset uint64 `protobuf:"varint,5,opt,name=stop_offset,json=stopOffset" json:"stop_offset,omitempty"`
  505. }
  506. func (m *CopyFileRequest) Reset() { *m = CopyFileRequest{} }
  507. func (m *CopyFileRequest) String() string { return proto.CompactTextString(m) }
  508. func (*CopyFileRequest) ProtoMessage() {}
  509. func (*CopyFileRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{28} }
  510. func (m *CopyFileRequest) GetVolumeId() uint32 {
  511. if m != nil {
  512. return m.VolumeId
  513. }
  514. return 0
  515. }
  516. func (m *CopyFileRequest) GetIsIdxFile() bool {
  517. if m != nil {
  518. return m.IsIdxFile
  519. }
  520. return false
  521. }
  522. func (m *CopyFileRequest) GetIsDatFile() bool {
  523. if m != nil {
  524. return m.IsDatFile
  525. }
  526. return false
  527. }
  528. func (m *CopyFileRequest) GetCompactionRevision() uint32 {
  529. if m != nil {
  530. return m.CompactionRevision
  531. }
  532. return 0
  533. }
  534. func (m *CopyFileRequest) GetStopOffset() uint64 {
  535. if m != nil {
  536. return m.StopOffset
  537. }
  538. return 0
  539. }
  540. type CopyFileResponse struct {
  541. FileContent []byte `protobuf:"bytes,1,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
  542. }
  543. func (m *CopyFileResponse) Reset() { *m = CopyFileResponse{} }
  544. func (m *CopyFileResponse) String() string { return proto.CompactTextString(m) }
  545. func (*CopyFileResponse) ProtoMessage() {}
  546. func (*CopyFileResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{29} }
  547. func (m *CopyFileResponse) GetFileContent() []byte {
  548. if m != nil {
  549. return m.FileContent
  550. }
  551. return nil
  552. }
  553. type VolumeTailSenderRequest struct {
  554. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  555. SinceNs uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
  556. IdleTimeoutSeconds uint32 `protobuf:"varint,3,opt,name=idle_timeout_seconds,json=idleTimeoutSeconds" json:"idle_timeout_seconds,omitempty"`
  557. }
  558. func (m *VolumeTailSenderRequest) Reset() { *m = VolumeTailSenderRequest{} }
  559. func (m *VolumeTailSenderRequest) String() string { return proto.CompactTextString(m) }
  560. func (*VolumeTailSenderRequest) ProtoMessage() {}
  561. func (*VolumeTailSenderRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{30} }
  562. func (m *VolumeTailSenderRequest) GetVolumeId() uint32 {
  563. if m != nil {
  564. return m.VolumeId
  565. }
  566. return 0
  567. }
  568. func (m *VolumeTailSenderRequest) GetSinceNs() uint64 {
  569. if m != nil {
  570. return m.SinceNs
  571. }
  572. return 0
  573. }
  574. func (m *VolumeTailSenderRequest) GetIdleTimeoutSeconds() uint32 {
  575. if m != nil {
  576. return m.IdleTimeoutSeconds
  577. }
  578. return 0
  579. }
  580. type VolumeTailSenderResponse struct {
  581. NeedleHeader []byte `protobuf:"bytes,1,opt,name=needle_header,json=needleHeader,proto3" json:"needle_header,omitempty"`
  582. NeedleBody []byte `protobuf:"bytes,2,opt,name=needle_body,json=needleBody,proto3" json:"needle_body,omitempty"`
  583. IsLastChunk bool `protobuf:"varint,3,opt,name=is_last_chunk,json=isLastChunk" json:"is_last_chunk,omitempty"`
  584. }
  585. func (m *VolumeTailSenderResponse) Reset() { *m = VolumeTailSenderResponse{} }
  586. func (m *VolumeTailSenderResponse) String() string { return proto.CompactTextString(m) }
  587. func (*VolumeTailSenderResponse) ProtoMessage() {}
  588. func (*VolumeTailSenderResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{31} }
  589. func (m *VolumeTailSenderResponse) GetNeedleHeader() []byte {
  590. if m != nil {
  591. return m.NeedleHeader
  592. }
  593. return nil
  594. }
  595. func (m *VolumeTailSenderResponse) GetNeedleBody() []byte {
  596. if m != nil {
  597. return m.NeedleBody
  598. }
  599. return nil
  600. }
  601. func (m *VolumeTailSenderResponse) GetIsLastChunk() bool {
  602. if m != nil {
  603. return m.IsLastChunk
  604. }
  605. return false
  606. }
  607. type VolumeTailReceiverRequest struct {
  608. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  609. SinceNs uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
  610. IdleTimeoutSeconds uint32 `protobuf:"varint,3,opt,name=idle_timeout_seconds,json=idleTimeoutSeconds" json:"idle_timeout_seconds,omitempty"`
  611. SourceVolumeServer string `protobuf:"bytes,4,opt,name=source_volume_server,json=sourceVolumeServer" json:"source_volume_server,omitempty"`
  612. }
  613. func (m *VolumeTailReceiverRequest) Reset() { *m = VolumeTailReceiverRequest{} }
  614. func (m *VolumeTailReceiverRequest) String() string { return proto.CompactTextString(m) }
  615. func (*VolumeTailReceiverRequest) ProtoMessage() {}
  616. func (*VolumeTailReceiverRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{32} }
  617. func (m *VolumeTailReceiverRequest) GetVolumeId() uint32 {
  618. if m != nil {
  619. return m.VolumeId
  620. }
  621. return 0
  622. }
  623. func (m *VolumeTailReceiverRequest) GetSinceNs() uint64 {
  624. if m != nil {
  625. return m.SinceNs
  626. }
  627. return 0
  628. }
  629. func (m *VolumeTailReceiverRequest) GetIdleTimeoutSeconds() uint32 {
  630. if m != nil {
  631. return m.IdleTimeoutSeconds
  632. }
  633. return 0
  634. }
  635. func (m *VolumeTailReceiverRequest) GetSourceVolumeServer() string {
  636. if m != nil {
  637. return m.SourceVolumeServer
  638. }
  639. return ""
  640. }
  641. type VolumeTailReceiverResponse struct {
  642. }
  643. func (m *VolumeTailReceiverResponse) Reset() { *m = VolumeTailReceiverResponse{} }
  644. func (m *VolumeTailReceiverResponse) String() string { return proto.CompactTextString(m) }
  645. func (*VolumeTailReceiverResponse) ProtoMessage() {}
  646. func (*VolumeTailReceiverResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{33} }
  647. type ReadVolumeFileStatusRequest struct {
  648. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  649. }
  650. func (m *ReadVolumeFileStatusRequest) Reset() { *m = ReadVolumeFileStatusRequest{} }
  651. func (m *ReadVolumeFileStatusRequest) String() string { return proto.CompactTextString(m) }
  652. func (*ReadVolumeFileStatusRequest) ProtoMessage() {}
  653. func (*ReadVolumeFileStatusRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{34} }
  654. func (m *ReadVolumeFileStatusRequest) GetVolumeId() uint32 {
  655. if m != nil {
  656. return m.VolumeId
  657. }
  658. return 0
  659. }
  660. type ReadVolumeFileStatusResponse struct {
  661. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  662. IdxFileTimestampSeconds uint64 `protobuf:"varint,2,opt,name=idx_file_timestamp_seconds,json=idxFileTimestampSeconds" json:"idx_file_timestamp_seconds,omitempty"`
  663. IdxFileSize uint64 `protobuf:"varint,3,opt,name=idx_file_size,json=idxFileSize" json:"idx_file_size,omitempty"`
  664. DatFileTimestampSeconds uint64 `protobuf:"varint,4,opt,name=dat_file_timestamp_seconds,json=datFileTimestampSeconds" json:"dat_file_timestamp_seconds,omitempty"`
  665. DatFileSize uint64 `protobuf:"varint,5,opt,name=dat_file_size,json=datFileSize" json:"dat_file_size,omitempty"`
  666. FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  667. CompactionRevision uint32 `protobuf:"varint,7,opt,name=compaction_revision,json=compactionRevision" json:"compaction_revision,omitempty"`
  668. Collection string `protobuf:"bytes,8,opt,name=collection" json:"collection,omitempty"`
  669. }
  670. func (m *ReadVolumeFileStatusResponse) Reset() { *m = ReadVolumeFileStatusResponse{} }
  671. func (m *ReadVolumeFileStatusResponse) String() string { return proto.CompactTextString(m) }
  672. func (*ReadVolumeFileStatusResponse) ProtoMessage() {}
  673. func (*ReadVolumeFileStatusResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{35} }
  674. func (m *ReadVolumeFileStatusResponse) GetVolumeId() uint32 {
  675. if m != nil {
  676. return m.VolumeId
  677. }
  678. return 0
  679. }
  680. func (m *ReadVolumeFileStatusResponse) GetIdxFileTimestampSeconds() uint64 {
  681. if m != nil {
  682. return m.IdxFileTimestampSeconds
  683. }
  684. return 0
  685. }
  686. func (m *ReadVolumeFileStatusResponse) GetIdxFileSize() uint64 {
  687. if m != nil {
  688. return m.IdxFileSize
  689. }
  690. return 0
  691. }
  692. func (m *ReadVolumeFileStatusResponse) GetDatFileTimestampSeconds() uint64 {
  693. if m != nil {
  694. return m.DatFileTimestampSeconds
  695. }
  696. return 0
  697. }
  698. func (m *ReadVolumeFileStatusResponse) GetDatFileSize() uint64 {
  699. if m != nil {
  700. return m.DatFileSize
  701. }
  702. return 0
  703. }
  704. func (m *ReadVolumeFileStatusResponse) GetFileCount() uint64 {
  705. if m != nil {
  706. return m.FileCount
  707. }
  708. return 0
  709. }
  710. func (m *ReadVolumeFileStatusResponse) GetCompactionRevision() uint32 {
  711. if m != nil {
  712. return m.CompactionRevision
  713. }
  714. return 0
  715. }
  716. func (m *ReadVolumeFileStatusResponse) GetCollection() string {
  717. if m != nil {
  718. return m.Collection
  719. }
  720. return ""
  721. }
  722. type DiskStatus struct {
  723. Dir string `protobuf:"bytes,1,opt,name=dir" json:"dir,omitempty"`
  724. All uint64 `protobuf:"varint,2,opt,name=all" json:"all,omitempty"`
  725. Used uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
  726. Free uint64 `protobuf:"varint,4,opt,name=free" json:"free,omitempty"`
  727. }
  728. func (m *DiskStatus) Reset() { *m = DiskStatus{} }
  729. func (m *DiskStatus) String() string { return proto.CompactTextString(m) }
  730. func (*DiskStatus) ProtoMessage() {}
  731. func (*DiskStatus) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{36} }
  732. func (m *DiskStatus) GetDir() string {
  733. if m != nil {
  734. return m.Dir
  735. }
  736. return ""
  737. }
  738. func (m *DiskStatus) GetAll() uint64 {
  739. if m != nil {
  740. return m.All
  741. }
  742. return 0
  743. }
  744. func (m *DiskStatus) GetUsed() uint64 {
  745. if m != nil {
  746. return m.Used
  747. }
  748. return 0
  749. }
  750. func (m *DiskStatus) GetFree() uint64 {
  751. if m != nil {
  752. return m.Free
  753. }
  754. return 0
  755. }
  756. type MemStatus struct {
  757. Goroutines int32 `protobuf:"varint,1,opt,name=goroutines" json:"goroutines,omitempty"`
  758. All uint64 `protobuf:"varint,2,opt,name=all" json:"all,omitempty"`
  759. Used uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
  760. Free uint64 `protobuf:"varint,4,opt,name=free" json:"free,omitempty"`
  761. Self uint64 `protobuf:"varint,5,opt,name=self" json:"self,omitempty"`
  762. Heap uint64 `protobuf:"varint,6,opt,name=heap" json:"heap,omitempty"`
  763. Stack uint64 `protobuf:"varint,7,opt,name=stack" json:"stack,omitempty"`
  764. }
  765. func (m *MemStatus) Reset() { *m = MemStatus{} }
  766. func (m *MemStatus) String() string { return proto.CompactTextString(m) }
  767. func (*MemStatus) ProtoMessage() {}
  768. func (*MemStatus) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{37} }
  769. func (m *MemStatus) GetGoroutines() int32 {
  770. if m != nil {
  771. return m.Goroutines
  772. }
  773. return 0
  774. }
  775. func (m *MemStatus) GetAll() uint64 {
  776. if m != nil {
  777. return m.All
  778. }
  779. return 0
  780. }
  781. func (m *MemStatus) GetUsed() uint64 {
  782. if m != nil {
  783. return m.Used
  784. }
  785. return 0
  786. }
  787. func (m *MemStatus) GetFree() uint64 {
  788. if m != nil {
  789. return m.Free
  790. }
  791. return 0
  792. }
  793. func (m *MemStatus) GetSelf() uint64 {
  794. if m != nil {
  795. return m.Self
  796. }
  797. return 0
  798. }
  799. func (m *MemStatus) GetHeap() uint64 {
  800. if m != nil {
  801. return m.Heap
  802. }
  803. return 0
  804. }
  805. func (m *MemStatus) GetStack() uint64 {
  806. if m != nil {
  807. return m.Stack
  808. }
  809. return 0
  810. }
  811. func init() {
  812. proto.RegisterType((*BatchDeleteRequest)(nil), "volume_server_pb.BatchDeleteRequest")
  813. proto.RegisterType((*BatchDeleteResponse)(nil), "volume_server_pb.BatchDeleteResponse")
  814. proto.RegisterType((*DeleteResult)(nil), "volume_server_pb.DeleteResult")
  815. proto.RegisterType((*Empty)(nil), "volume_server_pb.Empty")
  816. proto.RegisterType((*VacuumVolumeCheckRequest)(nil), "volume_server_pb.VacuumVolumeCheckRequest")
  817. proto.RegisterType((*VacuumVolumeCheckResponse)(nil), "volume_server_pb.VacuumVolumeCheckResponse")
  818. proto.RegisterType((*VacuumVolumeCompactRequest)(nil), "volume_server_pb.VacuumVolumeCompactRequest")
  819. proto.RegisterType((*VacuumVolumeCompactResponse)(nil), "volume_server_pb.VacuumVolumeCompactResponse")
  820. proto.RegisterType((*VacuumVolumeCommitRequest)(nil), "volume_server_pb.VacuumVolumeCommitRequest")
  821. proto.RegisterType((*VacuumVolumeCommitResponse)(nil), "volume_server_pb.VacuumVolumeCommitResponse")
  822. proto.RegisterType((*VacuumVolumeCleanupRequest)(nil), "volume_server_pb.VacuumVolumeCleanupRequest")
  823. proto.RegisterType((*VacuumVolumeCleanupResponse)(nil), "volume_server_pb.VacuumVolumeCleanupResponse")
  824. proto.RegisterType((*DeleteCollectionRequest)(nil), "volume_server_pb.DeleteCollectionRequest")
  825. proto.RegisterType((*DeleteCollectionResponse)(nil), "volume_server_pb.DeleteCollectionResponse")
  826. proto.RegisterType((*AllocateVolumeRequest)(nil), "volume_server_pb.AllocateVolumeRequest")
  827. proto.RegisterType((*AllocateVolumeResponse)(nil), "volume_server_pb.AllocateVolumeResponse")
  828. proto.RegisterType((*VolumeSyncStatusRequest)(nil), "volume_server_pb.VolumeSyncStatusRequest")
  829. proto.RegisterType((*VolumeSyncStatusResponse)(nil), "volume_server_pb.VolumeSyncStatusResponse")
  830. proto.RegisterType((*VolumeIncrementalCopyRequest)(nil), "volume_server_pb.VolumeIncrementalCopyRequest")
  831. proto.RegisterType((*VolumeIncrementalCopyResponse)(nil), "volume_server_pb.VolumeIncrementalCopyResponse")
  832. proto.RegisterType((*VolumeMountRequest)(nil), "volume_server_pb.VolumeMountRequest")
  833. proto.RegisterType((*VolumeMountResponse)(nil), "volume_server_pb.VolumeMountResponse")
  834. proto.RegisterType((*VolumeUnmountRequest)(nil), "volume_server_pb.VolumeUnmountRequest")
  835. proto.RegisterType((*VolumeUnmountResponse)(nil), "volume_server_pb.VolumeUnmountResponse")
  836. proto.RegisterType((*VolumeDeleteRequest)(nil), "volume_server_pb.VolumeDeleteRequest")
  837. proto.RegisterType((*VolumeDeleteResponse)(nil), "volume_server_pb.VolumeDeleteResponse")
  838. proto.RegisterType((*VolumeCopyRequest)(nil), "volume_server_pb.VolumeCopyRequest")
  839. proto.RegisterType((*VolumeCopyResponse)(nil), "volume_server_pb.VolumeCopyResponse")
  840. proto.RegisterType((*CopyFileRequest)(nil), "volume_server_pb.CopyFileRequest")
  841. proto.RegisterType((*CopyFileResponse)(nil), "volume_server_pb.CopyFileResponse")
  842. proto.RegisterType((*VolumeTailSenderRequest)(nil), "volume_server_pb.VolumeTailSenderRequest")
  843. proto.RegisterType((*VolumeTailSenderResponse)(nil), "volume_server_pb.VolumeTailSenderResponse")
  844. proto.RegisterType((*VolumeTailReceiverRequest)(nil), "volume_server_pb.VolumeTailReceiverRequest")
  845. proto.RegisterType((*VolumeTailReceiverResponse)(nil), "volume_server_pb.VolumeTailReceiverResponse")
  846. proto.RegisterType((*ReadVolumeFileStatusRequest)(nil), "volume_server_pb.ReadVolumeFileStatusRequest")
  847. proto.RegisterType((*ReadVolumeFileStatusResponse)(nil), "volume_server_pb.ReadVolumeFileStatusResponse")
  848. proto.RegisterType((*DiskStatus)(nil), "volume_server_pb.DiskStatus")
  849. proto.RegisterType((*MemStatus)(nil), "volume_server_pb.MemStatus")
  850. }
  851. // Reference imports to suppress errors if they are not otherwise used.
  852. var _ context.Context
  853. var _ grpc.ClientConn
  854. // This is a compile-time assertion to ensure that this generated file
  855. // is compatible with the grpc package it is being compiled against.
  856. const _ = grpc.SupportPackageIsVersion4
  857. // Client API for VolumeServer service
  858. type VolumeServerClient interface {
  859. // Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
  860. BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error)
  861. VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error)
  862. VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (*VacuumVolumeCompactResponse, error)
  863. VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error)
  864. VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error)
  865. DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
  866. AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error)
  867. VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error)
  868. VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error)
  869. VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error)
  870. VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error)
  871. VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error)
  872. // copy the .idx .dat files, and mount this volume
  873. VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (*VolumeCopyResponse, error)
  874. ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error)
  875. CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error)
  876. VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error)
  877. VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error)
  878. }
  879. type volumeServerClient struct {
  880. cc *grpc.ClientConn
  881. }
  882. func NewVolumeServerClient(cc *grpc.ClientConn) VolumeServerClient {
  883. return &volumeServerClient{cc}
  884. }
  885. func (c *volumeServerClient) BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error) {
  886. out := new(BatchDeleteResponse)
  887. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/BatchDelete", in, out, c.cc, opts...)
  888. if err != nil {
  889. return nil, err
  890. }
  891. return out, nil
  892. }
  893. func (c *volumeServerClient) VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error) {
  894. out := new(VacuumVolumeCheckResponse)
  895. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCheck", in, out, c.cc, opts...)
  896. if err != nil {
  897. return nil, err
  898. }
  899. return out, nil
  900. }
  901. func (c *volumeServerClient) VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (*VacuumVolumeCompactResponse, error) {
  902. out := new(VacuumVolumeCompactResponse)
  903. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCompact", in, out, c.cc, opts...)
  904. if err != nil {
  905. return nil, err
  906. }
  907. return out, nil
  908. }
  909. func (c *volumeServerClient) VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error) {
  910. out := new(VacuumVolumeCommitResponse)
  911. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCommit", in, out, c.cc, opts...)
  912. if err != nil {
  913. return nil, err
  914. }
  915. return out, nil
  916. }
  917. func (c *volumeServerClient) VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error) {
  918. out := new(VacuumVolumeCleanupResponse)
  919. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VacuumVolumeCleanup", in, out, c.cc, opts...)
  920. if err != nil {
  921. return nil, err
  922. }
  923. return out, nil
  924. }
  925. func (c *volumeServerClient) DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) {
  926. out := new(DeleteCollectionResponse)
  927. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/DeleteCollection", in, out, c.cc, opts...)
  928. if err != nil {
  929. return nil, err
  930. }
  931. return out, nil
  932. }
  933. func (c *volumeServerClient) AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error) {
  934. out := new(AllocateVolumeResponse)
  935. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/AllocateVolume", in, out, c.cc, opts...)
  936. if err != nil {
  937. return nil, err
  938. }
  939. return out, nil
  940. }
  941. func (c *volumeServerClient) VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error) {
  942. out := new(VolumeSyncStatusResponse)
  943. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeSyncStatus", in, out, c.cc, opts...)
  944. if err != nil {
  945. return nil, err
  946. }
  947. return out, nil
  948. }
  949. func (c *volumeServerClient) VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error) {
  950. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[0], c.cc, "/volume_server_pb.VolumeServer/VolumeIncrementalCopy", opts...)
  951. if err != nil {
  952. return nil, err
  953. }
  954. x := &volumeServerVolumeIncrementalCopyClient{stream}
  955. if err := x.ClientStream.SendMsg(in); err != nil {
  956. return nil, err
  957. }
  958. if err := x.ClientStream.CloseSend(); err != nil {
  959. return nil, err
  960. }
  961. return x, nil
  962. }
  963. type VolumeServer_VolumeIncrementalCopyClient interface {
  964. Recv() (*VolumeIncrementalCopyResponse, error)
  965. grpc.ClientStream
  966. }
  967. type volumeServerVolumeIncrementalCopyClient struct {
  968. grpc.ClientStream
  969. }
  970. func (x *volumeServerVolumeIncrementalCopyClient) Recv() (*VolumeIncrementalCopyResponse, error) {
  971. m := new(VolumeIncrementalCopyResponse)
  972. if err := x.ClientStream.RecvMsg(m); err != nil {
  973. return nil, err
  974. }
  975. return m, nil
  976. }
  977. func (c *volumeServerClient) VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error) {
  978. out := new(VolumeMountResponse)
  979. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeMount", in, out, c.cc, opts...)
  980. if err != nil {
  981. return nil, err
  982. }
  983. return out, nil
  984. }
  985. func (c *volumeServerClient) VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error) {
  986. out := new(VolumeUnmountResponse)
  987. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeUnmount", in, out, c.cc, opts...)
  988. if err != nil {
  989. return nil, err
  990. }
  991. return out, nil
  992. }
  993. func (c *volumeServerClient) VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error) {
  994. out := new(VolumeDeleteResponse)
  995. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeDelete", in, out, c.cc, opts...)
  996. if err != nil {
  997. return nil, err
  998. }
  999. return out, nil
  1000. }
  1001. func (c *volumeServerClient) VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (*VolumeCopyResponse, error) {
  1002. out := new(VolumeCopyResponse)
  1003. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeCopy", in, out, c.cc, opts...)
  1004. if err != nil {
  1005. return nil, err
  1006. }
  1007. return out, nil
  1008. }
  1009. func (c *volumeServerClient) ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error) {
  1010. out := new(ReadVolumeFileStatusResponse)
  1011. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/ReadVolumeFileStatus", in, out, c.cc, opts...)
  1012. if err != nil {
  1013. return nil, err
  1014. }
  1015. return out, nil
  1016. }
  1017. func (c *volumeServerClient) CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error) {
  1018. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[1], c.cc, "/volume_server_pb.VolumeServer/CopyFile", opts...)
  1019. if err != nil {
  1020. return nil, err
  1021. }
  1022. x := &volumeServerCopyFileClient{stream}
  1023. if err := x.ClientStream.SendMsg(in); err != nil {
  1024. return nil, err
  1025. }
  1026. if err := x.ClientStream.CloseSend(); err != nil {
  1027. return nil, err
  1028. }
  1029. return x, nil
  1030. }
  1031. type VolumeServer_CopyFileClient interface {
  1032. Recv() (*CopyFileResponse, error)
  1033. grpc.ClientStream
  1034. }
  1035. type volumeServerCopyFileClient struct {
  1036. grpc.ClientStream
  1037. }
  1038. func (x *volumeServerCopyFileClient) Recv() (*CopyFileResponse, error) {
  1039. m := new(CopyFileResponse)
  1040. if err := x.ClientStream.RecvMsg(m); err != nil {
  1041. return nil, err
  1042. }
  1043. return m, nil
  1044. }
  1045. func (c *volumeServerClient) VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error) {
  1046. stream, err := grpc.NewClientStream(ctx, &_VolumeServer_serviceDesc.Streams[2], c.cc, "/volume_server_pb.VolumeServer/VolumeTailSender", opts...)
  1047. if err != nil {
  1048. return nil, err
  1049. }
  1050. x := &volumeServerVolumeTailSenderClient{stream}
  1051. if err := x.ClientStream.SendMsg(in); err != nil {
  1052. return nil, err
  1053. }
  1054. if err := x.ClientStream.CloseSend(); err != nil {
  1055. return nil, err
  1056. }
  1057. return x, nil
  1058. }
  1059. type VolumeServer_VolumeTailSenderClient interface {
  1060. Recv() (*VolumeTailSenderResponse, error)
  1061. grpc.ClientStream
  1062. }
  1063. type volumeServerVolumeTailSenderClient struct {
  1064. grpc.ClientStream
  1065. }
  1066. func (x *volumeServerVolumeTailSenderClient) Recv() (*VolumeTailSenderResponse, error) {
  1067. m := new(VolumeTailSenderResponse)
  1068. if err := x.ClientStream.RecvMsg(m); err != nil {
  1069. return nil, err
  1070. }
  1071. return m, nil
  1072. }
  1073. func (c *volumeServerClient) VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error) {
  1074. out := new(VolumeTailReceiverResponse)
  1075. err := grpc.Invoke(ctx, "/volume_server_pb.VolumeServer/VolumeTailReceiver", in, out, c.cc, opts...)
  1076. if err != nil {
  1077. return nil, err
  1078. }
  1079. return out, nil
  1080. }
  1081. // Server API for VolumeServer service
  1082. type VolumeServerServer interface {
  1083. // Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
  1084. BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)
  1085. VacuumVolumeCheck(context.Context, *VacuumVolumeCheckRequest) (*VacuumVolumeCheckResponse, error)
  1086. VacuumVolumeCompact(context.Context, *VacuumVolumeCompactRequest) (*VacuumVolumeCompactResponse, error)
  1087. VacuumVolumeCommit(context.Context, *VacuumVolumeCommitRequest) (*VacuumVolumeCommitResponse, error)
  1088. VacuumVolumeCleanup(context.Context, *VacuumVolumeCleanupRequest) (*VacuumVolumeCleanupResponse, error)
  1089. DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
  1090. AllocateVolume(context.Context, *AllocateVolumeRequest) (*AllocateVolumeResponse, error)
  1091. VolumeSyncStatus(context.Context, *VolumeSyncStatusRequest) (*VolumeSyncStatusResponse, error)
  1092. VolumeIncrementalCopy(*VolumeIncrementalCopyRequest, VolumeServer_VolumeIncrementalCopyServer) error
  1093. VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error)
  1094. VolumeUnmount(context.Context, *VolumeUnmountRequest) (*VolumeUnmountResponse, error)
  1095. VolumeDelete(context.Context, *VolumeDeleteRequest) (*VolumeDeleteResponse, error)
  1096. // copy the .idx .dat files, and mount this volume
  1097. VolumeCopy(context.Context, *VolumeCopyRequest) (*VolumeCopyResponse, error)
  1098. ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error)
  1099. CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error
  1100. VolumeTailSender(*VolumeTailSenderRequest, VolumeServer_VolumeTailSenderServer) error
  1101. VolumeTailReceiver(context.Context, *VolumeTailReceiverRequest) (*VolumeTailReceiverResponse, error)
  1102. }
  1103. func RegisterVolumeServerServer(s *grpc.Server, srv VolumeServerServer) {
  1104. s.RegisterService(&_VolumeServer_serviceDesc, srv)
  1105. }
  1106. func _VolumeServer_BatchDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1107. in := new(BatchDeleteRequest)
  1108. if err := dec(in); err != nil {
  1109. return nil, err
  1110. }
  1111. if interceptor == nil {
  1112. return srv.(VolumeServerServer).BatchDelete(ctx, in)
  1113. }
  1114. info := &grpc.UnaryServerInfo{
  1115. Server: srv,
  1116. FullMethod: "/volume_server_pb.VolumeServer/BatchDelete",
  1117. }
  1118. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1119. return srv.(VolumeServerServer).BatchDelete(ctx, req.(*BatchDeleteRequest))
  1120. }
  1121. return interceptor(ctx, in, info, handler)
  1122. }
  1123. func _VolumeServer_VacuumVolumeCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1124. in := new(VacuumVolumeCheckRequest)
  1125. if err := dec(in); err != nil {
  1126. return nil, err
  1127. }
  1128. if interceptor == nil {
  1129. return srv.(VolumeServerServer).VacuumVolumeCheck(ctx, in)
  1130. }
  1131. info := &grpc.UnaryServerInfo{
  1132. Server: srv,
  1133. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCheck",
  1134. }
  1135. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1136. return srv.(VolumeServerServer).VacuumVolumeCheck(ctx, req.(*VacuumVolumeCheckRequest))
  1137. }
  1138. return interceptor(ctx, in, info, handler)
  1139. }
  1140. func _VolumeServer_VacuumVolumeCompact_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1141. in := new(VacuumVolumeCompactRequest)
  1142. if err := dec(in); err != nil {
  1143. return nil, err
  1144. }
  1145. if interceptor == nil {
  1146. return srv.(VolumeServerServer).VacuumVolumeCompact(ctx, in)
  1147. }
  1148. info := &grpc.UnaryServerInfo{
  1149. Server: srv,
  1150. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCompact",
  1151. }
  1152. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1153. return srv.(VolumeServerServer).VacuumVolumeCompact(ctx, req.(*VacuumVolumeCompactRequest))
  1154. }
  1155. return interceptor(ctx, in, info, handler)
  1156. }
  1157. func _VolumeServer_VacuumVolumeCommit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1158. in := new(VacuumVolumeCommitRequest)
  1159. if err := dec(in); err != nil {
  1160. return nil, err
  1161. }
  1162. if interceptor == nil {
  1163. return srv.(VolumeServerServer).VacuumVolumeCommit(ctx, in)
  1164. }
  1165. info := &grpc.UnaryServerInfo{
  1166. Server: srv,
  1167. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCommit",
  1168. }
  1169. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1170. return srv.(VolumeServerServer).VacuumVolumeCommit(ctx, req.(*VacuumVolumeCommitRequest))
  1171. }
  1172. return interceptor(ctx, in, info, handler)
  1173. }
  1174. func _VolumeServer_VacuumVolumeCleanup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1175. in := new(VacuumVolumeCleanupRequest)
  1176. if err := dec(in); err != nil {
  1177. return nil, err
  1178. }
  1179. if interceptor == nil {
  1180. return srv.(VolumeServerServer).VacuumVolumeCleanup(ctx, in)
  1181. }
  1182. info := &grpc.UnaryServerInfo{
  1183. Server: srv,
  1184. FullMethod: "/volume_server_pb.VolumeServer/VacuumVolumeCleanup",
  1185. }
  1186. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1187. return srv.(VolumeServerServer).VacuumVolumeCleanup(ctx, req.(*VacuumVolumeCleanupRequest))
  1188. }
  1189. return interceptor(ctx, in, info, handler)
  1190. }
  1191. func _VolumeServer_DeleteCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1192. in := new(DeleteCollectionRequest)
  1193. if err := dec(in); err != nil {
  1194. return nil, err
  1195. }
  1196. if interceptor == nil {
  1197. return srv.(VolumeServerServer).DeleteCollection(ctx, in)
  1198. }
  1199. info := &grpc.UnaryServerInfo{
  1200. Server: srv,
  1201. FullMethod: "/volume_server_pb.VolumeServer/DeleteCollection",
  1202. }
  1203. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1204. return srv.(VolumeServerServer).DeleteCollection(ctx, req.(*DeleteCollectionRequest))
  1205. }
  1206. return interceptor(ctx, in, info, handler)
  1207. }
  1208. func _VolumeServer_AllocateVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1209. in := new(AllocateVolumeRequest)
  1210. if err := dec(in); err != nil {
  1211. return nil, err
  1212. }
  1213. if interceptor == nil {
  1214. return srv.(VolumeServerServer).AllocateVolume(ctx, in)
  1215. }
  1216. info := &grpc.UnaryServerInfo{
  1217. Server: srv,
  1218. FullMethod: "/volume_server_pb.VolumeServer/AllocateVolume",
  1219. }
  1220. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1221. return srv.(VolumeServerServer).AllocateVolume(ctx, req.(*AllocateVolumeRequest))
  1222. }
  1223. return interceptor(ctx, in, info, handler)
  1224. }
  1225. func _VolumeServer_VolumeSyncStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1226. in := new(VolumeSyncStatusRequest)
  1227. if err := dec(in); err != nil {
  1228. return nil, err
  1229. }
  1230. if interceptor == nil {
  1231. return srv.(VolumeServerServer).VolumeSyncStatus(ctx, in)
  1232. }
  1233. info := &grpc.UnaryServerInfo{
  1234. Server: srv,
  1235. FullMethod: "/volume_server_pb.VolumeServer/VolumeSyncStatus",
  1236. }
  1237. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1238. return srv.(VolumeServerServer).VolumeSyncStatus(ctx, req.(*VolumeSyncStatusRequest))
  1239. }
  1240. return interceptor(ctx, in, info, handler)
  1241. }
  1242. func _VolumeServer_VolumeIncrementalCopy_Handler(srv interface{}, stream grpc.ServerStream) error {
  1243. m := new(VolumeIncrementalCopyRequest)
  1244. if err := stream.RecvMsg(m); err != nil {
  1245. return err
  1246. }
  1247. return srv.(VolumeServerServer).VolumeIncrementalCopy(m, &volumeServerVolumeIncrementalCopyServer{stream})
  1248. }
  1249. type VolumeServer_VolumeIncrementalCopyServer interface {
  1250. Send(*VolumeIncrementalCopyResponse) error
  1251. grpc.ServerStream
  1252. }
  1253. type volumeServerVolumeIncrementalCopyServer struct {
  1254. grpc.ServerStream
  1255. }
  1256. func (x *volumeServerVolumeIncrementalCopyServer) Send(m *VolumeIncrementalCopyResponse) error {
  1257. return x.ServerStream.SendMsg(m)
  1258. }
  1259. func _VolumeServer_VolumeMount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1260. in := new(VolumeMountRequest)
  1261. if err := dec(in); err != nil {
  1262. return nil, err
  1263. }
  1264. if interceptor == nil {
  1265. return srv.(VolumeServerServer).VolumeMount(ctx, in)
  1266. }
  1267. info := &grpc.UnaryServerInfo{
  1268. Server: srv,
  1269. FullMethod: "/volume_server_pb.VolumeServer/VolumeMount",
  1270. }
  1271. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1272. return srv.(VolumeServerServer).VolumeMount(ctx, req.(*VolumeMountRequest))
  1273. }
  1274. return interceptor(ctx, in, info, handler)
  1275. }
  1276. func _VolumeServer_VolumeUnmount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1277. in := new(VolumeUnmountRequest)
  1278. if err := dec(in); err != nil {
  1279. return nil, err
  1280. }
  1281. if interceptor == nil {
  1282. return srv.(VolumeServerServer).VolumeUnmount(ctx, in)
  1283. }
  1284. info := &grpc.UnaryServerInfo{
  1285. Server: srv,
  1286. FullMethod: "/volume_server_pb.VolumeServer/VolumeUnmount",
  1287. }
  1288. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1289. return srv.(VolumeServerServer).VolumeUnmount(ctx, req.(*VolumeUnmountRequest))
  1290. }
  1291. return interceptor(ctx, in, info, handler)
  1292. }
  1293. func _VolumeServer_VolumeDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1294. in := new(VolumeDeleteRequest)
  1295. if err := dec(in); err != nil {
  1296. return nil, err
  1297. }
  1298. if interceptor == nil {
  1299. return srv.(VolumeServerServer).VolumeDelete(ctx, in)
  1300. }
  1301. info := &grpc.UnaryServerInfo{
  1302. Server: srv,
  1303. FullMethod: "/volume_server_pb.VolumeServer/VolumeDelete",
  1304. }
  1305. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1306. return srv.(VolumeServerServer).VolumeDelete(ctx, req.(*VolumeDeleteRequest))
  1307. }
  1308. return interceptor(ctx, in, info, handler)
  1309. }
  1310. func _VolumeServer_VolumeCopy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1311. in := new(VolumeCopyRequest)
  1312. if err := dec(in); err != nil {
  1313. return nil, err
  1314. }
  1315. if interceptor == nil {
  1316. return srv.(VolumeServerServer).VolumeCopy(ctx, in)
  1317. }
  1318. info := &grpc.UnaryServerInfo{
  1319. Server: srv,
  1320. FullMethod: "/volume_server_pb.VolumeServer/VolumeCopy",
  1321. }
  1322. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1323. return srv.(VolumeServerServer).VolumeCopy(ctx, req.(*VolumeCopyRequest))
  1324. }
  1325. return interceptor(ctx, in, info, handler)
  1326. }
  1327. func _VolumeServer_ReadVolumeFileStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1328. in := new(ReadVolumeFileStatusRequest)
  1329. if err := dec(in); err != nil {
  1330. return nil, err
  1331. }
  1332. if interceptor == nil {
  1333. return srv.(VolumeServerServer).ReadVolumeFileStatus(ctx, in)
  1334. }
  1335. info := &grpc.UnaryServerInfo{
  1336. Server: srv,
  1337. FullMethod: "/volume_server_pb.VolumeServer/ReadVolumeFileStatus",
  1338. }
  1339. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1340. return srv.(VolumeServerServer).ReadVolumeFileStatus(ctx, req.(*ReadVolumeFileStatusRequest))
  1341. }
  1342. return interceptor(ctx, in, info, handler)
  1343. }
  1344. func _VolumeServer_CopyFile_Handler(srv interface{}, stream grpc.ServerStream) error {
  1345. m := new(CopyFileRequest)
  1346. if err := stream.RecvMsg(m); err != nil {
  1347. return err
  1348. }
  1349. return srv.(VolumeServerServer).CopyFile(m, &volumeServerCopyFileServer{stream})
  1350. }
  1351. type VolumeServer_CopyFileServer interface {
  1352. Send(*CopyFileResponse) error
  1353. grpc.ServerStream
  1354. }
  1355. type volumeServerCopyFileServer struct {
  1356. grpc.ServerStream
  1357. }
  1358. func (x *volumeServerCopyFileServer) Send(m *CopyFileResponse) error {
  1359. return x.ServerStream.SendMsg(m)
  1360. }
  1361. func _VolumeServer_VolumeTailSender_Handler(srv interface{}, stream grpc.ServerStream) error {
  1362. m := new(VolumeTailSenderRequest)
  1363. if err := stream.RecvMsg(m); err != nil {
  1364. return err
  1365. }
  1366. return srv.(VolumeServerServer).VolumeTailSender(m, &volumeServerVolumeTailSenderServer{stream})
  1367. }
  1368. type VolumeServer_VolumeTailSenderServer interface {
  1369. Send(*VolumeTailSenderResponse) error
  1370. grpc.ServerStream
  1371. }
  1372. type volumeServerVolumeTailSenderServer struct {
  1373. grpc.ServerStream
  1374. }
  1375. func (x *volumeServerVolumeTailSenderServer) Send(m *VolumeTailSenderResponse) error {
  1376. return x.ServerStream.SendMsg(m)
  1377. }
  1378. func _VolumeServer_VolumeTailReceiver_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1379. in := new(VolumeTailReceiverRequest)
  1380. if err := dec(in); err != nil {
  1381. return nil, err
  1382. }
  1383. if interceptor == nil {
  1384. return srv.(VolumeServerServer).VolumeTailReceiver(ctx, in)
  1385. }
  1386. info := &grpc.UnaryServerInfo{
  1387. Server: srv,
  1388. FullMethod: "/volume_server_pb.VolumeServer/VolumeTailReceiver",
  1389. }
  1390. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1391. return srv.(VolumeServerServer).VolumeTailReceiver(ctx, req.(*VolumeTailReceiverRequest))
  1392. }
  1393. return interceptor(ctx, in, info, handler)
  1394. }
  1395. var _VolumeServer_serviceDesc = grpc.ServiceDesc{
  1396. ServiceName: "volume_server_pb.VolumeServer",
  1397. HandlerType: (*VolumeServerServer)(nil),
  1398. Methods: []grpc.MethodDesc{
  1399. {
  1400. MethodName: "BatchDelete",
  1401. Handler: _VolumeServer_BatchDelete_Handler,
  1402. },
  1403. {
  1404. MethodName: "VacuumVolumeCheck",
  1405. Handler: _VolumeServer_VacuumVolumeCheck_Handler,
  1406. },
  1407. {
  1408. MethodName: "VacuumVolumeCompact",
  1409. Handler: _VolumeServer_VacuumVolumeCompact_Handler,
  1410. },
  1411. {
  1412. MethodName: "VacuumVolumeCommit",
  1413. Handler: _VolumeServer_VacuumVolumeCommit_Handler,
  1414. },
  1415. {
  1416. MethodName: "VacuumVolumeCleanup",
  1417. Handler: _VolumeServer_VacuumVolumeCleanup_Handler,
  1418. },
  1419. {
  1420. MethodName: "DeleteCollection",
  1421. Handler: _VolumeServer_DeleteCollection_Handler,
  1422. },
  1423. {
  1424. MethodName: "AllocateVolume",
  1425. Handler: _VolumeServer_AllocateVolume_Handler,
  1426. },
  1427. {
  1428. MethodName: "VolumeSyncStatus",
  1429. Handler: _VolumeServer_VolumeSyncStatus_Handler,
  1430. },
  1431. {
  1432. MethodName: "VolumeMount",
  1433. Handler: _VolumeServer_VolumeMount_Handler,
  1434. },
  1435. {
  1436. MethodName: "VolumeUnmount",
  1437. Handler: _VolumeServer_VolumeUnmount_Handler,
  1438. },
  1439. {
  1440. MethodName: "VolumeDelete",
  1441. Handler: _VolumeServer_VolumeDelete_Handler,
  1442. },
  1443. {
  1444. MethodName: "VolumeCopy",
  1445. Handler: _VolumeServer_VolumeCopy_Handler,
  1446. },
  1447. {
  1448. MethodName: "ReadVolumeFileStatus",
  1449. Handler: _VolumeServer_ReadVolumeFileStatus_Handler,
  1450. },
  1451. {
  1452. MethodName: "VolumeTailReceiver",
  1453. Handler: _VolumeServer_VolumeTailReceiver_Handler,
  1454. },
  1455. },
  1456. Streams: []grpc.StreamDesc{
  1457. {
  1458. StreamName: "VolumeIncrementalCopy",
  1459. Handler: _VolumeServer_VolumeIncrementalCopy_Handler,
  1460. ServerStreams: true,
  1461. },
  1462. {
  1463. StreamName: "CopyFile",
  1464. Handler: _VolumeServer_CopyFile_Handler,
  1465. ServerStreams: true,
  1466. },
  1467. {
  1468. StreamName: "VolumeTailSender",
  1469. Handler: _VolumeServer_VolumeTailSender_Handler,
  1470. ServerStreams: true,
  1471. },
  1472. },
  1473. Metadata: "volume_server.proto",
  1474. }
  1475. func init() { proto.RegisterFile("volume_server.proto", fileDescriptor0) }
  1476. var fileDescriptor0 = []byte{
  1477. // 1453 bytes of a gzipped FileDescriptorProto
  1478. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xc4, 0x18, 0x4b, 0x73, 0xdc, 0x44,
  1479. 0xd3, 0xca, 0xae, 0xed, 0x75, 0xef, 0xda, 0x71, 0xc6, 0x4e, 0xbc, 0x56, 0x5e, 0x8e, 0x92, 0x2f,
  1480. 0xd9, 0x3c, 0x3e, 0x27, 0x24, 0x05, 0x04, 0x38, 0x40, 0x62, 0x43, 0xe1, 0x2a, 0x92, 0x54, 0xc9,
  1481. 0x49, 0x0a, 0x0a, 0xaa, 0x54, 0x63, 0x69, 0x1c, 0xab, 0xac, 0xd5, 0x28, 0x9a, 0x91, 0x89, 0x29,
  1482. 0x6e, 0xf0, 0x4f, 0xb8, 0xe5, 0xc0, 0x95, 0x2b, 0x7f, 0x88, 0x5f, 0xc0, 0x85, 0x9a, 0x87, 0xb4,
  1483. 0x7a, 0x7a, 0x15, 0x72, 0xe0, 0x36, 0xea, 0x77, 0xf7, 0x74, 0xf7, 0x74, 0x0b, 0x56, 0x8e, 0x68,
  1484. 0x90, 0x8c, 0x89, 0xc3, 0x48, 0x7c, 0x44, 0xe2, 0xcd, 0x28, 0xa6, 0x9c, 0xa2, 0xe5, 0x02, 0xd0,
  1485. 0x89, 0xf6, 0xac, 0xbb, 0x80, 0x1e, 0x63, 0xee, 0x1e, 0x6c, 0x93, 0x80, 0x70, 0x62, 0x93, 0xd7,
  1486. 0x09, 0x61, 0x1c, 0xad, 0x43, 0x6f, 0xdf, 0x0f, 0x88, 0xe3, 0x7b, 0x6c, 0x68, 0x6c, 0x74, 0x46,
  1487. 0x0b, 0xf6, 0xbc, 0xf8, 0xde, 0xf1, 0x98, 0xf5, 0x0c, 0x56, 0x0a, 0x0c, 0x2c, 0xa2, 0x21, 0x23,
  1488. 0xe8, 0x21, 0xcc, 0xc7, 0x84, 0x25, 0x01, 0x57, 0x0c, 0xfd, 0xfb, 0x97, 0x36, 0xcb, 0xba, 0x36,
  1489. 0x33, 0x96, 0x24, 0xe0, 0x76, 0x4a, 0x6e, 0xf9, 0x30, 0xc8, 0x23, 0xd0, 0x1a, 0xcc, 0x6b, 0xdd,
  1490. 0x43, 0x63, 0xc3, 0x18, 0x2d, 0xd8, 0x73, 0x4a, 0x35, 0x3a, 0x07, 0x73, 0x8c, 0x63, 0x9e, 0xb0,
  1491. 0xe1, 0xa9, 0x0d, 0x63, 0x34, 0x6b, 0xeb, 0x2f, 0xb4, 0x0a, 0xb3, 0x24, 0x8e, 0x69, 0x3c, 0xec,
  1492. 0x48, 0x72, 0xf5, 0x81, 0x10, 0x74, 0x99, 0xff, 0x13, 0x19, 0x76, 0x37, 0x8c, 0xd1, 0xa2, 0x2d,
  1493. 0xcf, 0xd6, 0x3c, 0xcc, 0x7e, 0x39, 0x8e, 0xf8, 0xb1, 0xf5, 0x31, 0x0c, 0x5f, 0x62, 0x37, 0x49,
  1494. 0xc6, 0x2f, 0xa5, 0x8d, 0x5b, 0x07, 0xc4, 0x3d, 0x4c, 0x7d, 0x3f, 0x0f, 0x0b, 0xda, 0x72, 0x6d,
  1495. 0xc1, 0xa2, 0xdd, 0x53, 0x80, 0x1d, 0xcf, 0xfa, 0x02, 0xd6, 0x6b, 0x18, 0x75, 0x0c, 0xae, 0xc2,
  1496. 0xe2, 0x2b, 0x1c, 0xef, 0xe1, 0x57, 0xc4, 0x89, 0x31, 0xf7, 0xa9, 0xe4, 0x36, 0xec, 0x81, 0x06,
  1497. 0xda, 0x02, 0x66, 0x7d, 0x0f, 0x66, 0x41, 0x02, 0x1d, 0x47, 0xd8, 0xe5, 0x6d, 0x94, 0xa3, 0x0d,
  1498. 0xe8, 0x47, 0x31, 0xc1, 0x41, 0x40, 0x5d, 0xcc, 0x89, 0x8c, 0x42, 0xc7, 0xce, 0x83, 0xac, 0x8b,
  1499. 0x70, 0xbe, 0x56, 0xb8, 0x32, 0xd0, 0x7a, 0x58, 0xb2, 0x9e, 0x8e, 0xc7, 0x7e, 0x2b, 0xd5, 0xd6,
  1500. 0x85, 0x8a, 0xd5, 0x92, 0x53, 0xcb, 0xfd, 0xa4, 0x84, 0x0d, 0x08, 0x0e, 0x93, 0xa8, 0x95, 0xe0,
  1501. 0xb2, 0xc5, 0x29, 0x6b, 0x26, 0x79, 0x4d, 0x25, 0xc7, 0x16, 0x0d, 0x02, 0xe2, 0x72, 0x9f, 0x86,
  1502. 0xa9, 0xd8, 0x4b, 0x00, 0x6e, 0x06, 0xd4, 0xa9, 0x92, 0x83, 0x58, 0x26, 0x0c, 0xab, 0xac, 0x5a,
  1503. 0xec, 0x5b, 0x03, 0xce, 0x3e, 0xd2, 0x41, 0x53, 0x8a, 0x5b, 0x5d, 0x40, 0x51, 0xe5, 0xa9, 0xb2,
  1504. 0xca, 0xf2, 0x05, 0x75, 0x2a, 0x17, 0x24, 0x28, 0x62, 0x12, 0x05, 0xbe, 0x8b, 0xa5, 0x88, 0xae,
  1505. 0x14, 0x91, 0x07, 0xa1, 0x65, 0xe8, 0x70, 0x1e, 0x0c, 0x67, 0x25, 0x46, 0x1c, 0xad, 0x21, 0x9c,
  1506. 0x2b, 0xdb, 0xaa, 0xdd, 0xf8, 0x08, 0xd6, 0x14, 0x64, 0xf7, 0x38, 0x74, 0x77, 0x65, 0x35, 0xb4,
  1507. 0x0a, 0xfa, 0xdf, 0x06, 0x0c, 0xab, 0x8c, 0x3a, 0x8b, 0xdf, 0x37, 0x02, 0xef, 0xea, 0x1f, 0xba,
  1508. 0x0c, 0x7d, 0x8e, 0xfd, 0xc0, 0xa1, 0xfb, 0xfb, 0x8c, 0xf0, 0xe1, 0xdc, 0x86, 0x31, 0xea, 0xda,
  1509. 0x20, 0x40, 0xcf, 0x24, 0x04, 0xdd, 0x84, 0x65, 0x57, 0x65, 0xb2, 0x13, 0x93, 0x23, 0x9f, 0x09,
  1510. 0xc9, 0xf3, 0xd2, 0xb0, 0xd3, 0x6e, 0x9a, 0xe1, 0x0a, 0x8c, 0x2c, 0x58, 0xf4, 0xbd, 0x37, 0x8e,
  1511. 0x6c, 0x20, 0xb2, 0xfc, 0x7b, 0x52, 0x5a, 0xdf, 0xf7, 0xde, 0x7c, 0xe5, 0x07, 0x64, 0x57, 0x74,
  1512. 0x81, 0x97, 0x70, 0x41, 0x39, 0xbf, 0x13, 0xba, 0x31, 0x19, 0x93, 0x90, 0xe3, 0x60, 0x8b, 0x46,
  1513. 0xc7, 0xad, 0x52, 0x60, 0x1d, 0x7a, 0xcc, 0x0f, 0x5d, 0xe2, 0x84, 0xaa, 0x0d, 0x75, 0xed, 0x79,
  1514. 0xf9, 0xfd, 0x94, 0x59, 0x8f, 0xe1, 0x62, 0x83, 0x5c, 0x1d, 0xd9, 0x2b, 0x30, 0x90, 0x86, 0xb9,
  1515. 0x34, 0xe4, 0x24, 0xe4, 0x52, 0xf6, 0xc0, 0xee, 0x0b, 0xd8, 0x96, 0x02, 0x59, 0x1f, 0x00, 0x52,
  1516. 0x32, 0x9e, 0xd0, 0x24, 0x6c, 0x57, 0x9a, 0x67, 0x61, 0xa5, 0xc0, 0xa2, 0x73, 0xe3, 0x01, 0xac,
  1517. 0x2a, 0xf0, 0x8b, 0x70, 0xdc, 0x5a, 0xd6, 0x1a, 0x9c, 0x2d, 0x31, 0x69, 0x69, 0xf7, 0x53, 0x25,
  1518. 0xc5, 0x77, 0xe2, 0x44, 0x61, 0xe7, 0x52, 0x0b, 0x8a, 0x4f, 0x85, 0xf5, 0xbb, 0x01, 0x67, 0xd2,
  1519. 0x36, 0xd2, 0x32, 0xea, 0xef, 0x98, 0x76, 0x9d, 0xc6, 0xb4, 0xeb, 0x4e, 0xd2, 0x6e, 0x04, 0xcb,
  1520. 0x8c, 0x26, 0xb1, 0x4b, 0x1c, 0x0f, 0x73, 0xec, 0x84, 0xd4, 0x23, 0x3a, 0x2b, 0x97, 0x14, 0x7c,
  1521. 0x1b, 0x73, 0xfc, 0x94, 0x7a, 0xc4, 0xfa, 0x3c, 0xbd, 0x94, 0xc2, 0x6d, 0xde, 0x84, 0x33, 0x01,
  1522. 0x66, 0xdc, 0xc1, 0x51, 0x44, 0x42, 0xcf, 0xc1, 0x5c, 0xa4, 0x84, 0x21, 0x53, 0x62, 0x49, 0x20,
  1523. 0x1e, 0x49, 0xf8, 0x23, 0xfe, 0x94, 0x59, 0x7f, 0x1a, 0x70, 0x5a, 0xf0, 0x8a, 0x14, 0x6c, 0xe9,
  1524. 0x6f, 0xdf, 0x67, 0x4e, 0x9a, 0xc9, 0xd2, 0xe1, 0x9e, 0xbd, 0xe0, 0xb3, 0x1d, 0x95, 0xc6, 0x1a,
  1525. 0xef, 0x61, 0xae, 0xf0, 0x9d, 0x14, 0xbf, 0x8d, 0xb9, 0xc4, 0xdf, 0x85, 0x15, 0x5d, 0x19, 0x3e,
  1526. 0x0d, 0x27, 0x45, 0xa3, 0xde, 0x42, 0x34, 0x41, 0x65, 0x75, 0x73, 0x19, 0xfa, 0x8c, 0xd3, 0x28,
  1527. 0xad, 0xc1, 0x59, 0x55, 0x83, 0x02, 0xa4, 0x6a, 0xd0, 0xfa, 0x10, 0x96, 0x27, 0x1e, 0xb4, 0xcf,
  1528. 0xe7, 0x5f, 0x8c, 0xb4, 0x45, 0x3d, 0xc7, 0x7e, 0xb0, 0x4b, 0x42, 0x8f, 0xc4, 0xef, 0x59, 0x67,
  1529. 0xe8, 0x1e, 0xac, 0xfa, 0x5e, 0x40, 0x1c, 0xee, 0x8f, 0x09, 0x4d, 0xb8, 0xc3, 0x88, 0x4b, 0x43,
  1530. 0x8f, 0xc9, 0x28, 0x2c, 0xda, 0x48, 0xe0, 0x9e, 0x2b, 0xd4, 0xae, 0xc2, 0x58, 0xbf, 0x66, 0xfd,
  1531. 0x2e, 0x6f, 0xc5, 0xe4, 0xd5, 0x0e, 0x09, 0x11, 0x02, 0x0f, 0x08, 0xf6, 0x48, 0xac, 0xdd, 0x18,
  1532. 0x28, 0xe0, 0xd7, 0x12, 0x26, 0xe2, 0xa3, 0x89, 0xf6, 0xa8, 0x77, 0x2c, 0x2d, 0x1a, 0xd8, 0xa0,
  1533. 0x40, 0x8f, 0xa9, 0x77, 0x2c, 0x1b, 0x0f, 0x73, 0x64, 0x42, 0xb8, 0x07, 0x49, 0x78, 0xa8, 0xef,
  1534. 0xa4, 0xef, 0xb3, 0x6f, 0x30, 0xe3, 0x5b, 0x02, 0x64, 0xfd, 0x61, 0xc0, 0xfa, 0xc4, 0x0c, 0x9b,
  1535. 0xb8, 0xc4, 0x3f, 0xfa, 0x0f, 0xc2, 0x21, 0x38, 0x74, 0xe6, 0x17, 0x46, 0x34, 0x5d, 0x1c, 0x48,
  1536. 0xe1, 0xf4, 0xfb, 0x20, 0x31, 0xf2, 0xf9, 0xaf, 0x31, 0x5c, 0x17, 0xf4, 0xa7, 0x70, 0xde, 0x26,
  1537. 0xd8, 0x53, 0x14, 0xb2, 0xcd, 0xb6, 0x7f, 0x8a, 0xfe, 0x3a, 0x05, 0x17, 0xea, 0x99, 0xdb, 0x3c,
  1538. 0x47, 0x9f, 0x81, 0x99, 0xb5, 0x7b, 0xe1, 0x3f, 0xe3, 0x78, 0x1c, 0x65, 0x11, 0x50, 0x81, 0x5a,
  1539. 0xd3, 0xbd, 0xff, 0x79, 0x8a, 0x4f, 0xc3, 0x50, 0x79, 0x2b, 0x3a, 0x95, 0xb7, 0x42, 0x28, 0x48,
  1540. 0xab, 0xac, 0x46, 0x41, 0x57, 0x29, 0xf0, 0x54, 0xd5, 0xd5, 0x29, 0xc8, 0x98, 0xa5, 0x02, 0x55,
  1541. 0x56, 0x7d, 0x4d, 0x2f, 0x15, 0x5c, 0x04, 0xd0, 0x35, 0x94, 0x84, 0xe9, 0xdb, 0xb7, 0xa0, 0x2a,
  1542. 0x28, 0x09, 0x79, 0x53, 0x21, 0xcf, 0x37, 0x16, 0x72, 0xb1, 0x53, 0xf6, 0x2a, 0x53, 0xd1, 0xb7,
  1543. 0x00, 0xdb, 0x3e, 0x3b, 0x54, 0x41, 0x16, 0x5d, 0xd1, 0xf3, 0x63, 0x3d, 0x3c, 0x89, 0xa3, 0x80,
  1544. 0xe0, 0x20, 0xd0, 0xa1, 0x13, 0x47, 0x31, 0x48, 0x27, 0x8c, 0x78, 0x3a, 0x3a, 0xf2, 0x2c, 0x60,
  1545. 0xfb, 0x31, 0x21, 0x3a, 0x00, 0xf2, 0x6c, 0xfd, 0x66, 0xc0, 0xc2, 0x13, 0x32, 0xd6, 0x92, 0x2f,
  1546. 0x01, 0xbc, 0xa2, 0x31, 0x4d, 0xb8, 0x1f, 0x12, 0xd5, 0x16, 0x67, 0xed, 0x1c, 0xe4, 0xdf, 0xeb,
  1547. 0x91, 0x83, 0x3d, 0x09, 0xf6, 0x75, 0x30, 0xe5, 0x59, 0xc0, 0x0e, 0x08, 0x8e, 0x74, 0xfc, 0xe4,
  1548. 0x59, 0xac, 0x05, 0x8c, 0x63, 0xf7, 0x50, 0x06, 0xab, 0x6b, 0xab, 0x8f, 0xfb, 0x6f, 0x97, 0x60,
  1549. 0x90, 0x4f, 0x6d, 0xf4, 0x03, 0xf4, 0x73, 0xfb, 0x0c, 0xba, 0x56, 0x5d, 0x5b, 0xaa, 0xfb, 0x91,
  1550. 0xf9, 0xbf, 0x29, 0x54, 0xba, 0x30, 0x66, 0x50, 0x08, 0x67, 0x2a, 0xfb, 0x02, 0xba, 0x55, 0xe5,
  1551. 0x6e, 0xda, 0x46, 0xcc, 0xdb, 0xad, 0x68, 0x33, 0x7d, 0x1c, 0x56, 0x6a, 0x16, 0x00, 0x74, 0x67,
  1552. 0x8a, 0x94, 0xc2, 0x12, 0x62, 0xfe, 0xbf, 0x25, 0x75, 0xa6, 0xf5, 0x35, 0xa0, 0xea, 0x76, 0x80,
  1553. 0x6e, 0x4f, 0x15, 0x33, 0xd9, 0x3e, 0xcc, 0x3b, 0xed, 0x88, 0x1b, 0x1d, 0x55, 0x7b, 0xc3, 0x54,
  1554. 0x47, 0x0b, 0x9b, 0xc9, 0x54, 0x47, 0x4b, 0xcb, 0xc8, 0x0c, 0x3a, 0x84, 0xe5, 0xf2, 0x4e, 0x81,
  1555. 0x6e, 0x36, 0x2d, 0xba, 0x95, 0x95, 0xc5, 0xbc, 0xd5, 0x86, 0x34, 0x53, 0x46, 0x60, 0xa9, 0x38,
  1556. 0xf7, 0xa3, 0x1b, 0x55, 0xfe, 0xda, 0x2d, 0xc6, 0x1c, 0x4d, 0x27, 0xcc, 0xfb, 0x54, 0xde, 0x05,
  1557. 0xea, 0x7c, 0x6a, 0x58, 0x34, 0xea, 0x7c, 0x6a, 0x5a, 0x2d, 0xac, 0x19, 0xf4, 0x73, 0x3a, 0x60,
  1558. 0x96, 0x66, 0x64, 0xb4, 0xd9, 0x24, 0xa6, 0x7e, 0x48, 0x37, 0xef, 0xb6, 0xa6, 0x4f, 0x75, 0xdf,
  1559. 0x33, 0x44, 0xad, 0xe7, 0x46, 0xe5, 0xba, 0x5a, 0xaf, 0x0e, 0xdf, 0x75, 0xb5, 0x5e, 0x37, 0x6f,
  1560. 0xcf, 0xa0, 0x3d, 0x58, 0x2c, 0x0c, 0xcf, 0xe8, 0x7a, 0x13, 0x67, 0x71, 0x24, 0x37, 0x6f, 0x4c,
  1561. 0xa5, 0xcb, 0x74, 0x38, 0x69, 0xf7, 0xd2, 0xed, 0xaa, 0xd1, 0xb8, 0x62, 0xbf, 0xba, 0x3e, 0x8d,
  1562. 0x2c, 0x53, 0xf0, 0x1d, 0xc0, 0x64, 0xd6, 0x45, 0x57, 0x9b, 0xf8, 0xf2, 0x57, 0x71, 0xed, 0x64,
  1563. 0xa2, 0x4c, 0xf4, 0x8f, 0xb0, 0x5a, 0xf7, 0xd2, 0xa3, 0x9a, 0x2a, 0x3c, 0x61, 0x9c, 0x30, 0x37,
  1564. 0xdb, 0x92, 0x67, 0x8a, 0x5f, 0x40, 0x2f, 0x9d, 0x5d, 0xd1, 0x95, 0x2a, 0x77, 0x69, 0x32, 0x37,
  1565. 0xad, 0x93, 0x48, 0x72, 0xd9, 0x34, 0x4e, 0x0b, 0x67, 0x32, 0x54, 0x36, 0x17, 0x4e, 0x65, 0xfc,
  1566. 0x6d, 0x2e, 0x9c, 0xea, 0x8c, 0x2a, 0xd5, 0xbd, 0x4e, 0xb7, 0x90, 0xfc, 0x0c, 0x56, 0xdb, 0x64,
  1567. 0x9b, 0x46, 0xcc, 0xda, 0x26, 0xdb, 0x3c, 0xd6, 0xcd, 0xec, 0xcd, 0xc9, 0xbf, 0x86, 0x0f, 0xfe,
  1568. 0x09, 0x00, 0x00, 0xff, 0xff, 0x5d, 0xcf, 0xff, 0x14, 0x4c, 0x14, 0x00, 0x00,
  1569. }