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.

1591 lines
55 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. Empty
  14. SuperBlockExtra
  15. ClientListenRequest
  16. VolumeLocation
  17. LookupVolumeRequest
  18. LookupVolumeResponse
  19. Location
  20. AssignRequest
  21. AssignResponse
  22. StatisticsRequest
  23. StatisticsResponse
  24. StorageType
  25. Collection
  26. CollectionListRequest
  27. CollectionListResponse
  28. CollectionDeleteRequest
  29. CollectionDeleteResponse
  30. DataNodeInfo
  31. RackInfo
  32. DataCenterInfo
  33. TopologyInfo
  34. VolumeListRequest
  35. VolumeListResponse
  36. */
  37. package master_pb
  38. import proto "github.com/golang/protobuf/proto"
  39. import fmt "fmt"
  40. import math "math"
  41. import (
  42. context "golang.org/x/net/context"
  43. grpc "google.golang.org/grpc"
  44. )
  45. // Reference imports to suppress errors if they are not otherwise used.
  46. var _ = proto.Marshal
  47. var _ = fmt.Errorf
  48. var _ = math.Inf
  49. // This is a compile-time assertion to ensure that this generated file
  50. // is compatible with the proto package it is being compiled against.
  51. // A compilation error at this line likely means your copy of the
  52. // proto package needs to be updated.
  53. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  54. type Heartbeat struct {
  55. Ip string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
  56. Port uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
  57. PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  58. MaxVolumeCount uint32 `protobuf:"varint,4,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  59. MaxFileKey uint64 `protobuf:"varint,5,opt,name=max_file_key,json=maxFileKey" json:"max_file_key,omitempty"`
  60. DataCenter string `protobuf:"bytes,6,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
  61. Rack string `protobuf:"bytes,7,opt,name=rack" json:"rack,omitempty"`
  62. AdminPort uint32 `protobuf:"varint,8,opt,name=admin_port,json=adminPort" json:"admin_port,omitempty"`
  63. Volumes []*VolumeInformationMessage `protobuf:"bytes,9,rep,name=volumes" json:"volumes,omitempty"`
  64. // delta volumes
  65. NewVolumes []*VolumeShortInformationMessage `protobuf:"bytes,10,rep,name=new_volumes,json=newVolumes" json:"new_volumes,omitempty"`
  66. DeletedVolumes []*VolumeShortInformationMessage `protobuf:"bytes,11,rep,name=deleted_volumes,json=deletedVolumes" json:"deleted_volumes,omitempty"`
  67. }
  68. func (m *Heartbeat) Reset() { *m = Heartbeat{} }
  69. func (m *Heartbeat) String() string { return proto.CompactTextString(m) }
  70. func (*Heartbeat) ProtoMessage() {}
  71. func (*Heartbeat) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
  72. func (m *Heartbeat) GetIp() string {
  73. if m != nil {
  74. return m.Ip
  75. }
  76. return ""
  77. }
  78. func (m *Heartbeat) GetPort() uint32 {
  79. if m != nil {
  80. return m.Port
  81. }
  82. return 0
  83. }
  84. func (m *Heartbeat) GetPublicUrl() string {
  85. if m != nil {
  86. return m.PublicUrl
  87. }
  88. return ""
  89. }
  90. func (m *Heartbeat) GetMaxVolumeCount() uint32 {
  91. if m != nil {
  92. return m.MaxVolumeCount
  93. }
  94. return 0
  95. }
  96. func (m *Heartbeat) GetMaxFileKey() uint64 {
  97. if m != nil {
  98. return m.MaxFileKey
  99. }
  100. return 0
  101. }
  102. func (m *Heartbeat) GetDataCenter() string {
  103. if m != nil {
  104. return m.DataCenter
  105. }
  106. return ""
  107. }
  108. func (m *Heartbeat) GetRack() string {
  109. if m != nil {
  110. return m.Rack
  111. }
  112. return ""
  113. }
  114. func (m *Heartbeat) GetAdminPort() uint32 {
  115. if m != nil {
  116. return m.AdminPort
  117. }
  118. return 0
  119. }
  120. func (m *Heartbeat) GetVolumes() []*VolumeInformationMessage {
  121. if m != nil {
  122. return m.Volumes
  123. }
  124. return nil
  125. }
  126. func (m *Heartbeat) GetNewVolumes() []*VolumeShortInformationMessage {
  127. if m != nil {
  128. return m.NewVolumes
  129. }
  130. return nil
  131. }
  132. func (m *Heartbeat) GetDeletedVolumes() []*VolumeShortInformationMessage {
  133. if m != nil {
  134. return m.DeletedVolumes
  135. }
  136. return nil
  137. }
  138. type HeartbeatResponse struct {
  139. VolumeSizeLimit uint64 `protobuf:"varint,1,opt,name=volumeSizeLimit" json:"volumeSizeLimit,omitempty"`
  140. Leader string `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
  141. }
  142. func (m *HeartbeatResponse) Reset() { *m = HeartbeatResponse{} }
  143. func (m *HeartbeatResponse) String() string { return proto.CompactTextString(m) }
  144. func (*HeartbeatResponse) ProtoMessage() {}
  145. func (*HeartbeatResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
  146. func (m *HeartbeatResponse) GetVolumeSizeLimit() uint64 {
  147. if m != nil {
  148. return m.VolumeSizeLimit
  149. }
  150. return 0
  151. }
  152. func (m *HeartbeatResponse) GetLeader() string {
  153. if m != nil {
  154. return m.Leader
  155. }
  156. return ""
  157. }
  158. type VolumeInformationMessage struct {
  159. Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
  160. Size uint64 `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
  161. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  162. FileCount uint64 `protobuf:"varint,4,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  163. DeleteCount uint64 `protobuf:"varint,5,opt,name=delete_count,json=deleteCount" json:"delete_count,omitempty"`
  164. DeletedByteCount uint64 `protobuf:"varint,6,opt,name=deleted_byte_count,json=deletedByteCount" json:"deleted_byte_count,omitempty"`
  165. ReadOnly bool `protobuf:"varint,7,opt,name=read_only,json=readOnly" json:"read_only,omitempty"`
  166. ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
  167. Version uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
  168. Ttl uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
  169. CompactRevision uint32 `protobuf:"varint,11,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
  170. }
  171. func (m *VolumeInformationMessage) Reset() { *m = VolumeInformationMessage{} }
  172. func (m *VolumeInformationMessage) String() string { return proto.CompactTextString(m) }
  173. func (*VolumeInformationMessage) ProtoMessage() {}
  174. func (*VolumeInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
  175. func (m *VolumeInformationMessage) GetId() uint32 {
  176. if m != nil {
  177. return m.Id
  178. }
  179. return 0
  180. }
  181. func (m *VolumeInformationMessage) GetSize() uint64 {
  182. if m != nil {
  183. return m.Size
  184. }
  185. return 0
  186. }
  187. func (m *VolumeInformationMessage) GetCollection() string {
  188. if m != nil {
  189. return m.Collection
  190. }
  191. return ""
  192. }
  193. func (m *VolumeInformationMessage) GetFileCount() uint64 {
  194. if m != nil {
  195. return m.FileCount
  196. }
  197. return 0
  198. }
  199. func (m *VolumeInformationMessage) GetDeleteCount() uint64 {
  200. if m != nil {
  201. return m.DeleteCount
  202. }
  203. return 0
  204. }
  205. func (m *VolumeInformationMessage) GetDeletedByteCount() uint64 {
  206. if m != nil {
  207. return m.DeletedByteCount
  208. }
  209. return 0
  210. }
  211. func (m *VolumeInformationMessage) GetReadOnly() bool {
  212. if m != nil {
  213. return m.ReadOnly
  214. }
  215. return false
  216. }
  217. func (m *VolumeInformationMessage) GetReplicaPlacement() uint32 {
  218. if m != nil {
  219. return m.ReplicaPlacement
  220. }
  221. return 0
  222. }
  223. func (m *VolumeInformationMessage) GetVersion() uint32 {
  224. if m != nil {
  225. return m.Version
  226. }
  227. return 0
  228. }
  229. func (m *VolumeInformationMessage) GetTtl() uint32 {
  230. if m != nil {
  231. return m.Ttl
  232. }
  233. return 0
  234. }
  235. func (m *VolumeInformationMessage) GetCompactRevision() uint32 {
  236. if m != nil {
  237. return m.CompactRevision
  238. }
  239. return 0
  240. }
  241. type VolumeShortInformationMessage struct {
  242. Id uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
  243. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  244. ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
  245. Version uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
  246. Ttl uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
  247. }
  248. func (m *VolumeShortInformationMessage) Reset() { *m = VolumeShortInformationMessage{} }
  249. func (m *VolumeShortInformationMessage) String() string { return proto.CompactTextString(m) }
  250. func (*VolumeShortInformationMessage) ProtoMessage() {}
  251. func (*VolumeShortInformationMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
  252. func (m *VolumeShortInformationMessage) GetId() uint32 {
  253. if m != nil {
  254. return m.Id
  255. }
  256. return 0
  257. }
  258. func (m *VolumeShortInformationMessage) GetCollection() string {
  259. if m != nil {
  260. return m.Collection
  261. }
  262. return ""
  263. }
  264. func (m *VolumeShortInformationMessage) GetReplicaPlacement() uint32 {
  265. if m != nil {
  266. return m.ReplicaPlacement
  267. }
  268. return 0
  269. }
  270. func (m *VolumeShortInformationMessage) GetVersion() uint32 {
  271. if m != nil {
  272. return m.Version
  273. }
  274. return 0
  275. }
  276. func (m *VolumeShortInformationMessage) GetTtl() uint32 {
  277. if m != nil {
  278. return m.Ttl
  279. }
  280. return 0
  281. }
  282. type Empty struct {
  283. }
  284. func (m *Empty) Reset() { *m = Empty{} }
  285. func (m *Empty) String() string { return proto.CompactTextString(m) }
  286. func (*Empty) ProtoMessage() {}
  287. func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
  288. type SuperBlockExtra struct {
  289. ErasureCoding *SuperBlockExtra_ErasureCoding `protobuf:"bytes,1,opt,name=erasure_coding,json=erasureCoding" json:"erasure_coding,omitempty"`
  290. }
  291. func (m *SuperBlockExtra) Reset() { *m = SuperBlockExtra{} }
  292. func (m *SuperBlockExtra) String() string { return proto.CompactTextString(m) }
  293. func (*SuperBlockExtra) ProtoMessage() {}
  294. func (*SuperBlockExtra) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
  295. func (m *SuperBlockExtra) GetErasureCoding() *SuperBlockExtra_ErasureCoding {
  296. if m != nil {
  297. return m.ErasureCoding
  298. }
  299. return nil
  300. }
  301. type SuperBlockExtra_ErasureCoding struct {
  302. Data uint32 `protobuf:"varint,1,opt,name=data" json:"data,omitempty"`
  303. Parity uint32 `protobuf:"varint,2,opt,name=parity" json:"parity,omitempty"`
  304. VolumeIds []uint32 `protobuf:"varint,3,rep,packed,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
  305. }
  306. func (m *SuperBlockExtra_ErasureCoding) Reset() { *m = SuperBlockExtra_ErasureCoding{} }
  307. func (m *SuperBlockExtra_ErasureCoding) String() string { return proto.CompactTextString(m) }
  308. func (*SuperBlockExtra_ErasureCoding) ProtoMessage() {}
  309. func (*SuperBlockExtra_ErasureCoding) Descriptor() ([]byte, []int) {
  310. return fileDescriptor0, []int{5, 0}
  311. }
  312. func (m *SuperBlockExtra_ErasureCoding) GetData() uint32 {
  313. if m != nil {
  314. return m.Data
  315. }
  316. return 0
  317. }
  318. func (m *SuperBlockExtra_ErasureCoding) GetParity() uint32 {
  319. if m != nil {
  320. return m.Parity
  321. }
  322. return 0
  323. }
  324. func (m *SuperBlockExtra_ErasureCoding) GetVolumeIds() []uint32 {
  325. if m != nil {
  326. return m.VolumeIds
  327. }
  328. return nil
  329. }
  330. type ClientListenRequest struct {
  331. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  332. }
  333. func (m *ClientListenRequest) Reset() { *m = ClientListenRequest{} }
  334. func (m *ClientListenRequest) String() string { return proto.CompactTextString(m) }
  335. func (*ClientListenRequest) ProtoMessage() {}
  336. func (*ClientListenRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
  337. func (m *ClientListenRequest) GetName() string {
  338. if m != nil {
  339. return m.Name
  340. }
  341. return ""
  342. }
  343. type VolumeLocation struct {
  344. Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
  345. PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  346. NewVids []uint32 `protobuf:"varint,3,rep,packed,name=new_vids,json=newVids" json:"new_vids,omitempty"`
  347. DeletedVids []uint32 `protobuf:"varint,4,rep,packed,name=deleted_vids,json=deletedVids" json:"deleted_vids,omitempty"`
  348. }
  349. func (m *VolumeLocation) Reset() { *m = VolumeLocation{} }
  350. func (m *VolumeLocation) String() string { return proto.CompactTextString(m) }
  351. func (*VolumeLocation) ProtoMessage() {}
  352. func (*VolumeLocation) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
  353. func (m *VolumeLocation) GetUrl() string {
  354. if m != nil {
  355. return m.Url
  356. }
  357. return ""
  358. }
  359. func (m *VolumeLocation) GetPublicUrl() string {
  360. if m != nil {
  361. return m.PublicUrl
  362. }
  363. return ""
  364. }
  365. func (m *VolumeLocation) GetNewVids() []uint32 {
  366. if m != nil {
  367. return m.NewVids
  368. }
  369. return nil
  370. }
  371. func (m *VolumeLocation) GetDeletedVids() []uint32 {
  372. if m != nil {
  373. return m.DeletedVids
  374. }
  375. return nil
  376. }
  377. type LookupVolumeRequest struct {
  378. VolumeIds []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
  379. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  380. }
  381. func (m *LookupVolumeRequest) Reset() { *m = LookupVolumeRequest{} }
  382. func (m *LookupVolumeRequest) String() string { return proto.CompactTextString(m) }
  383. func (*LookupVolumeRequest) ProtoMessage() {}
  384. func (*LookupVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
  385. func (m *LookupVolumeRequest) GetVolumeIds() []string {
  386. if m != nil {
  387. return m.VolumeIds
  388. }
  389. return nil
  390. }
  391. func (m *LookupVolumeRequest) GetCollection() string {
  392. if m != nil {
  393. return m.Collection
  394. }
  395. return ""
  396. }
  397. type LookupVolumeResponse struct {
  398. VolumeIdLocations []*LookupVolumeResponse_VolumeIdLocation `protobuf:"bytes,1,rep,name=volume_id_locations,json=volumeIdLocations" json:"volume_id_locations,omitempty"`
  399. }
  400. func (m *LookupVolumeResponse) Reset() { *m = LookupVolumeResponse{} }
  401. func (m *LookupVolumeResponse) String() string { return proto.CompactTextString(m) }
  402. func (*LookupVolumeResponse) ProtoMessage() {}
  403. func (*LookupVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
  404. func (m *LookupVolumeResponse) GetVolumeIdLocations() []*LookupVolumeResponse_VolumeIdLocation {
  405. if m != nil {
  406. return m.VolumeIdLocations
  407. }
  408. return nil
  409. }
  410. type LookupVolumeResponse_VolumeIdLocation struct {
  411. VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  412. Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
  413. Error string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
  414. }
  415. func (m *LookupVolumeResponse_VolumeIdLocation) Reset() { *m = LookupVolumeResponse_VolumeIdLocation{} }
  416. func (m *LookupVolumeResponse_VolumeIdLocation) String() string { return proto.CompactTextString(m) }
  417. func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage() {}
  418. func (*LookupVolumeResponse_VolumeIdLocation) Descriptor() ([]byte, []int) {
  419. return fileDescriptor0, []int{9, 0}
  420. }
  421. func (m *LookupVolumeResponse_VolumeIdLocation) GetVolumeId() string {
  422. if m != nil {
  423. return m.VolumeId
  424. }
  425. return ""
  426. }
  427. func (m *LookupVolumeResponse_VolumeIdLocation) GetLocations() []*Location {
  428. if m != nil {
  429. return m.Locations
  430. }
  431. return nil
  432. }
  433. func (m *LookupVolumeResponse_VolumeIdLocation) GetError() string {
  434. if m != nil {
  435. return m.Error
  436. }
  437. return ""
  438. }
  439. type Location struct {
  440. Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
  441. PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  442. }
  443. func (m *Location) Reset() { *m = Location{} }
  444. func (m *Location) String() string { return proto.CompactTextString(m) }
  445. func (*Location) ProtoMessage() {}
  446. func (*Location) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
  447. func (m *Location) GetUrl() string {
  448. if m != nil {
  449. return m.Url
  450. }
  451. return ""
  452. }
  453. func (m *Location) GetPublicUrl() string {
  454. if m != nil {
  455. return m.PublicUrl
  456. }
  457. return ""
  458. }
  459. type AssignRequest struct {
  460. Count uint64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
  461. Replication string `protobuf:"bytes,2,opt,name=replication" json:"replication,omitempty"`
  462. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  463. Ttl string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
  464. DataCenter string `protobuf:"bytes,5,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
  465. Rack string `protobuf:"bytes,6,opt,name=rack" json:"rack,omitempty"`
  466. DataNode string `protobuf:"bytes,7,opt,name=data_node,json=dataNode" json:"data_node,omitempty"`
  467. }
  468. func (m *AssignRequest) Reset() { *m = AssignRequest{} }
  469. func (m *AssignRequest) String() string { return proto.CompactTextString(m) }
  470. func (*AssignRequest) ProtoMessage() {}
  471. func (*AssignRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
  472. func (m *AssignRequest) GetCount() uint64 {
  473. if m != nil {
  474. return m.Count
  475. }
  476. return 0
  477. }
  478. func (m *AssignRequest) GetReplication() string {
  479. if m != nil {
  480. return m.Replication
  481. }
  482. return ""
  483. }
  484. func (m *AssignRequest) GetCollection() string {
  485. if m != nil {
  486. return m.Collection
  487. }
  488. return ""
  489. }
  490. func (m *AssignRequest) GetTtl() string {
  491. if m != nil {
  492. return m.Ttl
  493. }
  494. return ""
  495. }
  496. func (m *AssignRequest) GetDataCenter() string {
  497. if m != nil {
  498. return m.DataCenter
  499. }
  500. return ""
  501. }
  502. func (m *AssignRequest) GetRack() string {
  503. if m != nil {
  504. return m.Rack
  505. }
  506. return ""
  507. }
  508. func (m *AssignRequest) GetDataNode() string {
  509. if m != nil {
  510. return m.DataNode
  511. }
  512. return ""
  513. }
  514. type AssignResponse struct {
  515. Fid string `protobuf:"bytes,1,opt,name=fid" json:"fid,omitempty"`
  516. Url string `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
  517. PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  518. Count uint64 `protobuf:"varint,4,opt,name=count" json:"count,omitempty"`
  519. Error string `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
  520. Auth string `protobuf:"bytes,6,opt,name=auth" json:"auth,omitempty"`
  521. }
  522. func (m *AssignResponse) Reset() { *m = AssignResponse{} }
  523. func (m *AssignResponse) String() string { return proto.CompactTextString(m) }
  524. func (*AssignResponse) ProtoMessage() {}
  525. func (*AssignResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
  526. func (m *AssignResponse) GetFid() string {
  527. if m != nil {
  528. return m.Fid
  529. }
  530. return ""
  531. }
  532. func (m *AssignResponse) GetUrl() string {
  533. if m != nil {
  534. return m.Url
  535. }
  536. return ""
  537. }
  538. func (m *AssignResponse) GetPublicUrl() string {
  539. if m != nil {
  540. return m.PublicUrl
  541. }
  542. return ""
  543. }
  544. func (m *AssignResponse) GetCount() uint64 {
  545. if m != nil {
  546. return m.Count
  547. }
  548. return 0
  549. }
  550. func (m *AssignResponse) GetError() string {
  551. if m != nil {
  552. return m.Error
  553. }
  554. return ""
  555. }
  556. func (m *AssignResponse) GetAuth() string {
  557. if m != nil {
  558. return m.Auth
  559. }
  560. return ""
  561. }
  562. type StatisticsRequest struct {
  563. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  564. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  565. Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
  566. }
  567. func (m *StatisticsRequest) Reset() { *m = StatisticsRequest{} }
  568. func (m *StatisticsRequest) String() string { return proto.CompactTextString(m) }
  569. func (*StatisticsRequest) ProtoMessage() {}
  570. func (*StatisticsRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
  571. func (m *StatisticsRequest) GetReplication() string {
  572. if m != nil {
  573. return m.Replication
  574. }
  575. return ""
  576. }
  577. func (m *StatisticsRequest) GetCollection() string {
  578. if m != nil {
  579. return m.Collection
  580. }
  581. return ""
  582. }
  583. func (m *StatisticsRequest) GetTtl() string {
  584. if m != nil {
  585. return m.Ttl
  586. }
  587. return ""
  588. }
  589. type StatisticsResponse struct {
  590. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  591. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  592. Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
  593. TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize" json:"total_size,omitempty"`
  594. UsedSize uint64 `protobuf:"varint,5,opt,name=used_size,json=usedSize" json:"used_size,omitempty"`
  595. FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  596. }
  597. func (m *StatisticsResponse) Reset() { *m = StatisticsResponse{} }
  598. func (m *StatisticsResponse) String() string { return proto.CompactTextString(m) }
  599. func (*StatisticsResponse) ProtoMessage() {}
  600. func (*StatisticsResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
  601. func (m *StatisticsResponse) GetReplication() string {
  602. if m != nil {
  603. return m.Replication
  604. }
  605. return ""
  606. }
  607. func (m *StatisticsResponse) GetCollection() string {
  608. if m != nil {
  609. return m.Collection
  610. }
  611. return ""
  612. }
  613. func (m *StatisticsResponse) GetTtl() string {
  614. if m != nil {
  615. return m.Ttl
  616. }
  617. return ""
  618. }
  619. func (m *StatisticsResponse) GetTotalSize() uint64 {
  620. if m != nil {
  621. return m.TotalSize
  622. }
  623. return 0
  624. }
  625. func (m *StatisticsResponse) GetUsedSize() uint64 {
  626. if m != nil {
  627. return m.UsedSize
  628. }
  629. return 0
  630. }
  631. func (m *StatisticsResponse) GetFileCount() uint64 {
  632. if m != nil {
  633. return m.FileCount
  634. }
  635. return 0
  636. }
  637. type StorageType struct {
  638. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  639. Ttl string `protobuf:"bytes,2,opt,name=ttl" json:"ttl,omitempty"`
  640. }
  641. func (m *StorageType) Reset() { *m = StorageType{} }
  642. func (m *StorageType) String() string { return proto.CompactTextString(m) }
  643. func (*StorageType) ProtoMessage() {}
  644. func (*StorageType) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
  645. func (m *StorageType) GetReplication() string {
  646. if m != nil {
  647. return m.Replication
  648. }
  649. return ""
  650. }
  651. func (m *StorageType) GetTtl() string {
  652. if m != nil {
  653. return m.Ttl
  654. }
  655. return ""
  656. }
  657. type Collection struct {
  658. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  659. }
  660. func (m *Collection) Reset() { *m = Collection{} }
  661. func (m *Collection) String() string { return proto.CompactTextString(m) }
  662. func (*Collection) ProtoMessage() {}
  663. func (*Collection) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
  664. func (m *Collection) GetName() string {
  665. if m != nil {
  666. return m.Name
  667. }
  668. return ""
  669. }
  670. type CollectionListRequest struct {
  671. }
  672. func (m *CollectionListRequest) Reset() { *m = CollectionListRequest{} }
  673. func (m *CollectionListRequest) String() string { return proto.CompactTextString(m) }
  674. func (*CollectionListRequest) ProtoMessage() {}
  675. func (*CollectionListRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} }
  676. type CollectionListResponse struct {
  677. Collections []*Collection `protobuf:"bytes,1,rep,name=collections" json:"collections,omitempty"`
  678. }
  679. func (m *CollectionListResponse) Reset() { *m = CollectionListResponse{} }
  680. func (m *CollectionListResponse) String() string { return proto.CompactTextString(m) }
  681. func (*CollectionListResponse) ProtoMessage() {}
  682. func (*CollectionListResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{18} }
  683. func (m *CollectionListResponse) GetCollections() []*Collection {
  684. if m != nil {
  685. return m.Collections
  686. }
  687. return nil
  688. }
  689. type CollectionDeleteRequest struct {
  690. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  691. }
  692. func (m *CollectionDeleteRequest) Reset() { *m = CollectionDeleteRequest{} }
  693. func (m *CollectionDeleteRequest) String() string { return proto.CompactTextString(m) }
  694. func (*CollectionDeleteRequest) ProtoMessage() {}
  695. func (*CollectionDeleteRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{19} }
  696. func (m *CollectionDeleteRequest) GetName() string {
  697. if m != nil {
  698. return m.Name
  699. }
  700. return ""
  701. }
  702. type CollectionDeleteResponse struct {
  703. }
  704. func (m *CollectionDeleteResponse) Reset() { *m = CollectionDeleteResponse{} }
  705. func (m *CollectionDeleteResponse) String() string { return proto.CompactTextString(m) }
  706. func (*CollectionDeleteResponse) ProtoMessage() {}
  707. func (*CollectionDeleteResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{20} }
  708. //
  709. // volume related
  710. //
  711. type DataNodeInfo struct {
  712. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  713. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  714. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  715. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  716. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  717. VolumeInfos []*VolumeInformationMessage `protobuf:"bytes,6,rep,name=volume_infos,json=volumeInfos" json:"volume_infos,omitempty"`
  718. }
  719. func (m *DataNodeInfo) Reset() { *m = DataNodeInfo{} }
  720. func (m *DataNodeInfo) String() string { return proto.CompactTextString(m) }
  721. func (*DataNodeInfo) ProtoMessage() {}
  722. func (*DataNodeInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{21} }
  723. func (m *DataNodeInfo) GetId() string {
  724. if m != nil {
  725. return m.Id
  726. }
  727. return ""
  728. }
  729. func (m *DataNodeInfo) GetVolumeCount() uint64 {
  730. if m != nil {
  731. return m.VolumeCount
  732. }
  733. return 0
  734. }
  735. func (m *DataNodeInfo) GetMaxVolumeCount() uint64 {
  736. if m != nil {
  737. return m.MaxVolumeCount
  738. }
  739. return 0
  740. }
  741. func (m *DataNodeInfo) GetFreeVolumeCount() uint64 {
  742. if m != nil {
  743. return m.FreeVolumeCount
  744. }
  745. return 0
  746. }
  747. func (m *DataNodeInfo) GetActiveVolumeCount() uint64 {
  748. if m != nil {
  749. return m.ActiveVolumeCount
  750. }
  751. return 0
  752. }
  753. func (m *DataNodeInfo) GetVolumeInfos() []*VolumeInformationMessage {
  754. if m != nil {
  755. return m.VolumeInfos
  756. }
  757. return nil
  758. }
  759. type RackInfo struct {
  760. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  761. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  762. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  763. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  764. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  765. DataNodeInfos []*DataNodeInfo `protobuf:"bytes,6,rep,name=data_node_infos,json=dataNodeInfos" json:"data_node_infos,omitempty"`
  766. }
  767. func (m *RackInfo) Reset() { *m = RackInfo{} }
  768. func (m *RackInfo) String() string { return proto.CompactTextString(m) }
  769. func (*RackInfo) ProtoMessage() {}
  770. func (*RackInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{22} }
  771. func (m *RackInfo) GetId() string {
  772. if m != nil {
  773. return m.Id
  774. }
  775. return ""
  776. }
  777. func (m *RackInfo) GetVolumeCount() uint64 {
  778. if m != nil {
  779. return m.VolumeCount
  780. }
  781. return 0
  782. }
  783. func (m *RackInfo) GetMaxVolumeCount() uint64 {
  784. if m != nil {
  785. return m.MaxVolumeCount
  786. }
  787. return 0
  788. }
  789. func (m *RackInfo) GetFreeVolumeCount() uint64 {
  790. if m != nil {
  791. return m.FreeVolumeCount
  792. }
  793. return 0
  794. }
  795. func (m *RackInfo) GetActiveVolumeCount() uint64 {
  796. if m != nil {
  797. return m.ActiveVolumeCount
  798. }
  799. return 0
  800. }
  801. func (m *RackInfo) GetDataNodeInfos() []*DataNodeInfo {
  802. if m != nil {
  803. return m.DataNodeInfos
  804. }
  805. return nil
  806. }
  807. type DataCenterInfo struct {
  808. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  809. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  810. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  811. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  812. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  813. RackInfos []*RackInfo `protobuf:"bytes,6,rep,name=rack_infos,json=rackInfos" json:"rack_infos,omitempty"`
  814. }
  815. func (m *DataCenterInfo) Reset() { *m = DataCenterInfo{} }
  816. func (m *DataCenterInfo) String() string { return proto.CompactTextString(m) }
  817. func (*DataCenterInfo) ProtoMessage() {}
  818. func (*DataCenterInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{23} }
  819. func (m *DataCenterInfo) GetId() string {
  820. if m != nil {
  821. return m.Id
  822. }
  823. return ""
  824. }
  825. func (m *DataCenterInfo) GetVolumeCount() uint64 {
  826. if m != nil {
  827. return m.VolumeCount
  828. }
  829. return 0
  830. }
  831. func (m *DataCenterInfo) GetMaxVolumeCount() uint64 {
  832. if m != nil {
  833. return m.MaxVolumeCount
  834. }
  835. return 0
  836. }
  837. func (m *DataCenterInfo) GetFreeVolumeCount() uint64 {
  838. if m != nil {
  839. return m.FreeVolumeCount
  840. }
  841. return 0
  842. }
  843. func (m *DataCenterInfo) GetActiveVolumeCount() uint64 {
  844. if m != nil {
  845. return m.ActiveVolumeCount
  846. }
  847. return 0
  848. }
  849. func (m *DataCenterInfo) GetRackInfos() []*RackInfo {
  850. if m != nil {
  851. return m.RackInfos
  852. }
  853. return nil
  854. }
  855. type TopologyInfo struct {
  856. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
  857. VolumeCount uint64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
  858. MaxVolumeCount uint64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
  859. FreeVolumeCount uint64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
  860. ActiveVolumeCount uint64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
  861. DataCenterInfos []*DataCenterInfo `protobuf:"bytes,6,rep,name=data_center_infos,json=dataCenterInfos" json:"data_center_infos,omitempty"`
  862. }
  863. func (m *TopologyInfo) Reset() { *m = TopologyInfo{} }
  864. func (m *TopologyInfo) String() string { return proto.CompactTextString(m) }
  865. func (*TopologyInfo) ProtoMessage() {}
  866. func (*TopologyInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{24} }
  867. func (m *TopologyInfo) GetId() string {
  868. if m != nil {
  869. return m.Id
  870. }
  871. return ""
  872. }
  873. func (m *TopologyInfo) GetVolumeCount() uint64 {
  874. if m != nil {
  875. return m.VolumeCount
  876. }
  877. return 0
  878. }
  879. func (m *TopologyInfo) GetMaxVolumeCount() uint64 {
  880. if m != nil {
  881. return m.MaxVolumeCount
  882. }
  883. return 0
  884. }
  885. func (m *TopologyInfo) GetFreeVolumeCount() uint64 {
  886. if m != nil {
  887. return m.FreeVolumeCount
  888. }
  889. return 0
  890. }
  891. func (m *TopologyInfo) GetActiveVolumeCount() uint64 {
  892. if m != nil {
  893. return m.ActiveVolumeCount
  894. }
  895. return 0
  896. }
  897. func (m *TopologyInfo) GetDataCenterInfos() []*DataCenterInfo {
  898. if m != nil {
  899. return m.DataCenterInfos
  900. }
  901. return nil
  902. }
  903. type VolumeListRequest struct {
  904. }
  905. func (m *VolumeListRequest) Reset() { *m = VolumeListRequest{} }
  906. func (m *VolumeListRequest) String() string { return proto.CompactTextString(m) }
  907. func (*VolumeListRequest) ProtoMessage() {}
  908. func (*VolumeListRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{25} }
  909. type VolumeListResponse struct {
  910. TopologyInfo *TopologyInfo `protobuf:"bytes,1,opt,name=topology_info,json=topologyInfo" json:"topology_info,omitempty"`
  911. VolumeSizeLimitMb uint64 `protobuf:"varint,2,opt,name=volume_size_limit_mb,json=volumeSizeLimitMb" json:"volume_size_limit_mb,omitempty"`
  912. }
  913. func (m *VolumeListResponse) Reset() { *m = VolumeListResponse{} }
  914. func (m *VolumeListResponse) String() string { return proto.CompactTextString(m) }
  915. func (*VolumeListResponse) ProtoMessage() {}
  916. func (*VolumeListResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{26} }
  917. func (m *VolumeListResponse) GetTopologyInfo() *TopologyInfo {
  918. if m != nil {
  919. return m.TopologyInfo
  920. }
  921. return nil
  922. }
  923. func (m *VolumeListResponse) GetVolumeSizeLimitMb() uint64 {
  924. if m != nil {
  925. return m.VolumeSizeLimitMb
  926. }
  927. return 0
  928. }
  929. func init() {
  930. proto.RegisterType((*Heartbeat)(nil), "master_pb.Heartbeat")
  931. proto.RegisterType((*HeartbeatResponse)(nil), "master_pb.HeartbeatResponse")
  932. proto.RegisterType((*VolumeInformationMessage)(nil), "master_pb.VolumeInformationMessage")
  933. proto.RegisterType((*VolumeShortInformationMessage)(nil), "master_pb.VolumeShortInformationMessage")
  934. proto.RegisterType((*Empty)(nil), "master_pb.Empty")
  935. proto.RegisterType((*SuperBlockExtra)(nil), "master_pb.SuperBlockExtra")
  936. proto.RegisterType((*SuperBlockExtra_ErasureCoding)(nil), "master_pb.SuperBlockExtra.ErasureCoding")
  937. proto.RegisterType((*ClientListenRequest)(nil), "master_pb.ClientListenRequest")
  938. proto.RegisterType((*VolumeLocation)(nil), "master_pb.VolumeLocation")
  939. proto.RegisterType((*LookupVolumeRequest)(nil), "master_pb.LookupVolumeRequest")
  940. proto.RegisterType((*LookupVolumeResponse)(nil), "master_pb.LookupVolumeResponse")
  941. proto.RegisterType((*LookupVolumeResponse_VolumeIdLocation)(nil), "master_pb.LookupVolumeResponse.VolumeIdLocation")
  942. proto.RegisterType((*Location)(nil), "master_pb.Location")
  943. proto.RegisterType((*AssignRequest)(nil), "master_pb.AssignRequest")
  944. proto.RegisterType((*AssignResponse)(nil), "master_pb.AssignResponse")
  945. proto.RegisterType((*StatisticsRequest)(nil), "master_pb.StatisticsRequest")
  946. proto.RegisterType((*StatisticsResponse)(nil), "master_pb.StatisticsResponse")
  947. proto.RegisterType((*StorageType)(nil), "master_pb.StorageType")
  948. proto.RegisterType((*Collection)(nil), "master_pb.Collection")
  949. proto.RegisterType((*CollectionListRequest)(nil), "master_pb.CollectionListRequest")
  950. proto.RegisterType((*CollectionListResponse)(nil), "master_pb.CollectionListResponse")
  951. proto.RegisterType((*CollectionDeleteRequest)(nil), "master_pb.CollectionDeleteRequest")
  952. proto.RegisterType((*CollectionDeleteResponse)(nil), "master_pb.CollectionDeleteResponse")
  953. proto.RegisterType((*DataNodeInfo)(nil), "master_pb.DataNodeInfo")
  954. proto.RegisterType((*RackInfo)(nil), "master_pb.RackInfo")
  955. proto.RegisterType((*DataCenterInfo)(nil), "master_pb.DataCenterInfo")
  956. proto.RegisterType((*TopologyInfo)(nil), "master_pb.TopologyInfo")
  957. proto.RegisterType((*VolumeListRequest)(nil), "master_pb.VolumeListRequest")
  958. proto.RegisterType((*VolumeListResponse)(nil), "master_pb.VolumeListResponse")
  959. }
  960. // Reference imports to suppress errors if they are not otherwise used.
  961. var _ context.Context
  962. var _ grpc.ClientConn
  963. // This is a compile-time assertion to ensure that this generated file
  964. // is compatible with the grpc package it is being compiled against.
  965. const _ = grpc.SupportPackageIsVersion4
  966. // Client API for Seaweed service
  967. type SeaweedClient interface {
  968. SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error)
  969. KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error)
  970. LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error)
  971. Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error)
  972. Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
  973. CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error)
  974. CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error)
  975. VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error)
  976. }
  977. type seaweedClient struct {
  978. cc *grpc.ClientConn
  979. }
  980. func NewSeaweedClient(cc *grpc.ClientConn) SeaweedClient {
  981. return &seaweedClient{cc}
  982. }
  983. func (c *seaweedClient) SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) {
  984. stream, err := grpc.NewClientStream(ctx, &_Seaweed_serviceDesc.Streams[0], c.cc, "/master_pb.Seaweed/SendHeartbeat", opts...)
  985. if err != nil {
  986. return nil, err
  987. }
  988. x := &seaweedSendHeartbeatClient{stream}
  989. return x, nil
  990. }
  991. type Seaweed_SendHeartbeatClient interface {
  992. Send(*Heartbeat) error
  993. Recv() (*HeartbeatResponse, error)
  994. grpc.ClientStream
  995. }
  996. type seaweedSendHeartbeatClient struct {
  997. grpc.ClientStream
  998. }
  999. func (x *seaweedSendHeartbeatClient) Send(m *Heartbeat) error {
  1000. return x.ClientStream.SendMsg(m)
  1001. }
  1002. func (x *seaweedSendHeartbeatClient) Recv() (*HeartbeatResponse, error) {
  1003. m := new(HeartbeatResponse)
  1004. if err := x.ClientStream.RecvMsg(m); err != nil {
  1005. return nil, err
  1006. }
  1007. return m, nil
  1008. }
  1009. func (c *seaweedClient) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) {
  1010. stream, err := grpc.NewClientStream(ctx, &_Seaweed_serviceDesc.Streams[1], c.cc, "/master_pb.Seaweed/KeepConnected", opts...)
  1011. if err != nil {
  1012. return nil, err
  1013. }
  1014. x := &seaweedKeepConnectedClient{stream}
  1015. return x, nil
  1016. }
  1017. type Seaweed_KeepConnectedClient interface {
  1018. Send(*ClientListenRequest) error
  1019. Recv() (*VolumeLocation, error)
  1020. grpc.ClientStream
  1021. }
  1022. type seaweedKeepConnectedClient struct {
  1023. grpc.ClientStream
  1024. }
  1025. func (x *seaweedKeepConnectedClient) Send(m *ClientListenRequest) error {
  1026. return x.ClientStream.SendMsg(m)
  1027. }
  1028. func (x *seaweedKeepConnectedClient) Recv() (*VolumeLocation, error) {
  1029. m := new(VolumeLocation)
  1030. if err := x.ClientStream.RecvMsg(m); err != nil {
  1031. return nil, err
  1032. }
  1033. return m, nil
  1034. }
  1035. func (c *seaweedClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) {
  1036. out := new(LookupVolumeResponse)
  1037. err := grpc.Invoke(ctx, "/master_pb.Seaweed/LookupVolume", in, out, c.cc, opts...)
  1038. if err != nil {
  1039. return nil, err
  1040. }
  1041. return out, nil
  1042. }
  1043. func (c *seaweedClient) Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) {
  1044. out := new(AssignResponse)
  1045. err := grpc.Invoke(ctx, "/master_pb.Seaweed/Assign", in, out, c.cc, opts...)
  1046. if err != nil {
  1047. return nil, err
  1048. }
  1049. return out, nil
  1050. }
  1051. func (c *seaweedClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) {
  1052. out := new(StatisticsResponse)
  1053. err := grpc.Invoke(ctx, "/master_pb.Seaweed/Statistics", in, out, c.cc, opts...)
  1054. if err != nil {
  1055. return nil, err
  1056. }
  1057. return out, nil
  1058. }
  1059. func (c *seaweedClient) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) {
  1060. out := new(CollectionListResponse)
  1061. err := grpc.Invoke(ctx, "/master_pb.Seaweed/CollectionList", in, out, c.cc, opts...)
  1062. if err != nil {
  1063. return nil, err
  1064. }
  1065. return out, nil
  1066. }
  1067. func (c *seaweedClient) CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) {
  1068. out := new(CollectionDeleteResponse)
  1069. err := grpc.Invoke(ctx, "/master_pb.Seaweed/CollectionDelete", in, out, c.cc, opts...)
  1070. if err != nil {
  1071. return nil, err
  1072. }
  1073. return out, nil
  1074. }
  1075. func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) {
  1076. out := new(VolumeListResponse)
  1077. err := grpc.Invoke(ctx, "/master_pb.Seaweed/VolumeList", in, out, c.cc, opts...)
  1078. if err != nil {
  1079. return nil, err
  1080. }
  1081. return out, nil
  1082. }
  1083. // Server API for Seaweed service
  1084. type SeaweedServer interface {
  1085. SendHeartbeat(Seaweed_SendHeartbeatServer) error
  1086. KeepConnected(Seaweed_KeepConnectedServer) error
  1087. LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
  1088. Assign(context.Context, *AssignRequest) (*AssignResponse, error)
  1089. Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
  1090. CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
  1091. CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error)
  1092. VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)
  1093. }
  1094. func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer) {
  1095. s.RegisterService(&_Seaweed_serviceDesc, srv)
  1096. }
  1097. func _Seaweed_SendHeartbeat_Handler(srv interface{}, stream grpc.ServerStream) error {
  1098. return srv.(SeaweedServer).SendHeartbeat(&seaweedSendHeartbeatServer{stream})
  1099. }
  1100. type Seaweed_SendHeartbeatServer interface {
  1101. Send(*HeartbeatResponse) error
  1102. Recv() (*Heartbeat, error)
  1103. grpc.ServerStream
  1104. }
  1105. type seaweedSendHeartbeatServer struct {
  1106. grpc.ServerStream
  1107. }
  1108. func (x *seaweedSendHeartbeatServer) Send(m *HeartbeatResponse) error {
  1109. return x.ServerStream.SendMsg(m)
  1110. }
  1111. func (x *seaweedSendHeartbeatServer) Recv() (*Heartbeat, error) {
  1112. m := new(Heartbeat)
  1113. if err := x.ServerStream.RecvMsg(m); err != nil {
  1114. return nil, err
  1115. }
  1116. return m, nil
  1117. }
  1118. func _Seaweed_KeepConnected_Handler(srv interface{}, stream grpc.ServerStream) error {
  1119. return srv.(SeaweedServer).KeepConnected(&seaweedKeepConnectedServer{stream})
  1120. }
  1121. type Seaweed_KeepConnectedServer interface {
  1122. Send(*VolumeLocation) error
  1123. Recv() (*ClientListenRequest, error)
  1124. grpc.ServerStream
  1125. }
  1126. type seaweedKeepConnectedServer struct {
  1127. grpc.ServerStream
  1128. }
  1129. func (x *seaweedKeepConnectedServer) Send(m *VolumeLocation) error {
  1130. return x.ServerStream.SendMsg(m)
  1131. }
  1132. func (x *seaweedKeepConnectedServer) Recv() (*ClientListenRequest, error) {
  1133. m := new(ClientListenRequest)
  1134. if err := x.ServerStream.RecvMsg(m); err != nil {
  1135. return nil, err
  1136. }
  1137. return m, nil
  1138. }
  1139. func _Seaweed_LookupVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1140. in := new(LookupVolumeRequest)
  1141. if err := dec(in); err != nil {
  1142. return nil, err
  1143. }
  1144. if interceptor == nil {
  1145. return srv.(SeaweedServer).LookupVolume(ctx, in)
  1146. }
  1147. info := &grpc.UnaryServerInfo{
  1148. Server: srv,
  1149. FullMethod: "/master_pb.Seaweed/LookupVolume",
  1150. }
  1151. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1152. return srv.(SeaweedServer).LookupVolume(ctx, req.(*LookupVolumeRequest))
  1153. }
  1154. return interceptor(ctx, in, info, handler)
  1155. }
  1156. func _Seaweed_Assign_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1157. in := new(AssignRequest)
  1158. if err := dec(in); err != nil {
  1159. return nil, err
  1160. }
  1161. if interceptor == nil {
  1162. return srv.(SeaweedServer).Assign(ctx, in)
  1163. }
  1164. info := &grpc.UnaryServerInfo{
  1165. Server: srv,
  1166. FullMethod: "/master_pb.Seaweed/Assign",
  1167. }
  1168. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1169. return srv.(SeaweedServer).Assign(ctx, req.(*AssignRequest))
  1170. }
  1171. return interceptor(ctx, in, info, handler)
  1172. }
  1173. func _Seaweed_Statistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1174. in := new(StatisticsRequest)
  1175. if err := dec(in); err != nil {
  1176. return nil, err
  1177. }
  1178. if interceptor == nil {
  1179. return srv.(SeaweedServer).Statistics(ctx, in)
  1180. }
  1181. info := &grpc.UnaryServerInfo{
  1182. Server: srv,
  1183. FullMethod: "/master_pb.Seaweed/Statistics",
  1184. }
  1185. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1186. return srv.(SeaweedServer).Statistics(ctx, req.(*StatisticsRequest))
  1187. }
  1188. return interceptor(ctx, in, info, handler)
  1189. }
  1190. func _Seaweed_CollectionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1191. in := new(CollectionListRequest)
  1192. if err := dec(in); err != nil {
  1193. return nil, err
  1194. }
  1195. if interceptor == nil {
  1196. return srv.(SeaweedServer).CollectionList(ctx, in)
  1197. }
  1198. info := &grpc.UnaryServerInfo{
  1199. Server: srv,
  1200. FullMethod: "/master_pb.Seaweed/CollectionList",
  1201. }
  1202. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1203. return srv.(SeaweedServer).CollectionList(ctx, req.(*CollectionListRequest))
  1204. }
  1205. return interceptor(ctx, in, info, handler)
  1206. }
  1207. func _Seaweed_CollectionDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1208. in := new(CollectionDeleteRequest)
  1209. if err := dec(in); err != nil {
  1210. return nil, err
  1211. }
  1212. if interceptor == nil {
  1213. return srv.(SeaweedServer).CollectionDelete(ctx, in)
  1214. }
  1215. info := &grpc.UnaryServerInfo{
  1216. Server: srv,
  1217. FullMethod: "/master_pb.Seaweed/CollectionDelete",
  1218. }
  1219. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1220. return srv.(SeaweedServer).CollectionDelete(ctx, req.(*CollectionDeleteRequest))
  1221. }
  1222. return interceptor(ctx, in, info, handler)
  1223. }
  1224. func _Seaweed_VolumeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1225. in := new(VolumeListRequest)
  1226. if err := dec(in); err != nil {
  1227. return nil, err
  1228. }
  1229. if interceptor == nil {
  1230. return srv.(SeaweedServer).VolumeList(ctx, in)
  1231. }
  1232. info := &grpc.UnaryServerInfo{
  1233. Server: srv,
  1234. FullMethod: "/master_pb.Seaweed/VolumeList",
  1235. }
  1236. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1237. return srv.(SeaweedServer).VolumeList(ctx, req.(*VolumeListRequest))
  1238. }
  1239. return interceptor(ctx, in, info, handler)
  1240. }
  1241. var _Seaweed_serviceDesc = grpc.ServiceDesc{
  1242. ServiceName: "master_pb.Seaweed",
  1243. HandlerType: (*SeaweedServer)(nil),
  1244. Methods: []grpc.MethodDesc{
  1245. {
  1246. MethodName: "LookupVolume",
  1247. Handler: _Seaweed_LookupVolume_Handler,
  1248. },
  1249. {
  1250. MethodName: "Assign",
  1251. Handler: _Seaweed_Assign_Handler,
  1252. },
  1253. {
  1254. MethodName: "Statistics",
  1255. Handler: _Seaweed_Statistics_Handler,
  1256. },
  1257. {
  1258. MethodName: "CollectionList",
  1259. Handler: _Seaweed_CollectionList_Handler,
  1260. },
  1261. {
  1262. MethodName: "CollectionDelete",
  1263. Handler: _Seaweed_CollectionDelete_Handler,
  1264. },
  1265. {
  1266. MethodName: "VolumeList",
  1267. Handler: _Seaweed_VolumeList_Handler,
  1268. },
  1269. },
  1270. Streams: []grpc.StreamDesc{
  1271. {
  1272. StreamName: "SendHeartbeat",
  1273. Handler: _Seaweed_SendHeartbeat_Handler,
  1274. ServerStreams: true,
  1275. ClientStreams: true,
  1276. },
  1277. {
  1278. StreamName: "KeepConnected",
  1279. Handler: _Seaweed_KeepConnected_Handler,
  1280. ServerStreams: true,
  1281. ClientStreams: true,
  1282. },
  1283. },
  1284. Metadata: "master.proto",
  1285. }
  1286. func init() { proto.RegisterFile("master.proto", fileDescriptor0) }
  1287. var fileDescriptor0 = []byte{
  1288. // 1482 bytes of a gzipped FileDescriptorProto
  1289. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xd4, 0x58, 0x4d, 0x6f, 0xdb, 0x46,
  1290. 0x13, 0x36, 0xa9, 0x0f, 0x4b, 0xa3, 0xef, 0xb5, 0x93, 0x30, 0xca, 0x9b, 0x44, 0x61, 0x2e, 0xca,
  1291. 0xfb, 0xe1, 0x37, 0x75, 0x0f, 0x3d, 0xb4, 0x45, 0x90, 0x38, 0x0e, 0x6a, 0xc4, 0x69, 0x12, 0x2a,
  1292. 0x49, 0x81, 0x02, 0x05, 0xbb, 0x22, 0xd7, 0x0e, 0x61, 0x8a, 0x64, 0xc9, 0x95, 0x63, 0xe5, 0xd2,
  1293. 0x43, 0x7b, 0x2c, 0xda, 0x43, 0xff, 0x44, 0x7f, 0x45, 0x2f, 0x3d, 0xe6, 0xc7, 0x14, 0xe8, 0xbd,
  1294. 0x40, 0xb1, 0x1f, 0x24, 0x97, 0x94, 0x6c, 0xa7, 0x05, 0x72, 0xc8, 0x6d, 0x77, 0x66, 0x76, 0x76,
  1295. 0xf6, 0x99, 0xe1, 0x33, 0x23, 0x41, 0x7b, 0x86, 0x13, 0x4a, 0xe2, 0xad, 0x28, 0x0e, 0x69, 0x88,
  1296. 0x9a, 0x62, 0x67, 0x47, 0x53, 0xf3, 0x4d, 0x05, 0x9a, 0x9f, 0x11, 0x1c, 0xd3, 0x29, 0xc1, 0x14,
  1297. 0x75, 0x41, 0xf7, 0x22, 0x43, 0x1b, 0x69, 0xe3, 0xa6, 0xa5, 0x7b, 0x11, 0x42, 0x50, 0x8d, 0xc2,
  1298. 0x98, 0x1a, 0xfa, 0x48, 0x1b, 0x77, 0x2c, 0xbe, 0x46, 0x57, 0x01, 0xa2, 0xf9, 0xd4, 0xf7, 0x1c,
  1299. 0x7b, 0x1e, 0xfb, 0x46, 0x85, 0xdb, 0x36, 0x85, 0xe4, 0x79, 0xec, 0xa3, 0x31, 0xf4, 0x67, 0xf8,
  1300. 0xc4, 0x3e, 0x0e, 0xfd, 0xf9, 0x8c, 0xd8, 0x4e, 0x38, 0x0f, 0xa8, 0x51, 0xe5, 0xc7, 0xbb, 0x33,
  1301. 0x7c, 0xf2, 0x82, 0x8b, 0x77, 0x98, 0x14, 0x8d, 0x58, 0x54, 0x27, 0xf6, 0x81, 0xe7, 0x13, 0xfb,
  1302. 0x88, 0x2c, 0x8c, 0xda, 0x48, 0x1b, 0x57, 0x2d, 0x98, 0xe1, 0x93, 0x07, 0x9e, 0x4f, 0x1e, 0x92,
  1303. 0x05, 0xba, 0x0e, 0x2d, 0x17, 0x53, 0x6c, 0x3b, 0x24, 0xa0, 0x24, 0x36, 0xea, 0xfc, 0x2e, 0x60,
  1304. 0xa2, 0x1d, 0x2e, 0x61, 0xf1, 0xc5, 0xd8, 0x39, 0x32, 0xd6, 0xb9, 0x86, 0xaf, 0x59, 0x7c, 0xd8,
  1305. 0x9d, 0x79, 0x81, 0xcd, 0x23, 0x6f, 0xf0, 0xab, 0x9b, 0x5c, 0xf2, 0x84, 0x85, 0xff, 0x29, 0xac,
  1306. 0x8b, 0xd8, 0x12, 0xa3, 0x39, 0xaa, 0x8c, 0x5b, 0xdb, 0x37, 0xb7, 0x32, 0x34, 0xb6, 0x44, 0x78,
  1307. 0x7b, 0xc1, 0x41, 0x18, 0xcf, 0x30, 0xf5, 0xc2, 0xe0, 0x11, 0x49, 0x12, 0x7c, 0x48, 0xac, 0xf4,
  1308. 0x0c, 0xda, 0x83, 0x56, 0x40, 0x5e, 0xd9, 0xa9, 0x0b, 0xe0, 0x2e, 0xc6, 0x4b, 0x2e, 0x26, 0x2f,
  1309. 0xc3, 0x98, 0xae, 0xf0, 0x03, 0x01, 0x79, 0xf5, 0x42, 0xba, 0x7a, 0x0a, 0x3d, 0x97, 0xf8, 0x84,
  1310. 0x12, 0x37, 0x73, 0xd7, 0xfa, 0x9b, 0xee, 0xba, 0xd2, 0x81, 0x74, 0x69, 0x3e, 0x87, 0x41, 0x96,
  1311. 0x4c, 0x8b, 0x24, 0x51, 0x18, 0x24, 0x04, 0x8d, 0xa1, 0x27, 0xfc, 0x4f, 0xbc, 0xd7, 0x64, 0xdf,
  1312. 0x9b, 0x79, 0x94, 0x67, 0xb8, 0x6a, 0x95, 0xc5, 0xe8, 0x22, 0xd4, 0x7d, 0x82, 0x5d, 0x12, 0xcb,
  1313. 0xb4, 0xca, 0x9d, 0xf9, 0xbb, 0x0e, 0xc6, 0x69, 0xd0, 0xf0, 0x9a, 0x71, 0xb9, 0xc7, 0x8e, 0xa5,
  1314. 0x7b, 0x2e, 0xcb, 0x49, 0xe2, 0xbd, 0x26, 0xbc, 0x66, 0xaa, 0x16, 0x5f, 0xa3, 0x6b, 0x00, 0x4e,
  1315. 0xe8, 0xfb, 0xc4, 0x61, 0x07, 0xa5, 0x73, 0x45, 0xc2, 0x72, 0xc6, 0xcb, 0x20, 0x2f, 0x97, 0xaa,
  1316. 0xd5, 0x64, 0x12, 0x51, 0x29, 0x37, 0xa0, 0x2d, 0x1e, 0x2a, 0x0d, 0x44, 0xa5, 0xb4, 0x84, 0x4c,
  1317. 0x98, 0xfc, 0x17, 0x50, 0x0a, 0xe6, 0x74, 0x91, 0x19, 0xd6, 0xb9, 0x61, 0x5f, 0x6a, 0xee, 0x2d,
  1318. 0x52, 0xeb, 0x2b, 0xd0, 0x8c, 0x09, 0x76, 0xed, 0x30, 0xf0, 0x17, 0xbc, 0x78, 0x1a, 0x56, 0x83,
  1319. 0x09, 0x1e, 0x07, 0xfe, 0x02, 0xfd, 0x07, 0x06, 0x31, 0x89, 0x7c, 0xcf, 0xc1, 0x76, 0xe4, 0x63,
  1320. 0x87, 0xcc, 0x48, 0x90, 0xd6, 0x51, 0x5f, 0x2a, 0x9e, 0xa4, 0x72, 0x64, 0xc0, 0xfa, 0x31, 0x89,
  1321. 0x13, 0xf6, 0xac, 0x26, 0x37, 0x49, 0xb7, 0xa8, 0x0f, 0x15, 0x4a, 0x7d, 0x03, 0xb8, 0x94, 0x2d,
  1322. 0xd1, 0x2d, 0xe8, 0x3b, 0xe1, 0x2c, 0xc2, 0x0e, 0xb5, 0x63, 0x72, 0xec, 0xf1, 0x43, 0x2d, 0xae,
  1323. 0xee, 0x49, 0xb9, 0x25, 0xc5, 0xe6, 0x2f, 0x1a, 0x5c, 0x3d, 0x33, 0xf5, 0x4b, 0xb0, 0x9f, 0x07,
  1324. 0xf1, 0xbb, 0x7a, 0x95, 0xb9, 0x0e, 0xb5, 0xdd, 0x59, 0x44, 0x17, 0xe6, 0xaf, 0x1a, 0xf4, 0x26,
  1325. 0xf3, 0x88, 0xc4, 0xf7, 0xfc, 0xd0, 0x39, 0xda, 0x3d, 0xa1, 0x31, 0x46, 0x8f, 0xa1, 0x4b, 0x62,
  1326. 0x9c, 0xcc, 0x63, 0x96, 0x11, 0xd7, 0x0b, 0x0e, 0x79, 0xc4, 0xc5, 0x12, 0x2f, 0x9d, 0xd9, 0xda,
  1327. 0x15, 0x07, 0x76, 0xb8, 0xbd, 0xd5, 0x21, 0xea, 0x76, 0xf8, 0x25, 0x74, 0x0a, 0x7a, 0x56, 0x6e,
  1328. 0x8c, 0x10, 0x24, 0x12, 0x7c, 0xcd, 0xea, 0x38, 0xc2, 0xb1, 0x47, 0x17, 0x92, 0xb8, 0xe4, 0x8e,
  1329. 0x95, 0x99, 0xe4, 0x25, 0xcf, 0x4d, 0x8c, 0xca, 0xa8, 0xc2, 0xa8, 0x41, 0x48, 0xf6, 0xdc, 0xc4,
  1330. 0xbc, 0x05, 0x1b, 0x3b, 0xbe, 0x47, 0x02, 0xba, 0xef, 0x25, 0x94, 0x04, 0x16, 0xf9, 0x66, 0x4e,
  1331. 0x12, 0xca, 0x6e, 0x08, 0xf0, 0x8c, 0x48, 0x5a, 0xe4, 0x6b, 0xf3, 0x5b, 0xe8, 0x8a, 0xf4, 0xec,
  1332. 0x87, 0x0e, 0x4f, 0x0b, 0x03, 0x86, 0xf1, 0xa1, 0x30, 0x62, 0xcb, 0x12, 0x51, 0xea, 0x65, 0xa2,
  1333. 0xbc, 0x0c, 0x0d, 0xce, 0x24, 0x79, 0x28, 0xeb, 0x8c, 0x1c, 0x3c, 0x37, 0xc9, 0xeb, 0xdd, 0x15,
  1334. 0xea, 0x2a, 0x57, 0xb7, 0xd2, 0x8f, 0xdd, 0x73, 0x13, 0xf3, 0x19, 0x6c, 0xec, 0x87, 0xe1, 0xd1,
  1335. 0x3c, 0x12, 0x61, 0xa4, 0xb1, 0x16, 0x5f, 0xa8, 0x8d, 0x2a, 0xec, 0xce, 0xec, 0x85, 0xa5, 0x22,
  1336. 0xd1, 0xcb, 0x45, 0x62, 0xfe, 0xa1, 0xc1, 0x66, 0xd1, 0xad, 0xe4, 0x90, 0xaf, 0x61, 0x23, 0xf3,
  1337. 0x6b, 0xfb, 0xf2, 0xcd, 0xe2, 0x82, 0xd6, 0xf6, 0x6d, 0x25, 0x99, 0xab, 0x4e, 0xa7, 0xb4, 0xea,
  1338. 0xa6, 0x60, 0x59, 0x83, 0xe3, 0x92, 0x24, 0x19, 0x9e, 0x40, 0xbf, 0x6c, 0xc6, 0x3e, 0xd3, 0xec,
  1339. 0x56, 0x89, 0x6c, 0x23, 0x3d, 0x89, 0x3e, 0x80, 0x66, 0x1e, 0x88, 0xce, 0x03, 0xd9, 0x28, 0x04,
  1340. 0x22, 0xef, 0xca, 0xad, 0xd0, 0x26, 0xd4, 0x48, 0x1c, 0x87, 0x29, 0xbd, 0x89, 0x8d, 0xf9, 0x31,
  1341. 0x34, 0xfe, 0x71, 0x16, 0xcd, 0x37, 0x1a, 0x74, 0xee, 0x26, 0x89, 0x77, 0x98, 0x95, 0xcb, 0x26,
  1342. 0xd4, 0x04, 0xf9, 0x08, 0x92, 0x15, 0x1b, 0x34, 0x82, 0x96, 0xfc, 0xca, 0x14, 0xe8, 0x55, 0xd1,
  1343. 0xb9, 0x1f, 0xb0, 0xfc, 0xf2, 0xaa, 0x22, 0x34, 0xc6, 0x27, 0xa5, 0xf6, 0x58, 0x3b, 0xb5, 0x3d,
  1344. 0xd6, 0x95, 0xf6, 0x78, 0x05, 0x9a, 0xfc, 0x50, 0x10, 0xba, 0x44, 0xf6, 0xcd, 0x06, 0x13, 0x7c,
  1345. 0x1e, 0xba, 0xc4, 0xfc, 0x59, 0x83, 0x6e, 0xfa, 0x1a, 0x99, 0xf9, 0x3e, 0x54, 0x0e, 0x32, 0xf4,
  1346. 0xd9, 0x32, 0xc5, 0x48, 0x3f, 0x0d, 0xa3, 0xa5, 0x91, 0x20, 0x43, 0xa4, 0xaa, 0x22, 0x92, 0x25,
  1347. 0xa3, 0xa6, 0x24, 0x83, 0x85, 0x8c, 0xe7, 0xf4, 0x65, 0x1a, 0x32, 0x5b, 0x9b, 0x87, 0x30, 0x98,
  1348. 0x50, 0x4c, 0xbd, 0x84, 0x7a, 0x4e, 0x92, 0xc2, 0x5c, 0x02, 0x54, 0x3b, 0x0f, 0x50, 0xfd, 0x34,
  1349. 0x40, 0x2b, 0x19, 0xa0, 0xe6, 0x6f, 0x1a, 0x20, 0xf5, 0x26, 0x09, 0xc1, 0x3b, 0xb8, 0x8a, 0x41,
  1350. 0x46, 0x43, 0x8a, 0x7d, 0x9b, 0xf7, 0x4a, 0xd9, 0xf1, 0xb8, 0x84, 0xb5, 0x63, 0x96, 0xa5, 0x79,
  1351. 0x42, 0x5c, 0xa1, 0x15, 0xed, 0xae, 0xc1, 0x04, 0x5c, 0x59, 0xec, 0x96, 0xf5, 0x52, 0xb7, 0x34,
  1352. 0xef, 0x42, 0x6b, 0x42, 0xc3, 0x18, 0x1f, 0x92, 0x67, 0x8b, 0xe8, 0x6d, 0xa2, 0x97, 0xd1, 0xe9,
  1353. 0x39, 0x10, 0x23, 0x80, 0x9d, 0x3c, 0xfa, 0x55, 0x04, 0x78, 0x09, 0x2e, 0xe4, 0x16, 0x8c, 0x2f,
  1354. 0x65, 0x5e, 0xcc, 0xa7, 0x70, 0xb1, 0xac, 0x90, 0x30, 0x7e, 0x04, 0xad, 0x1c, 0x92, 0x94, 0x3b,
  1355. 0x2e, 0x28, 0x9f, 0x6c, 0x7e, 0xce, 0x52, 0x2d, 0xcd, 0xff, 0xc1, 0xa5, 0x5c, 0x75, 0x9f, 0x93,
  1356. 0xe0, 0x59, 0xdc, 0x3c, 0x04, 0x63, 0xd9, 0x5c, 0xc4, 0x60, 0xfe, 0xa4, 0x43, 0xfb, 0xbe, 0xac,
  1357. 0x76, 0xd6, 0x54, 0x95, 0x36, 0xda, 0xe4, 0x6d, 0xf4, 0x06, 0xb4, 0x0b, 0xa3, 0xab, 0x98, 0x62,
  1358. 0x5a, 0xc7, 0xca, 0xdc, 0xba, 0x6a, 0xc2, 0xad, 0x70, 0xb3, 0xf2, 0x84, 0xfb, 0x6f, 0x18, 0x1c,
  1359. 0xc4, 0x84, 0x2c, 0x0f, 0xc3, 0x55, 0xab, 0xc7, 0x14, 0xaa, 0xed, 0x16, 0x6c, 0x60, 0x87, 0x7a,
  1360. 0xc7, 0x25, 0x6b, 0x91, 0xfb, 0x81, 0x50, 0xa9, 0xf6, 0x0f, 0xb2, 0x40, 0xbd, 0xe0, 0x20, 0x4c,
  1361. 0x8c, 0xfa, 0xdb, 0x0f, 0xb3, 0xf2, 0x35, 0x4c, 0x93, 0x98, 0xdf, 0xeb, 0xd0, 0xb0, 0xb0, 0x73,
  1362. 0xf4, 0x7e, 0xa3, 0x71, 0x07, 0x7a, 0x19, 0xab, 0x15, 0x00, 0xb9, 0xa4, 0x00, 0xa2, 0x26, 0xde,
  1363. 0xea, 0xb8, 0xca, 0x2e, 0x31, 0xff, 0xd4, 0xa0, 0x7b, 0x3f, 0x63, 0xce, 0xf7, 0x1b, 0x8c, 0x6d,
  1364. 0x00, 0x46, 0xf5, 0x05, 0x1c, 0xd4, 0xd6, 0x98, 0xa6, 0xdb, 0x6a, 0xc6, 0x72, 0x95, 0x98, 0x3f,
  1365. 0xea, 0xd0, 0x7e, 0x16, 0x46, 0xa1, 0x1f, 0x1e, 0x2e, 0xde, 0xef, 0xd7, 0xef, 0xc2, 0x40, 0xe9,
  1366. 0x8a, 0x05, 0x10, 0x2e, 0x97, 0x8a, 0x21, 0x4f, 0xb6, 0xd5, 0x73, 0x0b, 0xfb, 0xc4, 0xdc, 0x80,
  1367. 0x81, 0x9c, 0xf0, 0x14, 0x72, 0xfb, 0x4e, 0x03, 0xa4, 0x4a, 0x25, 0xb3, 0x7d, 0x02, 0x1d, 0x2a,
  1368. 0xb1, 0xe3, 0xf7, 0xc9, 0x21, 0x57, 0xad, 0x3d, 0x15, 0x5b, 0xab, 0x4d, 0x55, 0xa4, 0xff, 0x0f,
  1369. 0x9b, 0xf2, 0x65, 0x8c, 0xed, 0x6d, 0x9f, 0xfd, 0x14, 0xb3, 0x67, 0x53, 0x89, 0xf0, 0xa0, 0xf4,
  1370. 0x23, 0xed, 0xd1, 0x74, 0xfb, 0x87, 0x1a, 0xac, 0x4f, 0x08, 0x7e, 0x45, 0x88, 0x8b, 0xf6, 0xa0,
  1371. 0x33, 0x21, 0x81, 0x9b, 0xff, 0x84, 0xdf, 0x54, 0x2e, 0xcd, 0xa4, 0xc3, 0x7f, 0xad, 0x92, 0x66,
  1372. 0xac, 0xb8, 0x36, 0xd6, 0x6e, 0x6b, 0xe8, 0x09, 0x74, 0x1e, 0x12, 0x12, 0xed, 0x84, 0x41, 0x40,
  1373. 0x1c, 0x4a, 0x5c, 0x74, 0x4d, 0xe5, 0xe6, 0xe5, 0xc1, 0x78, 0x78, 0x79, 0x89, 0x6c, 0xd2, 0x39,
  1374. 0x4a, 0x7a, 0x7c, 0x0a, 0x6d, 0x75, 0x1e, 0x2c, 0x38, 0x5c, 0x31, 0xbd, 0x0e, 0xaf, 0x9f, 0x33,
  1375. 0x48, 0x9a, 0x6b, 0xe8, 0x0e, 0xd4, 0xc5, 0x80, 0x82, 0x0c, 0xc5, 0xb8, 0x30, 0x81, 0x15, 0xe2,
  1376. 0x2a, 0x4e, 0x33, 0xe6, 0x1a, 0x7a, 0x08, 0x90, 0xb7, 0x78, 0xa4, 0xe2, 0xb2, 0x34, 0x63, 0x0c,
  1377. 0xaf, 0x9e, 0xa2, 0xcd, 0x9c, 0x7d, 0x01, 0xdd, 0x62, 0xb3, 0x43, 0xa3, 0x95, 0xfd, 0x4c, 0xa9,
  1378. 0xa1, 0xe1, 0x8d, 0x33, 0x2c, 0x32, 0xc7, 0x5f, 0x41, 0xbf, 0xdc, 0xc3, 0x90, 0xb9, 0xf2, 0x60,
  1379. 0xa1, 0x1f, 0x0e, 0x6f, 0x9e, 0x69, 0xa3, 0x82, 0x90, 0x97, 0x71, 0x01, 0x84, 0xa5, 0x9a, 0x2f,
  1380. 0x80, 0xb0, 0x5c, 0xfb, 0xe6, 0xda, 0xb4, 0xce, 0xff, 0x54, 0xfa, 0xf0, 0xaf, 0x00, 0x00, 0x00,
  1381. 0xff, 0xff, 0x94, 0xee, 0xe2, 0x89, 0x64, 0x12, 0x00, 0x00,
  1382. }