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.

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