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.

2125 lines
77 KiB

6 years ago
6 years ago
6 years ago
6 years ago
  1. // Code generated by protoc-gen-go.
  2. // source: master.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package master_pb is a generated protocol buffer package.
  6. It is generated from these files:
  7. master.proto
  8. It has these top-level messages:
  9. Heartbeat
  10. HeartbeatResponse
  11. VolumeInformationMessage
  12. VolumeShortInformationMessage
  13. VolumeEcShardInformationMessage
  14. StorageBackend
  15. Empty
  16. SuperBlockExtra
  17. KeepConnectedRequest
  18. VolumeLocation
  19. LookupVolumeRequest
  20. LookupVolumeResponse
  21. Location
  22. AssignRequest
  23. AssignResponse
  24. StatisticsRequest
  25. StatisticsResponse
  26. StorageType
  27. Collection
  28. CollectionListRequest
  29. CollectionListResponse
  30. CollectionDeleteRequest
  31. CollectionDeleteResponse
  32. DataNodeInfo
  33. RackInfo
  34. DataCenterInfo
  35. TopologyInfo
  36. VolumeListRequest
  37. VolumeListResponse
  38. LookupEcVolumeRequest
  39. LookupEcVolumeResponse
  40. GetMasterConfigurationRequest
  41. GetMasterConfigurationResponse
  42. ListMasterClientsRequest
  43. ListMasterClientsResponse
  44. */
  45. package master_pb
  46. import proto "github.com/golang/protobuf/proto"
  47. import fmt "fmt"
  48. import math "math"
  49. import (
  50. context "golang.org/x/net/context"
  51. grpc "google.golang.org/grpc"
  52. )
  53. // Reference imports to suppress errors if they are not otherwise used.
  54. var _ = proto.Marshal
  55. var _ = fmt.Errorf
  56. var _ = math.Inf
  57. // This is a compile-time assertion to ensure that this generated file
  58. // is compatible with the proto package it is being compiled against.
  59. // A compilation error at this line likely means your copy of the
  60. // proto package needs to be updated.
  61. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  62. type Heartbeat struct {
  63. Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
  64. Port uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
  65. PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  66. MaxVolumeCount uint32 `protobuf:"varint,4,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  67. MaxFileKey uint64 `protobuf:"varint,5,opt,name=max_file_key,json=maxFileKey" json:"max_file_key,omitempty"`
  68. DataCenter string `protobuf:"bytes,6,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
  69. Rack string `protobuf:"bytes,7,opt,name=rack" json:"rack,omitempty"`
  70. AdminPort uint32 `protobuf:"varint,8,opt,name=admin_port,json=adminPort" json:"admin_port,omitempty"`
  71. Volumes []*VolumeInformationMessage `protobuf:"bytes,9,rep,name=volumes" json:"volumes,omitempty"`
  72. // delta volumes
  73. NewVolumes []*VolumeShortInformationMessage `protobuf:"bytes,10,rep,name=new_volumes,json=newVolumes" json:"new_volumes,omitempty"`
  74. DeletedVolumes []*VolumeShortInformationMessage `protobuf:"bytes,11,rep,name=deleted_volumes,json=deletedVolumes" json:"deleted_volumes,omitempty"`
  75. HasNoVolumes bool `protobuf:"varint,12,opt,name=has_no_volumes,json=hasNoVolumes" json:"has_no_volumes,omitempty"`
  76. // erasure coding
  77. EcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,16,rep,name=ec_shards,json=ecShards" json:"ec_shards,omitempty"`
  78. // delta erasure coding shards
  79. NewEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,17,rep,name=new_ec_shards,json=newEcShards" json:"new_ec_shards,omitempty"`
  80. DeletedEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,18,rep,name=deleted_ec_shards,json=deletedEcShards" json:"deleted_ec_shards,omitempty"`
  81. HasNoEcShards bool `protobuf:"varint,19,opt,name=has_no_ec_shards,json=hasNoEcShards" json:"has_no_ec_shards,omitempty"`
  82. }
  83. func (m *Heartbeat) Reset() { *m = Heartbeat{} }
  84. func (m *Heartbeat) String() string { return proto.CompactTextString(m) }
  85. func (*Heartbeat) ProtoMessage() {}
  86. func (*Heartbeat) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
  87. func (m *Heartbeat) GetIp() string {
  88. if m != nil {
  89. return m.Ip
  90. }
  91. return ""
  92. }
  93. func (m *Heartbeat) GetPort() uint32 {
  94. if m != nil {
  95. return m.Port
  96. }
  97. return 0
  98. }
  99. func (m *Heartbeat) GetPublicUrl() string {
  100. if m != nil {
  101. return m.PublicUrl
  102. }
  103. return ""
  104. }
  105. func (m *Heartbeat) GetMaxVolumeCount() uint32 {
  106. if m != nil {
  107. return m.MaxVolumeCount
  108. }
  109. return 0
  110. }
  111. func (m *Heartbeat) GetMaxFileKey() uint64 {
  112. if m != nil {
  113. return m.MaxFileKey
  114. }
  115. return 0
  116. }
  117. func (m *Heartbeat) GetDataCenter() string {
  118. if m != nil {
  119. return m.DataCenter
  120. }
  121. return ""
  122. }
  123. func (m *Heartbeat) GetRack() string {
  124. if m != nil {
  125. return m.Rack
  126. }
  127. return ""
  128. }
  129. func (m *Heartbeat) GetAdminPort() uint32 {
  130. if m != nil {
  131. return m.AdminPort
  132. }
  133. return 0
  134. }
  135. func (m *Heartbeat) GetVolumes() []*VolumeInformationMessage {
  136. if m != nil {
  137. return m.Volumes
  138. }
  139. return nil
  140. }
  141. func (m *Heartbeat) GetNewVolumes() []*VolumeShortInformationMessage {
  142. if m != nil {
  143. return m.NewVolumes
  144. }
  145. return nil
  146. }
  147. func (m *Heartbeat) GetDeletedVolumes() []*VolumeShortInformationMessage {
  148. if m != nil {
  149. return m.DeletedVolumes
  150. }
  151. return nil
  152. }
  153. func (m *Heartbeat) GetHasNoVolumes() bool {
  154. if m != nil {
  155. return m.HasNoVolumes
  156. }
  157. return false
  158. }
  159. func (m *Heartbeat) GetEcShards() []*VolumeEcShardInformationMessage {
  160. if m != nil {
  161. return m.EcShards
  162. }
  163. return nil
  164. }
  165. func (m *Heartbeat) GetNewEcShards() []*VolumeEcShardInformationMessage {
  166. if m != nil {
  167. return m.NewEcShards
  168. }
  169. return nil
  170. }
  171. func (m *Heartbeat) GetDeletedEcShards() []*VolumeEcShardInformationMessage {
  172. if m != nil {
  173. return m.DeletedEcShards
  174. }
  175. return nil
  176. }
  177. func (m *Heartbeat) GetHasNoEcShards() bool {
  178. if m != nil {
  179. return m.HasNoEcShards
  180. }
  181. return false
  182. }
  183. type HeartbeatResponse struct {
  184. VolumeSizeLimit uint64 `protobuf:"varint,1,opt,name=volume_size_limit,json=volumeSizeLimit" json:"volume_size_limit,omitempty"`
  185. Leader string `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
  186. MetricsAddress string `protobuf:"bytes,3,opt,name=metrics_address,json=metricsAddress" json:"metrics_address,omitempty"`
  187. MetricsIntervalSeconds uint32 `protobuf:"varint,4,opt,name=metrics_interval_seconds,json=metricsIntervalSeconds" json:"metrics_interval_seconds,omitempty"`
  188. StorageBackends []*StorageBackend `protobuf:"bytes,5,rep,name=storage_backends,json=storageBackends" json:"storage_backends,omitempty"`
  189. }
  190. func (m *HeartbeatResponse) Reset() { *m = HeartbeatResponse{} }
  191. func (m *HeartbeatResponse) String() string { return proto.CompactTextString(m) }
  192. func (*HeartbeatResponse) ProtoMessage() {}
  193. func (*HeartbeatResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
  194. func (m *HeartbeatResponse) GetVolumeSizeLimit() uint64 {
  195. if m != nil {
  196. return m.VolumeSizeLimit
  197. }
  198. return 0
  199. }
  200. func (m *HeartbeatResponse) GetLeader() string {
  201. if m != nil {
  202. return m.Leader
  203. }
  204. return ""
  205. }
  206. func (m *HeartbeatResponse) GetMetricsAddress() string {
  207. if m != nil {
  208. return m.MetricsAddress
  209. }
  210. return ""
  211. }
  212. func (m *HeartbeatResponse) GetMetricsIntervalSeconds() uint32 {
  213. if m != nil {
  214. return m.MetricsIntervalSeconds
  215. }
  216. return 0
  217. }
  218. func (m *HeartbeatResponse) GetStorageBackends() []*StorageBackend {
  219. if m != nil {
  220. return m.StorageBackends
  221. }
  222. return nil
  223. }
  224. type VolumeInformationMessage struct {
  225. Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
  226. Size uint64 `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
  227. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  228. FileCount uint64 `protobuf:"varint,4,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  229. DeleteCount uint64 `protobuf:"varint,5,opt,name=delete_count,json=deleteCount" json:"delete_count,omitempty"`
  230. DeletedByteCount uint64 `protobuf:"varint,6,opt,name=deleted_byte_count,json=deletedByteCount" json:"deleted_byte_count,omitempty"`
  231. ReadOnly bool `protobuf:"varint,7,opt,name=read_only,json=readOnly" json:"read_only,omitempty"`
  232. ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
  233. Version uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
  234. Ttl uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
  235. CompactRevision uint32 `protobuf:"varint,11,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
  236. ModifiedAtSecond int64 `protobuf:"varint,12,opt,name=modified_at_second,json=modifiedAtSecond" json:"modified_at_second,omitempty"`
  237. RemoteStorageName string `protobuf:"bytes,13,opt,name=remote_storage_name,json=remoteStorageName" json:"remote_storage_name,omitempty"`
  238. RemoteStorageKey string `protobuf:"bytes,14,opt,name=remote_storage_key,json=remoteStorageKey" json:"remote_storage_key,omitempty"`
  239. }
  240. func (m *VolumeInformationMessage) Reset() { *m = VolumeInformationMessage{} }
  241. func (m *VolumeInformationMessage) String() string { return proto.CompactTextString(m) }
  242. func (*VolumeInformationMessage) ProtoMessage() {}
  243. func (*VolumeInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
  244. func (m *VolumeInformationMessage) GetId() uint32 {
  245. if m != nil {
  246. return m.Id
  247. }
  248. return 0
  249. }
  250. func (m *VolumeInformationMessage) GetSize() uint64 {
  251. if m != nil {
  252. return m.Size
  253. }
  254. return 0
  255. }
  256. func (m *VolumeInformationMessage) GetCollection() string {
  257. if m != nil {
  258. return m.Collection
  259. }
  260. return ""
  261. }
  262. func (m *VolumeInformationMessage) GetFileCount() uint64 {
  263. if m != nil {
  264. return m.FileCount
  265. }
  266. return 0
  267. }
  268. func (m *VolumeInformationMessage) GetDeleteCount() uint64 {
  269. if m != nil {
  270. return m.DeleteCount
  271. }
  272. return 0
  273. }
  274. func (m *VolumeInformationMessage) GetDeletedByteCount() uint64 {
  275. if m != nil {
  276. return m.DeletedByteCount
  277. }
  278. return 0
  279. }
  280. func (m *VolumeInformationMessage) GetReadOnly() bool {
  281. if m != nil {
  282. return m.ReadOnly
  283. }
  284. return false
  285. }
  286. func (m *VolumeInformationMessage) GetReplicaPlacement() uint32 {
  287. if m != nil {
  288. return m.ReplicaPlacement
  289. }
  290. return 0
  291. }
  292. func (m *VolumeInformationMessage) GetVersion() uint32 {
  293. if m != nil {
  294. return m.Version
  295. }
  296. return 0
  297. }
  298. func (m *VolumeInformationMessage) GetTtl() uint32 {
  299. if m != nil {
  300. return m.Ttl
  301. }
  302. return 0
  303. }
  304. func (m *VolumeInformationMessage) GetCompactRevision() uint32 {
  305. if m != nil {
  306. return m.CompactRevision
  307. }
  308. return 0
  309. }
  310. func (m *VolumeInformationMessage) GetModifiedAtSecond() int64 {
  311. if m != nil {
  312. return m.ModifiedAtSecond
  313. }
  314. return 0
  315. }
  316. func (m *VolumeInformationMessage) GetRemoteStorageName() string {
  317. if m != nil {
  318. return m.RemoteStorageName
  319. }
  320. return ""
  321. }
  322. func (m *VolumeInformationMessage) GetRemoteStorageKey() string {
  323. if m != nil {
  324. return m.RemoteStorageKey
  325. }
  326. return ""
  327. }
  328. type VolumeShortInformationMessage struct {
  329. Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
  330. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  331. ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
  332. Version uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
  333. Ttl uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
  334. }
  335. func (m *VolumeShortInformationMessage) Reset() { *m = VolumeShortInformationMessage{} }
  336. func (m *VolumeShortInformationMessage) String() string { return proto.CompactTextString(m) }
  337. func (*VolumeShortInformationMessage) ProtoMessage() {}
  338. func (*VolumeShortInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
  339. func (m *VolumeShortInformationMessage) GetId() uint32 {
  340. if m != nil {
  341. return m.Id
  342. }
  343. return 0
  344. }
  345. func (m *VolumeShortInformationMessage) GetCollection() string {
  346. if m != nil {
  347. return m.Collection
  348. }
  349. return ""
  350. }
  351. func (m *VolumeShortInformationMessage) GetReplicaPlacement() uint32 {
  352. if m != nil {
  353. return m.ReplicaPlacement
  354. }
  355. return 0
  356. }
  357. func (m *VolumeShortInformationMessage) GetVersion() uint32 {
  358. if m != nil {
  359. return m.Version
  360. }
  361. return 0
  362. }
  363. func (m *VolumeShortInformationMessage) GetTtl() uint32 {
  364. if m != nil {
  365. return m.Ttl
  366. }
  367. return 0
  368. }
  369. type VolumeEcShardInformationMessage struct {
  370. Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
  371. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  372. EcIndexBits uint32 `protobuf:"varint,3,opt,name=ec_index_bits,json=ecIndexBits" json:"ec_index_bits,omitempty"`
  373. }
  374. func (m *VolumeEcShardInformationMessage) Reset() { *m = VolumeEcShardInformationMessage{} }
  375. func (m *VolumeEcShardInformationMessage) String() string { return proto.CompactTextString(m) }
  376. func (*VolumeEcShardInformationMessage) ProtoMessage() {}
  377. func (*VolumeEcShardInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
  378. func (m *VolumeEcShardInformationMessage) GetId() uint32 {
  379. if m != nil {
  380. return m.Id
  381. }
  382. return 0
  383. }
  384. func (m *VolumeEcShardInformationMessage) GetCollection() string {
  385. if m != nil {
  386. return m.Collection
  387. }
  388. return ""
  389. }
  390. func (m *VolumeEcShardInformationMessage) GetEcIndexBits() uint32 {
  391. if m != nil {
  392. return m.EcIndexBits
  393. }
  394. return 0
  395. }
  396. type StorageBackend struct {
  397. Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
  398. Id string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
  399. Properties map[string]string `protobuf:"bytes,3,rep,name=properties" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
  400. }
  401. func (m *StorageBackend) Reset() { *m = StorageBackend{} }
  402. func (m *StorageBackend) String() string { return proto.CompactTextString(m) }
  403. func (*StorageBackend) ProtoMessage() {}
  404. func (*StorageBackend) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
  405. func (m *StorageBackend) GetType() string {
  406. if m != nil {
  407. return m.Type
  408. }
  409. return ""
  410. }
  411. func (m *StorageBackend) GetId() string {
  412. if m != nil {
  413. return m.Id
  414. }
  415. return ""
  416. }
  417. func (m *StorageBackend) GetProperties() map[string]string {
  418. if m != nil {
  419. return m.Properties
  420. }
  421. return nil
  422. }
  423. type Empty struct {
  424. }
  425. func (m *Empty) Reset() { *m = Empty{} }
  426. func (m *Empty) String() string { return proto.CompactTextString(m) }
  427. func (*Empty) ProtoMessage() {}
  428. func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
  429. type SuperBlockExtra struct {
  430. ErasureCoding *SuperBlockExtra_ErasureCoding `protobuf:"bytes,1,opt,name=erasure_coding,json=erasureCoding" json:"erasure_coding,omitempty"`
  431. }
  432. func (m *SuperBlockExtra) Reset() { *m = SuperBlockExtra{} }
  433. func (m *SuperBlockExtra) String() string { return proto.CompactTextString(m) }
  434. func (*SuperBlockExtra) ProtoMessage() {}
  435. func (*SuperBlockExtra) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
  436. func (m *SuperBlockExtra) GetErasureCoding() *SuperBlockExtra_ErasureCoding {
  437. if m != nil {
  438. return m.ErasureCoding
  439. }
  440. return nil
  441. }
  442. type SuperBlockExtra_ErasureCoding struct {
  443. Data uint32 `protobuf:"varint,1,opt,name=data" json:"data,omitempty"`
  444. Parity uint32 `protobuf:"varint,2,opt,name=parity" json:"parity,omitempty"`
  445. VolumeIds []uint32 `protobuf:"varint,3,rep,packed,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
  446. }
  447. func (m *SuperBlockExtra_ErasureCoding) Reset() { *m = SuperBlockExtra_ErasureCoding{} }
  448. func (m *SuperBlockExtra_ErasureCoding) String() string { return proto.CompactTextString(m) }
  449. func (*SuperBlockExtra_ErasureCoding) ProtoMessage() {}
  450. func (*SuperBlockExtra_ErasureCoding) Descriptor() ([]byte, []int) {
  451. return fileDescriptor0, []int{7, 0}
  452. }
  453. func (m *SuperBlockExtra_ErasureCoding) GetData() uint32 {
  454. if m != nil {
  455. return m.Data
  456. }
  457. return 0
  458. }
  459. func (m *SuperBlockExtra_ErasureCoding) GetParity() uint32 {
  460. if m != nil {
  461. return m.Parity
  462. }
  463. return 0
  464. }
  465. func (m *SuperBlockExtra_ErasureCoding) GetVolumeIds() []uint32 {
  466. if m != nil {
  467. return m.VolumeIds
  468. }
  469. return nil
  470. }
  471. type KeepConnectedRequest struct {
  472. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  473. GrpcPort uint32 `protobuf:"varint,2,opt,name=grpc_port,json=grpcPort" json:"grpc_port,omitempty"`
  474. }
  475. func (m *KeepConnectedRequest) Reset() { *m = KeepConnectedRequest{} }
  476. func (m *KeepConnectedRequest) String() string { return proto.CompactTextString(m) }
  477. func (*KeepConnectedRequest) ProtoMessage() {}
  478. func (*KeepConnectedRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
  479. func (m *KeepConnectedRequest) GetName() string {
  480. if m != nil {
  481. return m.Name
  482. }
  483. return ""
  484. }
  485. func (m *KeepConnectedRequest) GetGrpcPort() uint32 {
  486. if m != nil {
  487. return m.GrpcPort
  488. }
  489. return 0
  490. }
  491. type VolumeLocation struct {
  492. Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
  493. PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  494. NewVids []uint32 `protobuf:"varint,3,rep,packed,name=new_vids,json=newVids" json:"new_vids,omitempty"`
  495. DeletedVids []uint32 `protobuf:"varint,4,rep,packed,name=deleted_vids,json=deletedVids" json:"deleted_vids,omitempty"`
  496. Leader string `protobuf:"bytes,5,opt,name=leader" json:"leader,omitempty"`
  497. }
  498. func (m *VolumeLocation) Reset() { *m = VolumeLocation{} }
  499. func (m *VolumeLocation) String() string { return proto.CompactTextString(m) }
  500. func (*VolumeLocation) ProtoMessage() {}
  501. func (*VolumeLocation) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
  502. func (m *VolumeLocation) GetUrl() string {
  503. if m != nil {
  504. return m.Url
  505. }
  506. return ""
  507. }
  508. func (m *VolumeLocation) GetPublicUrl() string {
  509. if m != nil {
  510. return m.PublicUrl
  511. }
  512. return ""
  513. }
  514. func (m *VolumeLocation) GetNewVids() []uint32 {
  515. if m != nil {
  516. return m.NewVids
  517. }
  518. return nil
  519. }
  520. func (m *VolumeLocation) GetDeletedVids() []uint32 {
  521. if m != nil {
  522. return m.DeletedVids
  523. }
  524. return nil
  525. }
  526. func (m *VolumeLocation) GetLeader() string {
  527. if m != nil {
  528. return m.Leader
  529. }
  530. return ""
  531. }
  532. type LookupVolumeRequest struct {
  533. VolumeIds []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
  534. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  535. }
  536. func (m *LookupVolumeRequest) Reset() { *m = LookupVolumeRequest{} }
  537. func (m *LookupVolumeRequest) String() string { return proto.CompactTextString(m) }
  538. func (*LookupVolumeRequest) ProtoMessage() {}
  539. func (*LookupVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
  540. func (m *LookupVolumeRequest) GetVolumeIds() []string {
  541. if m != nil {
  542. return m.VolumeIds
  543. }
  544. return nil
  545. }
  546. func (m *LookupVolumeRequest) GetCollection() string {
  547. if m != nil {
  548. return m.Collection
  549. }
  550. return ""
  551. }
  552. type LookupVolumeResponse struct {
  553. VolumeIdLocations []*LookupVolumeResponse_VolumeIdLocation `protobuf:"bytes,1,rep,name=volume_id_locations,json=volumeIdLocations" json:"volume_id_locations,omitempty"`
  554. }
  555. func (m *LookupVolumeResponse) Reset() { *m = LookupVolumeResponse{} }
  556. func (m *LookupVolumeResponse) String() string { return proto.CompactTextString(m) }
  557. func (*LookupVolumeResponse) ProtoMessage() {}
  558. func (*LookupVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
  559. func (m *LookupVolumeResponse) GetVolumeIdLocations() []*LookupVolumeResponse_VolumeIdLocation {
  560. if m != nil {
  561. return m.VolumeIdLocations
  562. }
  563. return nil
  564. }
  565. type LookupVolumeResponse_VolumeIdLocation struct {
  566. VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  567. Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
  568. Error string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
  569. }
  570. func (m *LookupVolumeResponse_VolumeIdLocation) Reset() { *m = LookupVolumeResponse_VolumeIdLocation{} }
  571. func (m *LookupVolumeResponse_VolumeIdLocation) String() string { return proto.CompactTextString(m) }
  572. func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage() {}
  573. func (*LookupVolumeResponse_VolumeIdLocation) Descriptor() ([]byte, []int) {
  574. return fileDescriptor0, []int{11, 0}
  575. }
  576. func (m *LookupVolumeResponse_VolumeIdLocation) GetVolumeId() string {
  577. if m != nil {
  578. return m.VolumeId
  579. }
  580. return ""
  581. }
  582. func (m *LookupVolumeResponse_VolumeIdLocation) GetLocations() []*Location {
  583. if m != nil {
  584. return m.Locations
  585. }
  586. return nil
  587. }
  588. func (m *LookupVolumeResponse_VolumeIdLocation) GetError() string {
  589. if m != nil {
  590. return m.Error
  591. }
  592. return ""
  593. }
  594. type Location struct {
  595. Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
  596. PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  597. }
  598. func (m *Location) Reset() { *m = Location{} }
  599. func (m *Location) String() string { return proto.CompactTextString(m) }
  600. func (*Location) ProtoMessage() {}
  601. func (*Location) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
  602. func (m *Location) GetUrl() string {
  603. if m != nil {
  604. return m.Url
  605. }
  606. return ""
  607. }
  608. func (m *Location) GetPublicUrl() string {
  609. if m != nil {
  610. return m.PublicUrl
  611. }
  612. return ""
  613. }
  614. type AssignRequest struct {
  615. Count uint64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
  616. Replication string `protobuf:"bytes,2,opt,name=replication" json:"replication,omitempty"`
  617. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  618. Ttl string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
  619. DataCenter string `protobuf:"bytes,5,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
  620. Rack string `protobuf:"bytes,6,opt,name=rack" json:"rack,omitempty"`
  621. DataNode string `protobuf:"bytes,7,opt,name=data_node,json=dataNode" json:"data_node,omitempty"`
  622. MemoryMapMaxSizeMb uint32 `protobuf:"varint,8,opt,name=memory_map_max_size_mb,json=memoryMapMaxSizeMb" json:"memory_map_max_size_mb,omitempty"`
  623. WritableVolumeCount uint32 `protobuf:"varint,9,opt,name=Writable_volume_count,json=WritableVolumeCount" json:"Writable_volume_count,omitempty"`
  624. }
  625. func (m *AssignRequest) Reset() { *m = AssignRequest{} }
  626. func (m *AssignRequest) String() string { return proto.CompactTextString(m) }
  627. func (*AssignRequest) ProtoMessage() {}
  628. func (*AssignRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
  629. func (m *AssignRequest) GetCount() uint64 {
  630. if m != nil {
  631. return m.Count
  632. }
  633. return 0
  634. }
  635. func (m *AssignRequest) GetReplication() string {
  636. if m != nil {
  637. return m.Replication
  638. }
  639. return ""
  640. }
  641. func (m *AssignRequest) GetCollection() string {
  642. if m != nil {
  643. return m.Collection
  644. }
  645. return ""
  646. }
  647. func (m *AssignRequest) GetTtl() string {
  648. if m != nil {
  649. return m.Ttl
  650. }
  651. return ""
  652. }
  653. func (m *AssignRequest) GetDataCenter() string {
  654. if m != nil {
  655. return m.DataCenter
  656. }
  657. return ""
  658. }
  659. func (m *AssignRequest) GetRack() string {
  660. if m != nil {
  661. return m.Rack
  662. }
  663. return ""
  664. }
  665. func (m *AssignRequest) GetDataNode() string {
  666. if m != nil {
  667. return m.DataNode
  668. }
  669. return ""
  670. }
  671. func (m *AssignRequest) GetMemoryMapMaxSizeMb() uint32 {
  672. if m != nil {
  673. return m.MemoryMapMaxSizeMb
  674. }
  675. return 0
  676. }
  677. func (m *AssignRequest) GetWritableVolumeCount() uint32 {
  678. if m != nil {
  679. return m.WritableVolumeCount
  680. }
  681. return 0
  682. }
  683. type AssignResponse struct {
  684. Fid string `protobuf:"bytes,1,opt,name=fid" json:"fid,omitempty"`
  685. Url string `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
  686. PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  687. Count uint64 `protobuf:"varint,4,opt,name=count" json:"count,omitempty"`
  688. Error string `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
  689. Auth string `protobuf:"bytes,6,opt,name=auth" json:"auth,omitempty"`
  690. }
  691. func (m *AssignResponse) Reset() { *m = AssignResponse{} }
  692. func (m *AssignResponse) String() string { return proto.CompactTextString(m) }
  693. func (*AssignResponse) ProtoMessage() {}
  694. func (*AssignResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
  695. func (m *AssignResponse) GetFid() string {
  696. if m != nil {
  697. return m.Fid
  698. }
  699. return ""
  700. }
  701. func (m *AssignResponse) GetUrl() string {
  702. if m != nil {
  703. return m.Url
  704. }
  705. return ""
  706. }
  707. func (m *AssignResponse) GetPublicUrl() string {
  708. if m != nil {
  709. return m.PublicUrl
  710. }
  711. return ""
  712. }
  713. func (m *AssignResponse) GetCount() uint64 {
  714. if m != nil {
  715. return m.Count
  716. }
  717. return 0
  718. }
  719. func (m *AssignResponse) GetError() string {
  720. if m != nil {
  721. return m.Error
  722. }
  723. return ""
  724. }
  725. func (m *AssignResponse) GetAuth() string {
  726. if m != nil {
  727. return m.Auth
  728. }
  729. return ""
  730. }
  731. type StatisticsRequest struct {
  732. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  733. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  734. Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
  735. }
  736. func (m *StatisticsRequest) Reset() { *m = StatisticsRequest{} }
  737. func (m *StatisticsRequest) String() string { return proto.CompactTextString(m) }
  738. func (*StatisticsRequest) ProtoMessage() {}
  739. func (*StatisticsRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
  740. func (m *StatisticsRequest) GetReplication() string {
  741. if m != nil {
  742. return m.Replication
  743. }
  744. return ""
  745. }
  746. func (m *StatisticsRequest) GetCollection() string {
  747. if m != nil {
  748. return m.Collection
  749. }
  750. return ""
  751. }
  752. func (m *StatisticsRequest) GetTtl() string {
  753. if m != nil {
  754. return m.Ttl
  755. }
  756. return ""
  757. }
  758. type StatisticsResponse struct {
  759. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  760. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  761. Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
  762. TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize" json:"total_size,omitempty"`
  763. UsedSize uint64 `protobuf:"varint,5,opt,name=used_size,json=usedSize" json:"used_size,omitempty"`
  764. FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  765. }
  766. func (m *StatisticsResponse) Reset() { *m = StatisticsResponse{} }
  767. func (m *StatisticsResponse) String() string { return proto.CompactTextString(m) }
  768. func (*StatisticsResponse) ProtoMessage() {}
  769. func (*StatisticsResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
  770. func (m *StatisticsResponse) GetReplication() string {
  771. if m != nil {
  772. return m.Replication
  773. }
  774. return ""
  775. }
  776. func (m *StatisticsResponse) GetCollection() string {
  777. if m != nil {
  778. return m.Collection
  779. }
  780. return ""
  781. }
  782. func (m *StatisticsResponse) GetTtl() string {
  783. if m != nil {
  784. return m.Ttl
  785. }
  786. return ""
  787. }
  788. func (m *StatisticsResponse) GetTotalSize() uint64 {
  789. if m != nil {
  790. return m.TotalSize
  791. }
  792. return 0
  793. }
  794. func (m *StatisticsResponse) GetUsedSize() uint64 {
  795. if m != nil {
  796. return m.UsedSize
  797. }
  798. return 0
  799. }
  800. func (m *StatisticsResponse) GetFileCount() uint64 {
  801. if m != nil {
  802. return m.FileCount
  803. }
  804. return 0
  805. }
  806. type StorageType struct {
  807. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  808. Ttl string `protobuf:"bytes,2,opt,name=ttl" json:"ttl,omitempty"`
  809. }
  810. func (m *StorageType) Reset() { *m = StorageType{} }
  811. func (m *StorageType) String() string { return proto.CompactTextString(m) }
  812. func (*StorageType) ProtoMessage() {}
  813. func (*StorageType) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} }
  814. func (m *StorageType) GetReplication() string {
  815. if m != nil {
  816. return m.Replication
  817. }
  818. return ""
  819. }
  820. func (m *StorageType) GetTtl() string {
  821. if m != nil {
  822. return m.Ttl
  823. }
  824. return ""
  825. }
  826. type Collection struct {
  827. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  828. }
  829. func (m *Collection) Reset() { *m = Collection{} }
  830. func (m *Collection) String() string { return proto.CompactTextString(m) }
  831. func (*Collection) ProtoMessage() {}
  832. func (*Collection) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{18} }
  833. func (m *Collection) GetName() string {
  834. if m != nil {
  835. return m.Name
  836. }
  837. return ""
  838. }
  839. type CollectionListRequest struct {
  840. IncludeNormalVolumes bool `protobuf:"varint,1,opt,name=include_normal_volumes,json=includeNormalVolumes" json:"include_normal_volumes,omitempty"`
  841. IncludeEcVolumes bool `protobuf:"varint,2,opt,name=include_ec_volumes,json=includeEcVolumes" json:"include_ec_volumes,omitempty"`
  842. }
  843. func (m *CollectionListRequest) Reset() { *m = CollectionListRequest{} }
  844. func (m *CollectionListRequest) String() string { return proto.CompactTextString(m) }
  845. func (*CollectionListRequest) ProtoMessage() {}
  846. func (*CollectionListRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{19} }
  847. func (m *CollectionListRequest) GetIncludeNormalVolumes() bool {
  848. if m != nil {
  849. return m.IncludeNormalVolumes
  850. }
  851. return false
  852. }
  853. func (m *CollectionListRequest) GetIncludeEcVolumes() bool {
  854. if m != nil {
  855. return m.IncludeEcVolumes
  856. }
  857. return false
  858. }
  859. type CollectionListResponse struct {
  860. Collections []*Collection `protobuf:"bytes,1,rep,name=collections" json:"collections,omitempty"`
  861. }
  862. func (m *CollectionListResponse) Reset() { *m = CollectionListResponse{} }
  863. func (m *CollectionListResponse) String() string { return proto.CompactTextString(m) }
  864. func (*CollectionListResponse) ProtoMessage() {}
  865. func (*CollectionListResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{20} }
  866. func (m *CollectionListResponse) GetCollections() []*Collection {
  867. if m != nil {
  868. return m.Collections
  869. }
  870. return nil
  871. }
  872. type CollectionDeleteRequest struct {
  873. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  874. }
  875. func (m *CollectionDeleteRequest) Reset() { *m = CollectionDeleteRequest{} }
  876. func (m *CollectionDeleteRequest) String() string { return proto.CompactTextString(m) }
  877. func (*CollectionDeleteRequest) ProtoMessage() {}
  878. func (*CollectionDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{21} }
  879. func (m *CollectionDeleteRequest) GetName() string {
  880. if m != nil {
  881. return m.Name
  882. }
  883. return ""
  884. }
  885. type CollectionDeleteResponse struct {
  886. }
  887. func (m *CollectionDeleteResponse) Reset() { *m = CollectionDeleteResponse{} }
  888. func (m *CollectionDeleteResponse) String() string { return proto.CompactTextString(m) }
  889. func (*CollectionDeleteResponse) ProtoMessage() {}
  890. func (*CollectionDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{22} }
  891. //
  892. // volume related
  893. //
  894. type DataNodeInfo struct {
  895. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  896. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  897. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  898. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  899. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  900. VolumeInfos []*VolumeInformationMessage `protobuf:"bytes,6,rep,name=volume_infos,json=volumeInfos" json:"volume_infos,omitempty"`
  901. EcShardInfos []*VolumeEcShardInformationMessage `protobuf:"bytes,7,rep,name=ec_shard_infos,json=ecShardInfos" json:"ec_shard_infos,omitempty"`
  902. RemoteVolumeCount uint64 `protobuf:"varint,8,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
  903. }
  904. func (m *DataNodeInfo) Reset() { *m = DataNodeInfo{} }
  905. func (m *DataNodeInfo) String() string { return proto.CompactTextString(m) }
  906. func (*DataNodeInfo) ProtoMessage() {}
  907. func (*DataNodeInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{23} }
  908. func (m *DataNodeInfo) GetId() string {
  909. if m != nil {
  910. return m.Id
  911. }
  912. return ""
  913. }
  914. func (m *DataNodeInfo) GetVolumeCount() uint64 {
  915. if m != nil {
  916. return m.VolumeCount
  917. }
  918. return 0
  919. }
  920. func (m *DataNodeInfo) GetMaxVolumeCount() uint64 {
  921. if m != nil {
  922. return m.MaxVolumeCount
  923. }
  924. return 0
  925. }
  926. func (m *DataNodeInfo) GetFreeVolumeCount() uint64 {
  927. if m != nil {
  928. return m.FreeVolumeCount
  929. }
  930. return 0
  931. }
  932. func (m *DataNodeInfo) GetActiveVolumeCount() uint64 {
  933. if m != nil {
  934. return m.ActiveVolumeCount
  935. }
  936. return 0
  937. }
  938. func (m *DataNodeInfo) GetVolumeInfos() []*VolumeInformationMessage {
  939. if m != nil {
  940. return m.VolumeInfos
  941. }
  942. return nil
  943. }
  944. func (m *DataNodeInfo) GetEcShardInfos() []*VolumeEcShardInformationMessage {
  945. if m != nil {
  946. return m.EcShardInfos
  947. }
  948. return nil
  949. }
  950. func (m *DataNodeInfo) GetRemoteVolumeCount() uint64 {
  951. if m != nil {
  952. return m.RemoteVolumeCount
  953. }
  954. return 0
  955. }
  956. type RackInfo struct {
  957. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  958. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  959. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  960. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  961. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  962. DataNodeInfos []*DataNodeInfo `protobuf:"bytes,6,rep,name=data_node_infos,json=dataNodeInfos" json:"data_node_infos,omitempty"`
  963. RemoteVolumeCount uint64 `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
  964. }
  965. func (m *RackInfo) Reset() { *m = RackInfo{} }
  966. func (m *RackInfo) String() string { return proto.CompactTextString(m) }
  967. func (*RackInfo) ProtoMessage() {}
  968. func (*RackInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{24} }
  969. func (m *RackInfo) GetId() string {
  970. if m != nil {
  971. return m.Id
  972. }
  973. return ""
  974. }
  975. func (m *RackInfo) GetVolumeCount() uint64 {
  976. if m != nil {
  977. return m.VolumeCount
  978. }
  979. return 0
  980. }
  981. func (m *RackInfo) GetMaxVolumeCount() uint64 {
  982. if m != nil {
  983. return m.MaxVolumeCount
  984. }
  985. return 0
  986. }
  987. func (m *RackInfo) GetFreeVolumeCount() uint64 {
  988. if m != nil {
  989. return m.FreeVolumeCount
  990. }
  991. return 0
  992. }
  993. func (m *RackInfo) GetActiveVolumeCount() uint64 {
  994. if m != nil {
  995. return m.ActiveVolumeCount
  996. }
  997. return 0
  998. }
  999. func (m *RackInfo) GetDataNodeInfos() []*DataNodeInfo {
  1000. if m != nil {
  1001. return m.DataNodeInfos
  1002. }
  1003. return nil
  1004. }
  1005. func (m *RackInfo) GetRemoteVolumeCount() uint64 {
  1006. if m != nil {
  1007. return m.RemoteVolumeCount
  1008. }
  1009. return 0
  1010. }
  1011. type DataCenterInfo struct {
  1012. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  1013. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  1014. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  1015. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  1016. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  1017. RackInfos []*RackInfo `protobuf:"bytes,6,rep,name=rack_infos,json=rackInfos" json:"rack_infos,omitempty"`
  1018. RemoteVolumeCount uint64 `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
  1019. }
  1020. func (m *DataCenterInfo) Reset() { *m = DataCenterInfo{} }
  1021. func (m *DataCenterInfo) String() string { return proto.CompactTextString(m) }
  1022. func (*DataCenterInfo) ProtoMessage() {}
  1023. func (*DataCenterInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{25} }
  1024. func (m *DataCenterInfo) GetId() string {
  1025. if m != nil {
  1026. return m.Id
  1027. }
  1028. return ""
  1029. }
  1030. func (m *DataCenterInfo) GetVolumeCount() uint64 {
  1031. if m != nil {
  1032. return m.VolumeCount
  1033. }
  1034. return 0
  1035. }
  1036. func (m *DataCenterInfo) GetMaxVolumeCount() uint64 {
  1037. if m != nil {
  1038. return m.MaxVolumeCount
  1039. }
  1040. return 0
  1041. }
  1042. func (m *DataCenterInfo) GetFreeVolumeCount() uint64 {
  1043. if m != nil {
  1044. return m.FreeVolumeCount
  1045. }
  1046. return 0
  1047. }
  1048. func (m *DataCenterInfo) GetActiveVolumeCount() uint64 {
  1049. if m != nil {
  1050. return m.ActiveVolumeCount
  1051. }
  1052. return 0
  1053. }
  1054. func (m *DataCenterInfo) GetRackInfos() []*RackInfo {
  1055. if m != nil {
  1056. return m.RackInfos
  1057. }
  1058. return nil
  1059. }
  1060. func (m *DataCenterInfo) GetRemoteVolumeCount() uint64 {
  1061. if m != nil {
  1062. return m.RemoteVolumeCount
  1063. }
  1064. return 0
  1065. }
  1066. type TopologyInfo struct {
  1067. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  1068. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  1069. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  1070. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  1071. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  1072. DataCenterInfos []*DataCenterInfo `protobuf:"bytes,6,rep,name=data_center_infos,json=dataCenterInfos" json:"data_center_infos,omitempty"`
  1073. RemoteVolumeCount uint64 `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount" json:"remote_volume_count,omitempty"`
  1074. }
  1075. func (m *TopologyInfo) Reset() { *m = TopologyInfo{} }
  1076. func (m *TopologyInfo) String() string { return proto.CompactTextString(m) }
  1077. func (*TopologyInfo) ProtoMessage() {}
  1078. func (*TopologyInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{26} }
  1079. func (m *TopologyInfo) GetId() string {
  1080. if m != nil {
  1081. return m.Id
  1082. }
  1083. return ""
  1084. }
  1085. func (m *TopologyInfo) GetVolumeCount() uint64 {
  1086. if m != nil {
  1087. return m.VolumeCount
  1088. }
  1089. return 0
  1090. }
  1091. func (m *TopologyInfo) GetMaxVolumeCount() uint64 {
  1092. if m != nil {
  1093. return m.MaxVolumeCount
  1094. }
  1095. return 0
  1096. }
  1097. func (m *TopologyInfo) GetFreeVolumeCount() uint64 {
  1098. if m != nil {
  1099. return m.FreeVolumeCount
  1100. }
  1101. return 0
  1102. }
  1103. func (m *TopologyInfo) GetActiveVolumeCount() uint64 {
  1104. if m != nil {
  1105. return m.ActiveVolumeCount
  1106. }
  1107. return 0
  1108. }
  1109. func (m *TopologyInfo) GetDataCenterInfos() []*DataCenterInfo {
  1110. if m != nil {
  1111. return m.DataCenterInfos
  1112. }
  1113. return nil
  1114. }
  1115. func (m *TopologyInfo) GetRemoteVolumeCount() uint64 {
  1116. if m != nil {
  1117. return m.RemoteVolumeCount
  1118. }
  1119. return 0
  1120. }
  1121. type VolumeListRequest struct {
  1122. }
  1123. func (m *VolumeListRequest) Reset() { *m = VolumeListRequest{} }
  1124. func (m *VolumeListRequest) String() string { return proto.CompactTextString(m) }
  1125. func (*VolumeListRequest) ProtoMessage() {}
  1126. func (*VolumeListRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{27} }
  1127. type VolumeListResponse struct {
  1128. TopologyInfo *TopologyInfo `protobuf:"bytes,1,opt,name=topology_info,json=topologyInfo" json:"topology_info,omitempty"`
  1129. VolumeSizeLimitMb uint64 `protobuf:"varint,2,opt,name=volume_size_limit_mb,json=volumeSizeLimitMb" json:"volume_size_limit_mb,omitempty"`
  1130. }
  1131. func (m *VolumeListResponse) Reset() { *m = VolumeListResponse{} }
  1132. func (m *VolumeListResponse) String() string { return proto.CompactTextString(m) }
  1133. func (*VolumeListResponse) ProtoMessage() {}
  1134. func (*VolumeListResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{28} }
  1135. func (m *VolumeListResponse) GetTopologyInfo() *TopologyInfo {
  1136. if m != nil {
  1137. return m.TopologyInfo
  1138. }
  1139. return nil
  1140. }
  1141. func (m *VolumeListResponse) GetVolumeSizeLimitMb() uint64 {
  1142. if m != nil {
  1143. return m.VolumeSizeLimitMb
  1144. }
  1145. return 0
  1146. }
  1147. type LookupEcVolumeRequest struct {
  1148. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1149. }
  1150. func (m *LookupEcVolumeRequest) Reset() { *m = LookupEcVolumeRequest{} }
  1151. func (m *LookupEcVolumeRequest) String() string { return proto.CompactTextString(m) }
  1152. func (*LookupEcVolumeRequest) ProtoMessage() {}
  1153. func (*LookupEcVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{29} }
  1154. func (m *LookupEcVolumeRequest) GetVolumeId() uint32 {
  1155. if m != nil {
  1156. return m.VolumeId
  1157. }
  1158. return 0
  1159. }
  1160. type LookupEcVolumeResponse struct {
  1161. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  1162. ShardIdLocations []*LookupEcVolumeResponse_EcShardIdLocation `protobuf:"bytes,2,rep,name=shard_id_locations,json=shardIdLocations" json:"shard_id_locations,omitempty"`
  1163. }
  1164. func (m *LookupEcVolumeResponse) Reset() { *m = LookupEcVolumeResponse{} }
  1165. func (m *LookupEcVolumeResponse) String() string { return proto.CompactTextString(m) }
  1166. func (*LookupEcVolumeResponse) ProtoMessage() {}
  1167. func (*LookupEcVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{30} }
  1168. func (m *LookupEcVolumeResponse) GetVolumeId() uint32 {
  1169. if m != nil {
  1170. return m.VolumeId
  1171. }
  1172. return 0
  1173. }
  1174. func (m *LookupEcVolumeResponse) GetShardIdLocations() []*LookupEcVolumeResponse_EcShardIdLocation {
  1175. if m != nil {
  1176. return m.ShardIdLocations
  1177. }
  1178. return nil
  1179. }
  1180. type LookupEcVolumeResponse_EcShardIdLocation struct {
  1181. ShardId uint32 `protobuf:"varint,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
  1182. Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
  1183. }
  1184. func (m *LookupEcVolumeResponse_EcShardIdLocation) Reset() {
  1185. *m = LookupEcVolumeResponse_EcShardIdLocation{}
  1186. }
  1187. func (m *LookupEcVolumeResponse_EcShardIdLocation) String() string { return proto.CompactTextString(m) }
  1188. func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage() {}
  1189. func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor() ([]byte, []int) {
  1190. return fileDescriptor0, []int{30, 0}
  1191. }
  1192. func (m *LookupEcVolumeResponse_EcShardIdLocation) GetShardId() uint32 {
  1193. if m != nil {
  1194. return m.ShardId
  1195. }
  1196. return 0
  1197. }
  1198. func (m *LookupEcVolumeResponse_EcShardIdLocation) GetLocations() []*Location {
  1199. if m != nil {
  1200. return m.Locations
  1201. }
  1202. return nil
  1203. }
  1204. type GetMasterConfigurationRequest struct {
  1205. }
  1206. func (m *GetMasterConfigurationRequest) Reset() { *m = GetMasterConfigurationRequest{} }
  1207. func (m *GetMasterConfigurationRequest) String() string { return proto.CompactTextString(m) }
  1208. func (*GetMasterConfigurationRequest) ProtoMessage() {}
  1209. func (*GetMasterConfigurationRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{31} }
  1210. type GetMasterConfigurationResponse struct {
  1211. MetricsAddress string `protobuf:"bytes,1,opt,name=metrics_address,json=metricsAddress" json:"metrics_address,omitempty"`
  1212. MetricsIntervalSeconds uint32 `protobuf:"varint,2,opt,name=metrics_interval_seconds,json=metricsIntervalSeconds" json:"metrics_interval_seconds,omitempty"`
  1213. }
  1214. func (m *GetMasterConfigurationResponse) Reset() { *m = GetMasterConfigurationResponse{} }
  1215. func (m *GetMasterConfigurationResponse) String() string { return proto.CompactTextString(m) }
  1216. func (*GetMasterConfigurationResponse) ProtoMessage() {}
  1217. func (*GetMasterConfigurationResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{32} }
  1218. func (m *GetMasterConfigurationResponse) GetMetricsAddress() string {
  1219. if m != nil {
  1220. return m.MetricsAddress
  1221. }
  1222. return ""
  1223. }
  1224. func (m *GetMasterConfigurationResponse) GetMetricsIntervalSeconds() uint32 {
  1225. if m != nil {
  1226. return m.MetricsIntervalSeconds
  1227. }
  1228. return 0
  1229. }
  1230. type ListMasterClientsRequest struct {
  1231. ClientType string `protobuf:"bytes,1,opt,name=client_type,json=clientType" json:"client_type,omitempty"`
  1232. }
  1233. func (m *ListMasterClientsRequest) Reset() { *m = ListMasterClientsRequest{} }
  1234. func (m *ListMasterClientsRequest) String() string { return proto.CompactTextString(m) }
  1235. func (*ListMasterClientsRequest) ProtoMessage() {}
  1236. func (*ListMasterClientsRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{33} }
  1237. func (m *ListMasterClientsRequest) GetClientType() string {
  1238. if m != nil {
  1239. return m.ClientType
  1240. }
  1241. return ""
  1242. }
  1243. type ListMasterClientsResponse struct {
  1244. GrpcAddresses []string `protobuf:"bytes,1,rep,name=grpc_addresses,json=grpcAddresses" json:"grpc_addresses,omitempty"`
  1245. }
  1246. func (m *ListMasterClientsResponse) Reset() { *m = ListMasterClientsResponse{} }
  1247. func (m *ListMasterClientsResponse) String() string { return proto.CompactTextString(m) }
  1248. func (*ListMasterClientsResponse) ProtoMessage() {}
  1249. func (*ListMasterClientsResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{34} }
  1250. func (m *ListMasterClientsResponse) GetGrpcAddresses() []string {
  1251. if m != nil {
  1252. return m.GrpcAddresses
  1253. }
  1254. return nil
  1255. }
  1256. func init() {
  1257. proto.RegisterType((*Heartbeat)(nil), "master_pb.Heartbeat")
  1258. proto.RegisterType((*HeartbeatResponse)(nil), "master_pb.HeartbeatResponse")
  1259. proto.RegisterType((*VolumeInformationMessage)(nil), "master_pb.VolumeInformationMessage")
  1260. proto.RegisterType((*VolumeShortInformationMessage)(nil), "master_pb.VolumeShortInformationMessage")
  1261. proto.RegisterType((*VolumeEcShardInformationMessage)(nil), "master_pb.VolumeEcShardInformationMessage")
  1262. proto.RegisterType((*StorageBackend)(nil), "master_pb.StorageBackend")
  1263. proto.RegisterType((*Empty)(nil), "master_pb.Empty")
  1264. proto.RegisterType((*SuperBlockExtra)(nil), "master_pb.SuperBlockExtra")
  1265. proto.RegisterType((*SuperBlockExtra_ErasureCoding)(nil), "master_pb.SuperBlockExtra.ErasureCoding")
  1266. proto.RegisterType((*KeepConnectedRequest)(nil), "master_pb.KeepConnectedRequest")
  1267. proto.RegisterType((*VolumeLocation)(nil), "master_pb.VolumeLocation")
  1268. proto.RegisterType((*LookupVolumeRequest)(nil), "master_pb.LookupVolumeRequest")
  1269. proto.RegisterType((*LookupVolumeResponse)(nil), "master_pb.LookupVolumeResponse")
  1270. proto.RegisterType((*LookupVolumeResponse_VolumeIdLocation)(nil), "master_pb.LookupVolumeResponse.VolumeIdLocation")
  1271. proto.RegisterType((*Location)(nil), "master_pb.Location")
  1272. proto.RegisterType((*AssignRequest)(nil), "master_pb.AssignRequest")
  1273. proto.RegisterType((*AssignResponse)(nil), "master_pb.AssignResponse")
  1274. proto.RegisterType((*StatisticsRequest)(nil), "master_pb.StatisticsRequest")
  1275. proto.RegisterType((*StatisticsResponse)(nil), "master_pb.StatisticsResponse")
  1276. proto.RegisterType((*StorageType)(nil), "master_pb.StorageType")
  1277. proto.RegisterType((*Collection)(nil), "master_pb.Collection")
  1278. proto.RegisterType((*CollectionListRequest)(nil), "master_pb.CollectionListRequest")
  1279. proto.RegisterType((*CollectionListResponse)(nil), "master_pb.CollectionListResponse")
  1280. proto.RegisterType((*CollectionDeleteRequest)(nil), "master_pb.CollectionDeleteRequest")
  1281. proto.RegisterType((*CollectionDeleteResponse)(nil), "master_pb.CollectionDeleteResponse")
  1282. proto.RegisterType((*DataNodeInfo)(nil), "master_pb.DataNodeInfo")
  1283. proto.RegisterType((*RackInfo)(nil), "master_pb.RackInfo")
  1284. proto.RegisterType((*DataCenterInfo)(nil), "master_pb.DataCenterInfo")
  1285. proto.RegisterType((*TopologyInfo)(nil), "master_pb.TopologyInfo")
  1286. proto.RegisterType((*VolumeListRequest)(nil), "master_pb.VolumeListRequest")
  1287. proto.RegisterType((*VolumeListResponse)(nil), "master_pb.VolumeListResponse")
  1288. proto.RegisterType((*LookupEcVolumeRequest)(nil), "master_pb.LookupEcVolumeRequest")
  1289. proto.RegisterType((*LookupEcVolumeResponse)(nil), "master_pb.LookupEcVolumeResponse")
  1290. proto.RegisterType((*LookupEcVolumeResponse_EcShardIdLocation)(nil), "master_pb.LookupEcVolumeResponse.EcShardIdLocation")
  1291. proto.RegisterType((*GetMasterConfigurationRequest)(nil), "master_pb.GetMasterConfigurationRequest")
  1292. proto.RegisterType((*GetMasterConfigurationResponse)(nil), "master_pb.GetMasterConfigurationResponse")
  1293. proto.RegisterType((*ListMasterClientsRequest)(nil), "master_pb.ListMasterClientsRequest")
  1294. proto.RegisterType((*ListMasterClientsResponse)(nil), "master_pb.ListMasterClientsResponse")
  1295. }
  1296. // Reference imports to suppress errors if they are not otherwise used.
  1297. var _ context.Context
  1298. var _ grpc.ClientConn
  1299. // This is a compile-time assertion to ensure that this generated file
  1300. // is compatible with the grpc package it is being compiled against.
  1301. const _ = grpc.SupportPackageIsVersion4
  1302. // Client API for Seaweed service
  1303. type SeaweedClient interface {
  1304. SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error)
  1305. KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error)
  1306. LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error)
  1307. Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error)
  1308. Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
  1309. CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error)
  1310. CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error)
  1311. VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error)
  1312. LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error)
  1313. GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error)
  1314. ListMasterClients(ctx context.Context, in *ListMasterClientsRequest, opts ...grpc.CallOption) (*ListMasterClientsResponse, error)
  1315. }
  1316. type seaweedClient struct {
  1317. cc *grpc.ClientConn
  1318. }
  1319. func NewSeaweedClient(cc *grpc.ClientConn) SeaweedClient {
  1320. return &seaweedClient{cc}
  1321. }
  1322. func (c *seaweedClient) SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) {
  1323. stream, err := grpc.NewClientStream(ctx, &_Seaweed_serviceDesc.Streams[0], c.cc, "/master_pb.Seaweed/SendHeartbeat", opts...)
  1324. if err != nil {
  1325. return nil, err
  1326. }
  1327. x := &seaweedSendHeartbeatClient{stream}
  1328. return x, nil
  1329. }
  1330. type Seaweed_SendHeartbeatClient interface {
  1331. Send(*Heartbeat) error
  1332. Recv() (*HeartbeatResponse, error)
  1333. grpc.ClientStream
  1334. }
  1335. type seaweedSendHeartbeatClient struct {
  1336. grpc.ClientStream
  1337. }
  1338. func (x *seaweedSendHeartbeatClient) Send(m *Heartbeat) error {
  1339. return x.ClientStream.SendMsg(m)
  1340. }
  1341. func (x *seaweedSendHeartbeatClient) Recv() (*HeartbeatResponse, error) {
  1342. m := new(HeartbeatResponse)
  1343. if err := x.ClientStream.RecvMsg(m); err != nil {
  1344. return nil, err
  1345. }
  1346. return m, nil
  1347. }
  1348. func (c *seaweedClient) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) {
  1349. stream, err := grpc.NewClientStream(ctx, &_Seaweed_serviceDesc.Streams[1], c.cc, "/master_pb.Seaweed/KeepConnected", opts...)
  1350. if err != nil {
  1351. return nil, err
  1352. }
  1353. x := &seaweedKeepConnectedClient{stream}
  1354. return x, nil
  1355. }
  1356. type Seaweed_KeepConnectedClient interface {
  1357. Send(*KeepConnectedRequest) error
  1358. Recv() (*VolumeLocation, error)
  1359. grpc.ClientStream
  1360. }
  1361. type seaweedKeepConnectedClient struct {
  1362. grpc.ClientStream
  1363. }
  1364. func (x *seaweedKeepConnectedClient) Send(m *KeepConnectedRequest) error {
  1365. return x.ClientStream.SendMsg(m)
  1366. }
  1367. func (x *seaweedKeepConnectedClient) Recv() (*VolumeLocation, error) {
  1368. m := new(VolumeLocation)
  1369. if err := x.ClientStream.RecvMsg(m); err != nil {
  1370. return nil, err
  1371. }
  1372. return m, nil
  1373. }
  1374. func (c *seaweedClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) {
  1375. out := new(LookupVolumeResponse)
  1376. err := grpc.Invoke(ctx, "/master_pb.Seaweed/LookupVolume", in, out, c.cc, opts...)
  1377. if err != nil {
  1378. return nil, err
  1379. }
  1380. return out, nil
  1381. }
  1382. func (c *seaweedClient) Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) {
  1383. out := new(AssignResponse)
  1384. err := grpc.Invoke(ctx, "/master_pb.Seaweed/Assign", in, out, c.cc, opts...)
  1385. if err != nil {
  1386. return nil, err
  1387. }
  1388. return out, nil
  1389. }
  1390. func (c *seaweedClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) {
  1391. out := new(StatisticsResponse)
  1392. err := grpc.Invoke(ctx, "/master_pb.Seaweed/Statistics", in, out, c.cc, opts...)
  1393. if err != nil {
  1394. return nil, err
  1395. }
  1396. return out, nil
  1397. }
  1398. func (c *seaweedClient) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) {
  1399. out := new(CollectionListResponse)
  1400. err := grpc.Invoke(ctx, "/master_pb.Seaweed/CollectionList", in, out, c.cc, opts...)
  1401. if err != nil {
  1402. return nil, err
  1403. }
  1404. return out, nil
  1405. }
  1406. func (c *seaweedClient) CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) {
  1407. out := new(CollectionDeleteResponse)
  1408. err := grpc.Invoke(ctx, "/master_pb.Seaweed/CollectionDelete", in, out, c.cc, opts...)
  1409. if err != nil {
  1410. return nil, err
  1411. }
  1412. return out, nil
  1413. }
  1414. func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) {
  1415. out := new(VolumeListResponse)
  1416. err := grpc.Invoke(ctx, "/master_pb.Seaweed/VolumeList", in, out, c.cc, opts...)
  1417. if err != nil {
  1418. return nil, err
  1419. }
  1420. return out, nil
  1421. }
  1422. func (c *seaweedClient) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) {
  1423. out := new(LookupEcVolumeResponse)
  1424. err := grpc.Invoke(ctx, "/master_pb.Seaweed/LookupEcVolume", in, out, c.cc, opts...)
  1425. if err != nil {
  1426. return nil, err
  1427. }
  1428. return out, nil
  1429. }
  1430. func (c *seaweedClient) GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error) {
  1431. out := new(GetMasterConfigurationResponse)
  1432. err := grpc.Invoke(ctx, "/master_pb.Seaweed/GetMasterConfiguration", in, out, c.cc, opts...)
  1433. if err != nil {
  1434. return nil, err
  1435. }
  1436. return out, nil
  1437. }
  1438. func (c *seaweedClient) ListMasterClients(ctx context.Context, in *ListMasterClientsRequest, opts ...grpc.CallOption) (*ListMasterClientsResponse, error) {
  1439. out := new(ListMasterClientsResponse)
  1440. err := grpc.Invoke(ctx, "/master_pb.Seaweed/ListMasterClients", in, out, c.cc, opts...)
  1441. if err != nil {
  1442. return nil, err
  1443. }
  1444. return out, nil
  1445. }
  1446. // Server API for Seaweed service
  1447. type SeaweedServer interface {
  1448. SendHeartbeat(Seaweed_SendHeartbeatServer) error
  1449. KeepConnected(Seaweed_KeepConnectedServer) error
  1450. LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
  1451. Assign(context.Context, *AssignRequest) (*AssignResponse, error)
  1452. Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
  1453. CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
  1454. CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error)
  1455. VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)
  1456. LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error)
  1457. GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error)
  1458. ListMasterClients(context.Context, *ListMasterClientsRequest) (*ListMasterClientsResponse, error)
  1459. }
  1460. func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer) {
  1461. s.RegisterService(&_Seaweed_serviceDesc, srv)
  1462. }
  1463. func _Seaweed_SendHeartbeat_Handler(srv interface{}, stream grpc.ServerStream) error {
  1464. return srv.(SeaweedServer).SendHeartbeat(&seaweedSendHeartbeatServer{stream})
  1465. }
  1466. type Seaweed_SendHeartbeatServer interface {
  1467. Send(*HeartbeatResponse) error
  1468. Recv() (*Heartbeat, error)
  1469. grpc.ServerStream
  1470. }
  1471. type seaweedSendHeartbeatServer struct {
  1472. grpc.ServerStream
  1473. }
  1474. func (x *seaweedSendHeartbeatServer) Send(m *HeartbeatResponse) error {
  1475. return x.ServerStream.SendMsg(m)
  1476. }
  1477. func (x *seaweedSendHeartbeatServer) Recv() (*Heartbeat, error) {
  1478. m := new(Heartbeat)
  1479. if err := x.ServerStream.RecvMsg(m); err != nil {
  1480. return nil, err
  1481. }
  1482. return m, nil
  1483. }
  1484. func _Seaweed_KeepConnected_Handler(srv interface{}, stream grpc.ServerStream) error {
  1485. return srv.(SeaweedServer).KeepConnected(&seaweedKeepConnectedServer{stream})
  1486. }
  1487. type Seaweed_KeepConnectedServer interface {
  1488. Send(*VolumeLocation) error
  1489. Recv() (*KeepConnectedRequest, error)
  1490. grpc.ServerStream
  1491. }
  1492. type seaweedKeepConnectedServer struct {
  1493. grpc.ServerStream
  1494. }
  1495. func (x *seaweedKeepConnectedServer) Send(m *VolumeLocation) error {
  1496. return x.ServerStream.SendMsg(m)
  1497. }
  1498. func (x *seaweedKeepConnectedServer) Recv() (*KeepConnectedRequest, error) {
  1499. m := new(KeepConnectedRequest)
  1500. if err := x.ServerStream.RecvMsg(m); err != nil {
  1501. return nil, err
  1502. }
  1503. return m, nil
  1504. }
  1505. func _Seaweed_LookupVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1506. in := new(LookupVolumeRequest)
  1507. if err := dec(in); err != nil {
  1508. return nil, err
  1509. }
  1510. if interceptor == nil {
  1511. return srv.(SeaweedServer).LookupVolume(ctx, in)
  1512. }
  1513. info := &grpc.UnaryServerInfo{
  1514. Server: srv,
  1515. FullMethod: "/master_pb.Seaweed/LookupVolume",
  1516. }
  1517. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1518. return srv.(SeaweedServer).LookupVolume(ctx, req.(*LookupVolumeRequest))
  1519. }
  1520. return interceptor(ctx, in, info, handler)
  1521. }
  1522. func _Seaweed_Assign_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1523. in := new(AssignRequest)
  1524. if err := dec(in); err != nil {
  1525. return nil, err
  1526. }
  1527. if interceptor == nil {
  1528. return srv.(SeaweedServer).Assign(ctx, in)
  1529. }
  1530. info := &grpc.UnaryServerInfo{
  1531. Server: srv,
  1532. FullMethod: "/master_pb.Seaweed/Assign",
  1533. }
  1534. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1535. return srv.(SeaweedServer).Assign(ctx, req.(*AssignRequest))
  1536. }
  1537. return interceptor(ctx, in, info, handler)
  1538. }
  1539. func _Seaweed_Statistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1540. in := new(StatisticsRequest)
  1541. if err := dec(in); err != nil {
  1542. return nil, err
  1543. }
  1544. if interceptor == nil {
  1545. return srv.(SeaweedServer).Statistics(ctx, in)
  1546. }
  1547. info := &grpc.UnaryServerInfo{
  1548. Server: srv,
  1549. FullMethod: "/master_pb.Seaweed/Statistics",
  1550. }
  1551. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1552. return srv.(SeaweedServer).Statistics(ctx, req.(*StatisticsRequest))
  1553. }
  1554. return interceptor(ctx, in, info, handler)
  1555. }
  1556. func _Seaweed_CollectionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1557. in := new(CollectionListRequest)
  1558. if err := dec(in); err != nil {
  1559. return nil, err
  1560. }
  1561. if interceptor == nil {
  1562. return srv.(SeaweedServer).CollectionList(ctx, in)
  1563. }
  1564. info := &grpc.UnaryServerInfo{
  1565. Server: srv,
  1566. FullMethod: "/master_pb.Seaweed/CollectionList",
  1567. }
  1568. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1569. return srv.(SeaweedServer).CollectionList(ctx, req.(*CollectionListRequest))
  1570. }
  1571. return interceptor(ctx, in, info, handler)
  1572. }
  1573. func _Seaweed_CollectionDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1574. in := new(CollectionDeleteRequest)
  1575. if err := dec(in); err != nil {
  1576. return nil, err
  1577. }
  1578. if interceptor == nil {
  1579. return srv.(SeaweedServer).CollectionDelete(ctx, in)
  1580. }
  1581. info := &grpc.UnaryServerInfo{
  1582. Server: srv,
  1583. FullMethod: "/master_pb.Seaweed/CollectionDelete",
  1584. }
  1585. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1586. return srv.(SeaweedServer).CollectionDelete(ctx, req.(*CollectionDeleteRequest))
  1587. }
  1588. return interceptor(ctx, in, info, handler)
  1589. }
  1590. func _Seaweed_VolumeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1591. in := new(VolumeListRequest)
  1592. if err := dec(in); err != nil {
  1593. return nil, err
  1594. }
  1595. if interceptor == nil {
  1596. return srv.(SeaweedServer).VolumeList(ctx, in)
  1597. }
  1598. info := &grpc.UnaryServerInfo{
  1599. Server: srv,
  1600. FullMethod: "/master_pb.Seaweed/VolumeList",
  1601. }
  1602. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1603. return srv.(SeaweedServer).VolumeList(ctx, req.(*VolumeListRequest))
  1604. }
  1605. return interceptor(ctx, in, info, handler)
  1606. }
  1607. func _Seaweed_LookupEcVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1608. in := new(LookupEcVolumeRequest)
  1609. if err := dec(in); err != nil {
  1610. return nil, err
  1611. }
  1612. if interceptor == nil {
  1613. return srv.(SeaweedServer).LookupEcVolume(ctx, in)
  1614. }
  1615. info := &grpc.UnaryServerInfo{
  1616. Server: srv,
  1617. FullMethod: "/master_pb.Seaweed/LookupEcVolume",
  1618. }
  1619. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1620. return srv.(SeaweedServer).LookupEcVolume(ctx, req.(*LookupEcVolumeRequest))
  1621. }
  1622. return interceptor(ctx, in, info, handler)
  1623. }
  1624. func _Seaweed_GetMasterConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1625. in := new(GetMasterConfigurationRequest)
  1626. if err := dec(in); err != nil {
  1627. return nil, err
  1628. }
  1629. if interceptor == nil {
  1630. return srv.(SeaweedServer).GetMasterConfiguration(ctx, in)
  1631. }
  1632. info := &grpc.UnaryServerInfo{
  1633. Server: srv,
  1634. FullMethod: "/master_pb.Seaweed/GetMasterConfiguration",
  1635. }
  1636. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1637. return srv.(SeaweedServer).GetMasterConfiguration(ctx, req.(*GetMasterConfigurationRequest))
  1638. }
  1639. return interceptor(ctx, in, info, handler)
  1640. }
  1641. func _Seaweed_ListMasterClients_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1642. in := new(ListMasterClientsRequest)
  1643. if err := dec(in); err != nil {
  1644. return nil, err
  1645. }
  1646. if interceptor == nil {
  1647. return srv.(SeaweedServer).ListMasterClients(ctx, in)
  1648. }
  1649. info := &grpc.UnaryServerInfo{
  1650. Server: srv,
  1651. FullMethod: "/master_pb.Seaweed/ListMasterClients",
  1652. }
  1653. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1654. return srv.(SeaweedServer).ListMasterClients(ctx, req.(*ListMasterClientsRequest))
  1655. }
  1656. return interceptor(ctx, in, info, handler)
  1657. }
  1658. var _Seaweed_serviceDesc = grpc.ServiceDesc{
  1659. ServiceName: "master_pb.Seaweed",
  1660. HandlerType: (*SeaweedServer)(nil),
  1661. Methods: []grpc.MethodDesc{
  1662. {
  1663. MethodName: "LookupVolume",
  1664. Handler: _Seaweed_LookupVolume_Handler,
  1665. },
  1666. {
  1667. MethodName: "Assign",
  1668. Handler: _Seaweed_Assign_Handler,
  1669. },
  1670. {
  1671. MethodName: "Statistics",
  1672. Handler: _Seaweed_Statistics_Handler,
  1673. },
  1674. {
  1675. MethodName: "CollectionList",
  1676. Handler: _Seaweed_CollectionList_Handler,
  1677. },
  1678. {
  1679. MethodName: "CollectionDelete",
  1680. Handler: _Seaweed_CollectionDelete_Handler,
  1681. },
  1682. {
  1683. MethodName: "VolumeList",
  1684. Handler: _Seaweed_VolumeList_Handler,
  1685. },
  1686. {
  1687. MethodName: "LookupEcVolume",
  1688. Handler: _Seaweed_LookupEcVolume_Handler,
  1689. },
  1690. {
  1691. MethodName: "GetMasterConfiguration",
  1692. Handler: _Seaweed_GetMasterConfiguration_Handler,
  1693. },
  1694. {
  1695. MethodName: "ListMasterClients",
  1696. Handler: _Seaweed_ListMasterClients_Handler,
  1697. },
  1698. },
  1699. Streams: []grpc.StreamDesc{
  1700. {
  1701. StreamName: "SendHeartbeat",
  1702. Handler: _Seaweed_SendHeartbeat_Handler,
  1703. ServerStreams: true,
  1704. ClientStreams: true,
  1705. },
  1706. {
  1707. StreamName: "KeepConnected",
  1708. Handler: _Seaweed_KeepConnected_Handler,
  1709. ServerStreams: true,
  1710. ClientStreams: true,
  1711. },
  1712. },
  1713. Metadata: "master.proto",
  1714. }
  1715. func init() { proto.RegisterFile("master.proto", fileDescriptor0) }
  1716. var fileDescriptor0 = []byte{
  1717. // 2183 bytes of a gzipped FileDescriptorProto
  1718. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xd4, 0x59, 0xcd, 0x6f, 0x1b, 0xc7,
  1719. 0x15, 0xf7, 0x92, 0x94, 0x48, 0x3e, 0x7e, 0x8f, 0x64, 0x85, 0x66, 0x62, 0x8b, 0xde, 0xa4, 0x88,
  1720. 0xec, 0xa6, 0x6a, 0xaa, 0x04, 0x68, 0xd0, 0x34, 0x08, 0x2c, 0x59, 0x71, 0x05, 0x5b, 0x8a, 0xbd,
  1721. 0x72, 0x1d, 0xa0, 0x40, 0xb1, 0x19, 0xee, 0x8e, 0xa4, 0x85, 0xf6, 0xab, 0xbb, 0x43, 0x59, 0x4c,
  1722. 0x2f, 0x05, 0x7a, 0xec, 0xa9, 0xe8, 0xa1, 0xff, 0x42, 0x2f, 0x3d, 0xb5, 0x97, 0x5e, 0x72, 0xe9,
  1723. 0x7f, 0xd4, 0x6b, 0x2e, 0xc5, 0x7c, 0xed, 0xce, 0x2e, 0x49, 0x29, 0x0a, 0x90, 0x83, 0x6f, 0xbb,
  1724. 0xef, 0xbd, 0x79, 0xf3, 0xf6, 0xf7, 0xe6, 0xbd, 0xf9, 0x3d, 0x12, 0xda, 0x01, 0x4e, 0x29, 0x49,
  1725. 0xb6, 0xe3, 0x24, 0xa2, 0x11, 0x6a, 0x8a, 0x37, 0x3b, 0x9e, 0x98, 0x7f, 0x59, 0x85, 0xe6, 0x6f,
  1726. 0x08, 0x4e, 0xe8, 0x84, 0x60, 0x8a, 0xba, 0x50, 0xf1, 0xe2, 0xa1, 0x31, 0x36, 0xb6, 0x9a, 0x56,
  1727. 0xc5, 0x8b, 0x11, 0x82, 0x5a, 0x1c, 0x25, 0x74, 0x58, 0x19, 0x1b, 0x5b, 0x1d, 0x8b, 0x3f, 0xa3,
  1728. 0xbb, 0x00, 0xf1, 0x74, 0xe2, 0x7b, 0x8e, 0x3d, 0x4d, 0xfc, 0x61, 0x95, 0xdb, 0x36, 0x85, 0xe4,
  1729. 0xb7, 0x89, 0x8f, 0xb6, 0xa0, 0x1f, 0xe0, 0x4b, 0xfb, 0x22, 0xf2, 0xa7, 0x01, 0xb1, 0x9d, 0x68,
  1730. 0x1a, 0xd2, 0x61, 0x8d, 0x2f, 0xef, 0x06, 0xf8, 0xf2, 0x15, 0x17, 0xef, 0x31, 0x29, 0x1a, 0xb3,
  1731. 0xa8, 0x2e, 0xed, 0x13, 0xcf, 0x27, 0xf6, 0x39, 0x99, 0x0d, 0x57, 0xc6, 0xc6, 0x56, 0xcd, 0x82,
  1732. 0x00, 0x5f, 0x7e, 0xe1, 0xf9, 0xe4, 0x29, 0x99, 0xa1, 0x4d, 0x68, 0xb9, 0x98, 0x62, 0xdb, 0x21,
  1733. 0x21, 0x25, 0xc9, 0x70, 0x95, 0xef, 0x05, 0x4c, 0xb4, 0xc7, 0x25, 0x2c, 0xbe, 0x04, 0x3b, 0xe7,
  1734. 0xc3, 0x3a, 0xd7, 0xf0, 0x67, 0x16, 0x1f, 0x76, 0x03, 0x2f, 0xb4, 0x79, 0xe4, 0x0d, 0xbe, 0x75,
  1735. 0x93, 0x4b, 0x9e, 0xb3, 0xf0, 0x3f, 0x83, 0xba, 0x88, 0x2d, 0x1d, 0x36, 0xc7, 0xd5, 0xad, 0xd6,
  1736. 0xce, 0xbb, 0xdb, 0x19, 0x1a, 0xdb, 0x22, 0xbc, 0x83, 0xf0, 0x24, 0x4a, 0x02, 0x4c, 0xbd, 0x28,
  1737. 0x3c, 0x24, 0x69, 0x8a, 0x4f, 0x89, 0xa5, 0xd6, 0xa0, 0x03, 0x68, 0x85, 0xe4, 0xb5, 0xad, 0x5c,
  1738. 0x00, 0x77, 0xb1, 0x35, 0xe7, 0xe2, 0xf8, 0x2c, 0x4a, 0xe8, 0x02, 0x3f, 0x10, 0x92, 0xd7, 0xaf,
  1739. 0xa4, 0xab, 0x17, 0xd0, 0x73, 0x89, 0x4f, 0x28, 0x71, 0x33, 0x77, 0xad, 0x1b, 0xba, 0xeb, 0x4a,
  1740. 0x07, 0xca, 0xe5, 0x7b, 0xd0, 0x3d, 0xc3, 0xa9, 0x1d, 0x46, 0x99, 0xc7, 0xf6, 0xd8, 0xd8, 0x6a,
  1741. 0x58, 0xed, 0x33, 0x9c, 0x1e, 0x45, 0xca, 0xea, 0x09, 0x34, 0x89, 0x63, 0xa7, 0x67, 0x38, 0x71,
  1742. 0xd3, 0x61, 0x9f, 0x6f, 0xf9, 0x70, 0x6e, 0xcb, 0x7d, 0xe7, 0x98, 0x19, 0x2c, 0xd8, 0xb4, 0x41,
  1743. 0x84, 0x2a, 0x45, 0x47, 0xd0, 0x61, 0x60, 0xe4, 0xce, 0x06, 0x37, 0x76, 0xc6, 0xd0, 0xdc, 0x57,
  1744. 0xfe, 0x5e, 0xc1, 0x40, 0x21, 0x92, 0xfb, 0x44, 0x37, 0xf6, 0xa9, 0x60, 0xcd, 0xfc, 0xbe, 0x0f,
  1745. 0x7d, 0x09, 0x4b, 0xee, 0x76, 0x8d, 0x03, 0xd3, 0xe1, 0xc0, 0x28, 0x43, 0xf3, 0x4f, 0x15, 0x18,
  1746. 0x64, 0xd5, 0x60, 0x91, 0x34, 0x8e, 0xc2, 0x94, 0xa0, 0x87, 0x30, 0x90, 0xc7, 0x39, 0xf5, 0xbe,
  1747. 0x21, 0xb6, 0xef, 0x05, 0x1e, 0xe5, 0x45, 0x52, 0xb3, 0x7a, 0x42, 0x71, 0xec, 0x7d, 0x43, 0x9e,
  1748. 0x31, 0x31, 0xda, 0x80, 0x55, 0x9f, 0x60, 0x97, 0x24, 0xbc, 0x66, 0x9a, 0x96, 0x7c, 0x43, 0xef,
  1749. 0x43, 0x2f, 0x20, 0x34, 0xf1, 0x9c, 0xd4, 0xc6, 0xae, 0x9b, 0x90, 0x34, 0x95, 0xa5, 0xd3, 0x95,
  1750. 0xe2, 0x47, 0x42, 0x8a, 0x3e, 0x81, 0xa1, 0x32, 0xf4, 0xd8, 0x19, 0xbf, 0xc0, 0xbe, 0x9d, 0x12,
  1751. 0x27, 0x0a, 0xdd, 0x54, 0xd6, 0xd1, 0x86, 0xd4, 0x1f, 0x48, 0xf5, 0xb1, 0xd0, 0xa2, 0xc7, 0xd0,
  1752. 0x4f, 0x69, 0x94, 0xe0, 0x53, 0x62, 0x4f, 0xb0, 0x73, 0x4e, 0xd8, 0x8a, 0x15, 0x0e, 0xde, 0x1d,
  1753. 0x0d, 0xbc, 0x63, 0x61, 0xb2, 0x2b, 0x2c, 0xac, 0x5e, 0x5a, 0x78, 0x4f, 0xcd, 0xef, 0xaa, 0x30,
  1754. 0x5c, 0x56, 0x06, 0xbc, 0x3f, 0xb8, 0xfc, 0xd3, 0x3b, 0x56, 0xc5, 0x73, 0x59, 0xfd, 0x31, 0x48,
  1755. 0xf8, 0xb7, 0xd6, 0x2c, 0xfe, 0x8c, 0xee, 0x01, 0x38, 0x91, 0xef, 0x13, 0x87, 0x2d, 0x94, 0x1f,
  1756. 0xa9, 0x49, 0x58, 0x7d, 0xf2, 0x92, 0xcf, 0x5b, 0x43, 0xcd, 0x6a, 0x32, 0x89, 0xe8, 0x0a, 0xf7,
  1757. 0xa1, 0x2d, 0xd2, 0x27, 0x0d, 0x44, 0x57, 0x68, 0x09, 0x99, 0x30, 0xf9, 0x00, 0x90, 0x3a, 0x26,
  1758. 0x93, 0x59, 0x66, 0xb8, 0xca, 0x0d, 0xfb, 0x52, 0xb3, 0x3b, 0x53, 0xd6, 0x6f, 0x43, 0x33, 0x21,
  1759. 0xd8, 0xb5, 0xa3, 0xd0, 0x9f, 0xf1, 0x46, 0xd1, 0xb0, 0x1a, 0x4c, 0xf0, 0x65, 0xe8, 0xcf, 0xd0,
  1760. 0x4f, 0x61, 0x90, 0x90, 0xd8, 0xf7, 0x1c, 0x6c, 0xc7, 0x3e, 0x76, 0x48, 0x40, 0x42, 0xd5, 0x33,
  1761. 0xfa, 0x52, 0xf1, 0x5c, 0xc9, 0xd1, 0x10, 0xea, 0x17, 0x24, 0x49, 0xd9, 0x67, 0x35, 0xb9, 0x89,
  1762. 0x7a, 0x45, 0x7d, 0xa8, 0x52, 0xea, 0x0f, 0x81, 0x4b, 0xd9, 0x23, 0x7a, 0x00, 0x7d, 0x27, 0x0a,
  1763. 0x62, 0xec, 0x50, 0x3b, 0x21, 0x17, 0x1e, 0x5f, 0xd4, 0xe2, 0xea, 0x9e, 0x94, 0x5b, 0x52, 0xcc,
  1764. 0x3e, 0x27, 0x88, 0x5c, 0xef, 0xc4, 0x23, 0xae, 0x8d, 0xa9, 0x4c, 0x36, 0x2f, 0xdc, 0xaa, 0xd5,
  1765. 0x57, 0x9a, 0x47, 0x54, 0xa4, 0x19, 0x6d, 0xc3, 0x5a, 0x42, 0x82, 0x88, 0x12, 0x5b, 0x25, 0x3b,
  1766. 0xc4, 0x01, 0x19, 0x76, 0x38, 0xce, 0x03, 0xa1, 0x92, 0x39, 0x3e, 0xc2, 0x01, 0x61, 0xde, 0x4b,
  1767. 0xf6, 0xac, 0xd7, 0x76, 0xb9, 0x79, 0xbf, 0x60, 0xfe, 0x94, 0xcc, 0xcc, 0x7f, 0x18, 0x70, 0xf7,
  1768. 0xca, 0x96, 0x33, 0x77, 0x04, 0xae, 0x4b, 0xf7, 0x8f, 0x85, 0xb0, 0x39, 0x85, 0xcd, 0x6b, 0x1a,
  1769. 0xc1, 0x35, 0xb1, 0x56, 0xe6, 0x62, 0x35, 0xa1, 0x43, 0x1c, 0xdb, 0x0b, 0x5d, 0x72, 0x69, 0x4f,
  1770. 0x3c, 0x2a, 0x4a, 0xb4, 0x63, 0xb5, 0x88, 0x73, 0xc0, 0x64, 0xbb, 0x1e, 0x4d, 0xcd, 0x6f, 0x0d,
  1771. 0xe8, 0x16, 0x6b, 0x88, 0x55, 0x01, 0x9d, 0xc5, 0x44, 0xde, 0x9b, 0xfc, 0x59, 0x6e, 0x5d, 0x91,
  1772. 0x37, 0xa9, 0x8b, 0x0e, 0x00, 0xe2, 0x24, 0x8a, 0x49, 0x42, 0x3d, 0xc2, 0xfc, 0xb2, 0xb2, 0x7c,
  1773. 0xb0, 0xb4, 0x2c, 0xb7, 0x9f, 0x67, 0xb6, 0xfb, 0x21, 0x4d, 0x66, 0x96, 0xb6, 0x78, 0xf4, 0x19,
  1774. 0xf4, 0x4a, 0x6a, 0x86, 0x0e, 0xcb, 0xaa, 0x08, 0x80, 0x3d, 0xa2, 0x75, 0x58, 0xb9, 0xc0, 0xfe,
  1775. 0x94, 0xc8, 0x10, 0xc4, 0xcb, 0xaf, 0x2a, 0x9f, 0x18, 0x66, 0x1d, 0x56, 0xf6, 0x83, 0x98, 0xce,
  1776. 0xd8, 0x97, 0xf4, 0x8e, 0xa7, 0x31, 0x49, 0x76, 0xfd, 0xc8, 0x39, 0xdf, 0xbf, 0xa4, 0x09, 0x46,
  1777. 0x5f, 0x42, 0x97, 0x24, 0x38, 0x9d, 0x26, 0xac, 0xaa, 0x5c, 0x2f, 0x3c, 0xe5, 0x3e, 0x8b, 0x57,
  1778. 0x52, 0x69, 0xcd, 0xf6, 0xbe, 0x58, 0xb0, 0xc7, 0xed, 0xad, 0x0e, 0xd1, 0x5f, 0x47, 0xbf, 0x83,
  1779. 0x4e, 0x41, 0xcf, 0xc0, 0x62, 0x17, 0xb8, 0xcc, 0x0a, 0x7f, 0x66, 0x4d, 0x33, 0xc6, 0x89, 0x47,
  1780. 0x67, 0x92, 0x68, 0xc8, 0x37, 0xd6, 0x2a, 0x64, 0xe3, 0xf5, 0x5c, 0x01, 0x5a, 0xc7, 0x6a, 0x0a,
  1781. 0xc9, 0x81, 0x9b, 0x9a, 0x4f, 0x60, 0xfd, 0x29, 0x21, 0xf1, 0x5e, 0x14, 0x86, 0xc4, 0xa1, 0xc4,
  1782. 0xb5, 0xc8, 0x1f, 0xa6, 0x24, 0xa5, 0x6c, 0x0b, 0x5e, 0x13, 0x32, 0x1f, 0xec, 0x99, 0x75, 0x81,
  1783. 0xd3, 0x24, 0x76, 0x6c, 0x8d, 0xce, 0x34, 0x98, 0x80, 0x71, 0x02, 0xf3, 0xef, 0x06, 0x74, 0xc5,
  1784. 0x59, 0x7a, 0x16, 0x39, 0xfc, 0x04, 0x31, 0x44, 0x19, 0xbd, 0x91, 0x88, 0x4e, 0x13, 0xbf, 0xc4,
  1785. 0x7b, 0x2a, 0x65, 0xde, 0x73, 0x07, 0x1a, 0x9c, 0x18, 0xe4, 0x91, 0xd6, 0xd9, 0x5d, 0xef, 0xb9,
  1786. 0x69, 0xde, 0xd2, 0x5c, 0xa1, 0xae, 0x71, 0x75, 0x4b, 0xdd, 0xdd, 0xcc, 0x24, 0xbf, 0x36, 0x56,
  1787. 0xf4, 0x6b, 0xc3, 0x7c, 0x09, 0x6b, 0xcf, 0xa2, 0xe8, 0x7c, 0x1a, 0x8b, 0xf0, 0xd4, 0x17, 0x16,
  1788. 0x81, 0x31, 0xc6, 0x55, 0x16, 0x4b, 0x06, 0xcc, 0x75, 0xe7, 0xdc, 0xfc, 0x9f, 0x01, 0xeb, 0x45,
  1789. 0xb7, 0xf2, 0xa6, 0xfb, 0x1a, 0xd6, 0x32, 0xbf, 0xb6, 0x2f, 0xb1, 0x10, 0x1b, 0xb4, 0x76, 0x3e,
  1790. 0xd4, 0xce, 0xc0, 0xa2, 0xd5, 0x8a, 0x3d, 0xb9, 0x0a, 0x44, 0x6b, 0x70, 0x51, 0x92, 0xa4, 0xa3,
  1791. 0x4b, 0xe8, 0x97, 0xcd, 0x58, 0x6e, 0xb2, 0x5d, 0x25, 0xe2, 0x0d, 0xb5, 0x12, 0xfd, 0x02, 0x9a,
  1792. 0x79, 0x20, 0x15, 0x1e, 0xc8, 0x5a, 0x21, 0x10, 0xb9, 0x57, 0x6e, 0xc5, 0xce, 0x3e, 0x49, 0x92,
  1793. 0x28, 0x91, 0xdd, 0x48, 0xbc, 0x98, 0x9f, 0x42, 0xe3, 0x07, 0x67, 0xd7, 0xfc, 0x57, 0x05, 0x3a,
  1794. 0x8f, 0xd2, 0xd4, 0x3b, 0x0d, 0x55, 0x0a, 0xd6, 0x61, 0x45, 0xdc, 0x3b, 0x82, 0x08, 0x88, 0x17,
  1795. 0x34, 0x86, 0x96, 0x6c, 0x6a, 0x1a, 0xf4, 0xba, 0xe8, 0xda, 0x7e, 0x29, 0x1b, 0x5d, 0x4d, 0x84,
  1796. 0xc6, 0xae, 0x92, 0x12, 0x0b, 0x5e, 0x59, 0xca, 0x82, 0x57, 0x35, 0x16, 0xfc, 0x36, 0x34, 0xf9,
  1797. 0xa2, 0x30, 0x72, 0x89, 0xa4, 0xc7, 0x0d, 0x26, 0x38, 0x8a, 0x5c, 0x82, 0x76, 0x60, 0x23, 0x20,
  1798. 0x41, 0x94, 0xcc, 0xec, 0x00, 0xc7, 0x36, 0x23, 0xe1, 0x9c, 0xd8, 0x04, 0x13, 0xd9, 0x98, 0x91,
  1799. 0xd0, 0x1e, 0xe2, 0xf8, 0x10, 0x5f, 0x32, 0x6e, 0x73, 0x38, 0x41, 0x3b, 0x70, 0xfb, 0xab, 0xc4,
  1800. 0xa3, 0x78, 0xe2, 0x93, 0x22, 0xb9, 0x17, 0x8d, 0x7a, 0x4d, 0x29, 0x35, 0x86, 0x6f, 0xfe, 0xcd,
  1801. 0x80, 0xae, 0x42, 0x4d, 0x9e, 0xb0, 0x3e, 0x54, 0x4f, 0xb2, 0x2c, 0xb3, 0x47, 0x95, 0x8b, 0xca,
  1802. 0xb2, 0x5c, 0xcc, 0x4d, 0x18, 0x19, 0xf2, 0x35, 0x1d, 0xf9, 0x2c, 0xe9, 0x2b, 0x5a, 0xd2, 0x19,
  1803. 0x34, 0x78, 0x4a, 0xcf, 0x14, 0x34, 0xec, 0xd9, 0x3c, 0x85, 0xc1, 0x31, 0xc5, 0xd4, 0x4b, 0xa9,
  1804. 0xe7, 0xa4, 0x2a, 0x9d, 0xa5, 0xc4, 0x19, 0xd7, 0x25, 0xae, 0xb2, 0x2c, 0x71, 0xd5, 0x2c, 0x71,
  1805. 0xe6, 0x7f, 0x0d, 0x40, 0xfa, 0x4e, 0x12, 0x82, 0x1f, 0x61, 0x2b, 0x06, 0x19, 0x8d, 0x28, 0xa3,
  1806. 0x8a, 0x8c, 0x8e, 0x49, 0x52, 0xc5, 0x25, 0x2c, 0x7d, 0xec, 0x34, 0x4c, 0x53, 0xe2, 0x0a, 0xad,
  1807. 0x60, 0x54, 0x0d, 0x26, 0xe0, 0xca, 0x22, 0x21, 0x5b, 0x2d, 0x11, 0x32, 0xf3, 0x11, 0xb4, 0xe4,
  1808. 0xe5, 0xf4, 0x92, 0x5d, 0x6c, 0xd7, 0x47, 0x2f, 0xa3, 0xab, 0xe4, 0x40, 0x8c, 0x01, 0xf6, 0xf2,
  1809. 0xe8, 0x17, 0xb4, 0x67, 0xf3, 0x8f, 0x70, 0x3b, 0xb7, 0x78, 0xe6, 0xa5, 0x54, 0xe5, 0xe5, 0x63,
  1810. 0xd8, 0xf0, 0x42, 0xc7, 0x9f, 0xba, 0xc4, 0x0e, 0xd9, 0xf5, 0xee, 0x67, 0x93, 0x8d, 0xc1, 0xa9,
  1811. 0xdc, 0xba, 0xd4, 0x1e, 0x71, 0xa5, 0x9a, 0x70, 0x3e, 0x00, 0xa4, 0x56, 0x11, 0x27, 0x5b, 0x51,
  1812. 0xe1, 0x2b, 0xfa, 0x52, 0xb3, 0xef, 0x48, 0x6b, 0xf3, 0x05, 0x6c, 0x94, 0x37, 0x97, 0xa9, 0xfa,
  1813. 0x25, 0xb4, 0x72, 0xd8, 0x55, 0x1f, 0xbc, 0xad, 0xb5, 0x9f, 0x7c, 0x9d, 0xa5, 0x5b, 0x9a, 0x3f,
  1814. 0x83, 0xb7, 0x72, 0xd5, 0x63, 0xde, 0xe8, 0xaf, 0xb8, 0x9d, 0xcc, 0x11, 0x0c, 0xe7, 0xcd, 0x45,
  1815. 0x0c, 0xe6, 0x5f, 0xab, 0xd0, 0x7e, 0x2c, 0x2b, 0x97, 0x71, 0x1c, 0x8d, 0xd5, 0x08, 0x6a, 0x71,
  1816. 0x1f, 0xda, 0x85, 0x82, 0x14, 0x64, 0xbc, 0x75, 0xa1, 0x8d, 0xda, 0x8b, 0x86, 0xf2, 0x2a, 0x37,
  1817. 0x2b, 0x0f, 0xe5, 0x0f, 0x61, 0x70, 0x92, 0x10, 0x32, 0x3f, 0xbf, 0xd7, 0xac, 0x1e, 0x53, 0xe8,
  1818. 0xb6, 0xdb, 0xb0, 0x86, 0x1d, 0xea, 0x5d, 0x94, 0xac, 0xc5, 0xf9, 0x1a, 0x08, 0x95, 0x6e, 0xff,
  1819. 0x45, 0x16, 0xa8, 0x17, 0x9e, 0x44, 0xe9, 0x70, 0xf5, 0xfb, 0xcf, 0xdf, 0xf2, 0x6b, 0x98, 0x26,
  1820. 0x45, 0xcf, 0xa1, 0xab, 0xe6, 0x38, 0xe9, 0xa9, 0x7e, 0xe3, 0x19, 0xb1, 0x4d, 0x72, 0x55, 0xaa,
  1821. 0x91, 0xea, 0xc2, 0x97, 0x34, 0xc4, 0x97, 0x08, 0x95, 0xde, 0xd8, 0xfe, 0x5d, 0x81, 0x86, 0x85,
  1822. 0x9d, 0xf3, 0x37, 0x3b, 0x1f, 0x9f, 0x43, 0x2f, 0xbb, 0x23, 0x0a, 0x29, 0x79, 0x4b, 0x03, 0x52,
  1823. 0x3f, 0x7a, 0x56, 0xc7, 0xd5, 0xde, 0x96, 0xc2, 0x56, 0x5f, 0x06, 0xdb, 0x3f, 0x2b, 0xd0, 0x7d,
  1824. 0x9c, 0xdd, 0x5b, 0x6f, 0x36, 0x78, 0x3b, 0x00, 0xec, 0xa2, 0x2d, 0xe0, 0xa6, 0x13, 0x13, 0x75,
  1825. 0x3c, 0xac, 0x66, 0x22, 0x9f, 0x6e, 0x8e, 0xd7, 0xb7, 0x15, 0x68, 0xbf, 0x8c, 0xe2, 0xc8, 0x8f,
  1826. 0x4e, 0x67, 0x6f, 0x36, 0x5a, 0xfb, 0x30, 0xd0, 0x38, 0x4c, 0x01, 0xb4, 0x3b, 0xa5, 0xc3, 0x96,
  1827. 0x1f, 0x0e, 0xab, 0xe7, 0x16, 0xde, 0x6f, 0x0e, 0xe0, 0x1a, 0x0c, 0x24, 0xaf, 0xcf, 0xaf, 0x14,
  1828. 0xf3, 0xcf, 0x06, 0x20, 0x5d, 0x2a, 0x7b, 0xfd, 0xaf, 0xa1, 0x43, 0x25, 0xd6, 0x3c, 0x3e, 0x39,
  1829. 0xf9, 0xe8, 0xb5, 0xa0, 0xe7, 0xc2, 0x6a, 0x53, 0x3d, 0x33, 0x3f, 0x87, 0xf5, 0xb9, 0xdf, 0x88,
  1830. 0x18, 0xa1, 0x12, 0x19, 0x19, 0x94, 0x7e, 0x26, 0x3a, 0x9c, 0x98, 0x1f, 0xc3, 0x6d, 0x41, 0xa2,
  1831. 0xd5, 0x3d, 0xa4, 0xee, 0x87, 0x39, 0x36, 0xdc, 0xc9, 0xd9, 0xb0, 0xf9, 0x9d, 0x01, 0x1b, 0xe5,
  1832. 0x65, 0x32, 0xfe, 0xab, 0xd6, 0x21, 0x0c, 0x48, 0xf6, 0x4b, 0x9d, 0xd7, 0x0b, 0x3a, 0xfd, 0xd1,
  1833. 0x1c, 0xaf, 0x2f, 0xfb, 0xde, 0x56, 0x7d, 0x34, 0xa7, 0xf6, 0xfd, 0xb4, 0x28, 0x48, 0x47, 0x18,
  1834. 0x06, 0x73, 0x66, 0x6c, 0x2a, 0x52, 0xfb, 0xca, 0x98, 0xea, 0x72, 0xe1, 0x0f, 0x20, 0xf6, 0xe6,
  1835. 0x26, 0xdc, 0x7d, 0x42, 0xe8, 0x21, 0xb7, 0xd9, 0x8b, 0xc2, 0x13, 0xef, 0x74, 0x9a, 0x08, 0xa3,
  1836. 0x3c, 0xb5, 0xf7, 0x96, 0x59, 0x48, 0x98, 0x16, 0xfc, 0x10, 0x67, 0xdc, 0xf8, 0x87, 0xb8, 0xca,
  1837. 0x55, 0x3f, 0xc4, 0x99, 0x9f, 0xc2, 0x90, 0x9d, 0x2c, 0x19, 0x85, 0xef, 0x91, 0x90, 0x66, 0x3c,
  1838. 0x73, 0x13, 0x5a, 0x0e, 0x97, 0xd8, 0xda, 0x4f, 0x06, 0x20, 0x44, 0x8c, 0x5f, 0x99, 0xbb, 0x70,
  1839. 0x67, 0xc1, 0x62, 0x19, 0xfc, 0x4f, 0xa0, 0xcb, 0xa7, 0x58, 0x19, 0x39, 0x51, 0xb3, 0x5f, 0x87,
  1840. 0x49, 0x1f, 0x29, 0xe1, 0xce, 0x7f, 0xea, 0x50, 0x3f, 0x26, 0xf8, 0x35, 0x21, 0x2e, 0x3a, 0x80,
  1841. 0xce, 0x31, 0x09, 0xdd, 0xfc, 0x37, 0xfe, 0x75, 0x0d, 0xe4, 0x4c, 0x3a, 0x7a, 0x67, 0x91, 0x34,
  1842. 0xe3, 0x20, 0xb7, 0xb6, 0x8c, 0x0f, 0x0d, 0xf4, 0x02, 0x3a, 0x85, 0x79, 0x1b, 0x6d, 0x6a, 0x8b,
  1843. 0x16, 0x4d, 0xe2, 0xa3, 0x3b, 0x73, 0x37, 0xb2, 0x4a, 0x6b, 0xe6, 0xb2, 0xad, 0x8f, 0x92, 0xe8,
  1844. 0xde, 0xd2, 0x19, 0x53, 0x38, 0xdc, 0xbc, 0x66, 0x06, 0x35, 0x6f, 0xa1, 0xcf, 0x61, 0x55, 0xcc,
  1845. 0x1c, 0x68, 0xa8, 0x19, 0x17, 0x86, 0xb7, 0x42, 0x5c, 0xc5, 0x01, 0xc5, 0xbc, 0x85, 0x9e, 0x02,
  1846. 0xe4, 0xac, 0x1d, 0xbd, 0x53, 0xf8, 0x91, 0xa6, 0x34, 0x36, 0x8c, 0xee, 0x2e, 0xd1, 0x66, 0xce,
  1847. 0xbe, 0x82, 0x6e, 0x91, 0x5b, 0xa2, 0xf1, 0x42, 0xfa, 0xa8, 0x35, 0xa8, 0xd1, 0xfd, 0x2b, 0x2c,
  1848. 0x32, 0xc7, 0xbf, 0x87, 0x7e, 0x99, 0x32, 0x22, 0x73, 0xe1, 0xc2, 0x02, 0xfd, 0x1c, 0xbd, 0x7b,
  1849. 0xa5, 0x8d, 0x0e, 0x42, 0xde, 0x23, 0x0b, 0x20, 0xcc, 0x35, 0xd4, 0x02, 0x08, 0xf3, 0x8d, 0x55,
  1850. 0x80, 0x50, 0x6c, 0x2c, 0x05, 0x10, 0x16, 0xb6, 0xc1, 0x02, 0x08, 0x8b, 0xbb, 0x92, 0x79, 0x0b,
  1851. 0x45, 0xb0, 0xb1, 0xb8, 0xdc, 0x91, 0xfe, 0x83, 0xd5, 0x95, 0x3d, 0x63, 0xf4, 0xe0, 0x7b, 0x58,
  1852. 0x66, 0x1b, 0x7e, 0x0d, 0x83, 0xb9, 0xea, 0x44, 0x3a, 0xa4, 0xcb, 0x0a, 0x7f, 0xf4, 0xde, 0xd5,
  1853. 0x46, 0x6a, 0x87, 0xc9, 0x2a, 0xff, 0x8b, 0xee, 0xa3, 0xff, 0x07, 0x00, 0x00, 0xff, 0xff, 0x6a,
  1854. 0xee, 0xfc, 0x90, 0xb2, 0x1b, 0x00, 0x00,
  1855. }