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.

1697 lines
60 KiB

  1. // Code generated by protoc-gen-go.
  2. // source: filer.proto
  3. // DO NOT EDIT!
  4. /*
  5. Package filer_pb is a generated protocol buffer package.
  6. It is generated from these files:
  7. filer.proto
  8. It has these top-level messages:
  9. LookupDirectoryEntryRequest
  10. LookupDirectoryEntryResponse
  11. ListEntriesRequest
  12. ListEntriesResponse
  13. Entry
  14. FullEntry
  15. EventNotification
  16. FileChunk
  17. FileId
  18. FuseAttributes
  19. CreateEntryRequest
  20. CreateEntryResponse
  21. UpdateEntryRequest
  22. UpdateEntryResponse
  23. DeleteEntryRequest
  24. DeleteEntryResponse
  25. AtomicRenameEntryRequest
  26. AtomicRenameEntryResponse
  27. AssignVolumeRequest
  28. AssignVolumeResponse
  29. LookupVolumeRequest
  30. Locations
  31. Location
  32. LookupVolumeResponse
  33. DeleteCollectionRequest
  34. DeleteCollectionResponse
  35. StatisticsRequest
  36. StatisticsResponse
  37. GetFilerConfigurationRequest
  38. GetFilerConfigurationResponse
  39. */
  40. package filer_pb
  41. import proto "github.com/golang/protobuf/proto"
  42. import fmt "fmt"
  43. import math "math"
  44. import (
  45. context "golang.org/x/net/context"
  46. grpc "google.golang.org/grpc"
  47. )
  48. // Reference imports to suppress errors if they are not otherwise used.
  49. var _ = proto.Marshal
  50. var _ = fmt.Errorf
  51. var _ = math.Inf
  52. // This is a compile-time assertion to ensure that this generated file
  53. // is compatible with the proto package it is being compiled against.
  54. // A compilation error at this line likely means your copy of the
  55. // proto package needs to be updated.
  56. const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  57. type LookupDirectoryEntryRequest struct {
  58. Directory string `protobuf:"bytes,1,opt,name=directory" json:"directory,omitempty"`
  59. Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
  60. }
  61. func (m *LookupDirectoryEntryRequest) Reset() { *m = LookupDirectoryEntryRequest{} }
  62. func (m *LookupDirectoryEntryRequest) String() string { return proto.CompactTextString(m) }
  63. func (*LookupDirectoryEntryRequest) ProtoMessage() {}
  64. func (*LookupDirectoryEntryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
  65. func (m *LookupDirectoryEntryRequest) GetDirectory() string {
  66. if m != nil {
  67. return m.Directory
  68. }
  69. return ""
  70. }
  71. func (m *LookupDirectoryEntryRequest) GetName() string {
  72. if m != nil {
  73. return m.Name
  74. }
  75. return ""
  76. }
  77. type LookupDirectoryEntryResponse struct {
  78. Entry *Entry `protobuf:"bytes,1,opt,name=entry" json:"entry,omitempty"`
  79. }
  80. func (m *LookupDirectoryEntryResponse) Reset() { *m = LookupDirectoryEntryResponse{} }
  81. func (m *LookupDirectoryEntryResponse) String() string { return proto.CompactTextString(m) }
  82. func (*LookupDirectoryEntryResponse) ProtoMessage() {}
  83. func (*LookupDirectoryEntryResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
  84. func (m *LookupDirectoryEntryResponse) GetEntry() *Entry {
  85. if m != nil {
  86. return m.Entry
  87. }
  88. return nil
  89. }
  90. type ListEntriesRequest struct {
  91. Directory string `protobuf:"bytes,1,opt,name=directory" json:"directory,omitempty"`
  92. Prefix string `protobuf:"bytes,2,opt,name=prefix" json:"prefix,omitempty"`
  93. StartFromFileName string `protobuf:"bytes,3,opt,name=startFromFileName" json:"startFromFileName,omitempty"`
  94. InclusiveStartFrom bool `protobuf:"varint,4,opt,name=inclusiveStartFrom" json:"inclusiveStartFrom,omitempty"`
  95. Limit uint32 `protobuf:"varint,5,opt,name=limit" json:"limit,omitempty"`
  96. }
  97. func (m *ListEntriesRequest) Reset() { *m = ListEntriesRequest{} }
  98. func (m *ListEntriesRequest) String() string { return proto.CompactTextString(m) }
  99. func (*ListEntriesRequest) ProtoMessage() {}
  100. func (*ListEntriesRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
  101. func (m *ListEntriesRequest) GetDirectory() string {
  102. if m != nil {
  103. return m.Directory
  104. }
  105. return ""
  106. }
  107. func (m *ListEntriesRequest) GetPrefix() string {
  108. if m != nil {
  109. return m.Prefix
  110. }
  111. return ""
  112. }
  113. func (m *ListEntriesRequest) GetStartFromFileName() string {
  114. if m != nil {
  115. return m.StartFromFileName
  116. }
  117. return ""
  118. }
  119. func (m *ListEntriesRequest) GetInclusiveStartFrom() bool {
  120. if m != nil {
  121. return m.InclusiveStartFrom
  122. }
  123. return false
  124. }
  125. func (m *ListEntriesRequest) GetLimit() uint32 {
  126. if m != nil {
  127. return m.Limit
  128. }
  129. return 0
  130. }
  131. type ListEntriesResponse struct {
  132. Entry *Entry `protobuf:"bytes,1,opt,name=entry" json:"entry,omitempty"`
  133. }
  134. func (m *ListEntriesResponse) Reset() { *m = ListEntriesResponse{} }
  135. func (m *ListEntriesResponse) String() string { return proto.CompactTextString(m) }
  136. func (*ListEntriesResponse) ProtoMessage() {}
  137. func (*ListEntriesResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
  138. func (m *ListEntriesResponse) GetEntry() *Entry {
  139. if m != nil {
  140. return m.Entry
  141. }
  142. return nil
  143. }
  144. type Entry struct {
  145. Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
  146. IsDirectory bool `protobuf:"varint,2,opt,name=is_directory,json=isDirectory" json:"is_directory,omitempty"`
  147. Chunks []*FileChunk `protobuf:"bytes,3,rep,name=chunks" json:"chunks,omitempty"`
  148. Attributes *FuseAttributes `protobuf:"bytes,4,opt,name=attributes" json:"attributes,omitempty"`
  149. Extended map[string][]byte `protobuf:"bytes,5,rep,name=extended" json:"extended,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value,proto3"`
  150. }
  151. func (m *Entry) Reset() { *m = Entry{} }
  152. func (m *Entry) String() string { return proto.CompactTextString(m) }
  153. func (*Entry) ProtoMessage() {}
  154. func (*Entry) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
  155. func (m *Entry) GetName() string {
  156. if m != nil {
  157. return m.Name
  158. }
  159. return ""
  160. }
  161. func (m *Entry) GetIsDirectory() bool {
  162. if m != nil {
  163. return m.IsDirectory
  164. }
  165. return false
  166. }
  167. func (m *Entry) GetChunks() []*FileChunk {
  168. if m != nil {
  169. return m.Chunks
  170. }
  171. return nil
  172. }
  173. func (m *Entry) GetAttributes() *FuseAttributes {
  174. if m != nil {
  175. return m.Attributes
  176. }
  177. return nil
  178. }
  179. func (m *Entry) GetExtended() map[string][]byte {
  180. if m != nil {
  181. return m.Extended
  182. }
  183. return nil
  184. }
  185. type FullEntry struct {
  186. Dir string `protobuf:"bytes,1,opt,name=dir" json:"dir,omitempty"`
  187. Entry *Entry `protobuf:"bytes,2,opt,name=entry" json:"entry,omitempty"`
  188. }
  189. func (m *FullEntry) Reset() { *m = FullEntry{} }
  190. func (m *FullEntry) String() string { return proto.CompactTextString(m) }
  191. func (*FullEntry) ProtoMessage() {}
  192. func (*FullEntry) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
  193. func (m *FullEntry) GetDir() string {
  194. if m != nil {
  195. return m.Dir
  196. }
  197. return ""
  198. }
  199. func (m *FullEntry) GetEntry() *Entry {
  200. if m != nil {
  201. return m.Entry
  202. }
  203. return nil
  204. }
  205. type EventNotification struct {
  206. OldEntry *Entry `protobuf:"bytes,1,opt,name=old_entry,json=oldEntry" json:"old_entry,omitempty"`
  207. NewEntry *Entry `protobuf:"bytes,2,opt,name=new_entry,json=newEntry" json:"new_entry,omitempty"`
  208. DeleteChunks bool `protobuf:"varint,3,opt,name=delete_chunks,json=deleteChunks" json:"delete_chunks,omitempty"`
  209. NewParentPath string `protobuf:"bytes,4,opt,name=new_parent_path,json=newParentPath" json:"new_parent_path,omitempty"`
  210. }
  211. func (m *EventNotification) Reset() { *m = EventNotification{} }
  212. func (m *EventNotification) String() string { return proto.CompactTextString(m) }
  213. func (*EventNotification) ProtoMessage() {}
  214. func (*EventNotification) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
  215. func (m *EventNotification) GetOldEntry() *Entry {
  216. if m != nil {
  217. return m.OldEntry
  218. }
  219. return nil
  220. }
  221. func (m *EventNotification) GetNewEntry() *Entry {
  222. if m != nil {
  223. return m.NewEntry
  224. }
  225. return nil
  226. }
  227. func (m *EventNotification) GetDeleteChunks() bool {
  228. if m != nil {
  229. return m.DeleteChunks
  230. }
  231. return false
  232. }
  233. func (m *EventNotification) GetNewParentPath() string {
  234. if m != nil {
  235. return m.NewParentPath
  236. }
  237. return ""
  238. }
  239. type FileChunk struct {
  240. FileId string `protobuf:"bytes,1,opt,name=file_id,json=fileId" json:"file_id,omitempty"`
  241. Offset int64 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
  242. Size uint64 `protobuf:"varint,3,opt,name=size" json:"size,omitempty"`
  243. Mtime int64 `protobuf:"varint,4,opt,name=mtime" json:"mtime,omitempty"`
  244. ETag string `protobuf:"bytes,5,opt,name=e_tag,json=eTag" json:"e_tag,omitempty"`
  245. SourceFileId string `protobuf:"bytes,6,opt,name=source_file_id,json=sourceFileId" json:"source_file_id,omitempty"`
  246. Fid *FileId `protobuf:"bytes,7,opt,name=fid" json:"fid,omitempty"`
  247. SourceFid *FileId `protobuf:"bytes,8,opt,name=source_fid,json=sourceFid" json:"source_fid,omitempty"`
  248. }
  249. func (m *FileChunk) Reset() { *m = FileChunk{} }
  250. func (m *FileChunk) String() string { return proto.CompactTextString(m) }
  251. func (*FileChunk) ProtoMessage() {}
  252. func (*FileChunk) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
  253. func (m *FileChunk) GetFileId() string {
  254. if m != nil {
  255. return m.FileId
  256. }
  257. return ""
  258. }
  259. func (m *FileChunk) GetOffset() int64 {
  260. if m != nil {
  261. return m.Offset
  262. }
  263. return 0
  264. }
  265. func (m *FileChunk) GetSize() uint64 {
  266. if m != nil {
  267. return m.Size
  268. }
  269. return 0
  270. }
  271. func (m *FileChunk) GetMtime() int64 {
  272. if m != nil {
  273. return m.Mtime
  274. }
  275. return 0
  276. }
  277. func (m *FileChunk) GetETag() string {
  278. if m != nil {
  279. return m.ETag
  280. }
  281. return ""
  282. }
  283. func (m *FileChunk) GetSourceFileId() string {
  284. if m != nil {
  285. return m.SourceFileId
  286. }
  287. return ""
  288. }
  289. func (m *FileChunk) GetFid() *FileId {
  290. if m != nil {
  291. return m.Fid
  292. }
  293. return nil
  294. }
  295. func (m *FileChunk) GetSourceFid() *FileId {
  296. if m != nil {
  297. return m.SourceFid
  298. }
  299. return nil
  300. }
  301. type FileId struct {
  302. VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
  303. FileKey uint64 `protobuf:"varint,2,opt,name=file_key,json=fileKey" json:"file_key,omitempty"`
  304. Cookie uint32 `protobuf:"fixed32,3,opt,name=cookie" json:"cookie,omitempty"`
  305. }
  306. func (m *FileId) Reset() { *m = FileId{} }
  307. func (m *FileId) String() string { return proto.CompactTextString(m) }
  308. func (*FileId) ProtoMessage() {}
  309. func (*FileId) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
  310. func (m *FileId) GetVolumeId() uint32 {
  311. if m != nil {
  312. return m.VolumeId
  313. }
  314. return 0
  315. }
  316. func (m *FileId) GetFileKey() uint64 {
  317. if m != nil {
  318. return m.FileKey
  319. }
  320. return 0
  321. }
  322. func (m *FileId) GetCookie() uint32 {
  323. if m != nil {
  324. return m.Cookie
  325. }
  326. return 0
  327. }
  328. type FuseAttributes struct {
  329. FileSize uint64 `protobuf:"varint,1,opt,name=file_size,json=fileSize" json:"file_size,omitempty"`
  330. Mtime int64 `protobuf:"varint,2,opt,name=mtime" json:"mtime,omitempty"`
  331. FileMode uint32 `protobuf:"varint,3,opt,name=file_mode,json=fileMode" json:"file_mode,omitempty"`
  332. Uid uint32 `protobuf:"varint,4,opt,name=uid" json:"uid,omitempty"`
  333. Gid uint32 `protobuf:"varint,5,opt,name=gid" json:"gid,omitempty"`
  334. Crtime int64 `protobuf:"varint,6,opt,name=crtime" json:"crtime,omitempty"`
  335. Mime string `protobuf:"bytes,7,opt,name=mime" json:"mime,omitempty"`
  336. Replication string `protobuf:"bytes,8,opt,name=replication" json:"replication,omitempty"`
  337. Collection string `protobuf:"bytes,9,opt,name=collection" json:"collection,omitempty"`
  338. TtlSec int32 `protobuf:"varint,10,opt,name=ttl_sec,json=ttlSec" json:"ttl_sec,omitempty"`
  339. UserName string `protobuf:"bytes,11,opt,name=user_name,json=userName" json:"user_name,omitempty"`
  340. GroupName []string `protobuf:"bytes,12,rep,name=group_name,json=groupName" json:"group_name,omitempty"`
  341. SymlinkTarget string `protobuf:"bytes,13,opt,name=symlink_target,json=symlinkTarget" json:"symlink_target,omitempty"`
  342. }
  343. func (m *FuseAttributes) Reset() { *m = FuseAttributes{} }
  344. func (m *FuseAttributes) String() string { return proto.CompactTextString(m) }
  345. func (*FuseAttributes) ProtoMessage() {}
  346. func (*FuseAttributes) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
  347. func (m *FuseAttributes) GetFileSize() uint64 {
  348. if m != nil {
  349. return m.FileSize
  350. }
  351. return 0
  352. }
  353. func (m *FuseAttributes) GetMtime() int64 {
  354. if m != nil {
  355. return m.Mtime
  356. }
  357. return 0
  358. }
  359. func (m *FuseAttributes) GetFileMode() uint32 {
  360. if m != nil {
  361. return m.FileMode
  362. }
  363. return 0
  364. }
  365. func (m *FuseAttributes) GetUid() uint32 {
  366. if m != nil {
  367. return m.Uid
  368. }
  369. return 0
  370. }
  371. func (m *FuseAttributes) GetGid() uint32 {
  372. if m != nil {
  373. return m.Gid
  374. }
  375. return 0
  376. }
  377. func (m *FuseAttributes) GetCrtime() int64 {
  378. if m != nil {
  379. return m.Crtime
  380. }
  381. return 0
  382. }
  383. func (m *FuseAttributes) GetMime() string {
  384. if m != nil {
  385. return m.Mime
  386. }
  387. return ""
  388. }
  389. func (m *FuseAttributes) GetReplication() string {
  390. if m != nil {
  391. return m.Replication
  392. }
  393. return ""
  394. }
  395. func (m *FuseAttributes) GetCollection() string {
  396. if m != nil {
  397. return m.Collection
  398. }
  399. return ""
  400. }
  401. func (m *FuseAttributes) GetTtlSec() int32 {
  402. if m != nil {
  403. return m.TtlSec
  404. }
  405. return 0
  406. }
  407. func (m *FuseAttributes) GetUserName() string {
  408. if m != nil {
  409. return m.UserName
  410. }
  411. return ""
  412. }
  413. func (m *FuseAttributes) GetGroupName() []string {
  414. if m != nil {
  415. return m.GroupName
  416. }
  417. return nil
  418. }
  419. func (m *FuseAttributes) GetSymlinkTarget() string {
  420. if m != nil {
  421. return m.SymlinkTarget
  422. }
  423. return ""
  424. }
  425. type CreateEntryRequest struct {
  426. Directory string `protobuf:"bytes,1,opt,name=directory" json:"directory,omitempty"`
  427. Entry *Entry `protobuf:"bytes,2,opt,name=entry" json:"entry,omitempty"`
  428. OExcl bool `protobuf:"varint,3,opt,name=o_excl,json=oExcl" json:"o_excl,omitempty"`
  429. }
  430. func (m *CreateEntryRequest) Reset() { *m = CreateEntryRequest{} }
  431. func (m *CreateEntryRequest) String() string { return proto.CompactTextString(m) }
  432. func (*CreateEntryRequest) ProtoMessage() {}
  433. func (*CreateEntryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
  434. func (m *CreateEntryRequest) GetDirectory() string {
  435. if m != nil {
  436. return m.Directory
  437. }
  438. return ""
  439. }
  440. func (m *CreateEntryRequest) GetEntry() *Entry {
  441. if m != nil {
  442. return m.Entry
  443. }
  444. return nil
  445. }
  446. func (m *CreateEntryRequest) GetOExcl() bool {
  447. if m != nil {
  448. return m.OExcl
  449. }
  450. return false
  451. }
  452. type CreateEntryResponse struct {
  453. Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
  454. }
  455. func (m *CreateEntryResponse) Reset() { *m = CreateEntryResponse{} }
  456. func (m *CreateEntryResponse) String() string { return proto.CompactTextString(m) }
  457. func (*CreateEntryResponse) ProtoMessage() {}
  458. func (*CreateEntryResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
  459. func (m *CreateEntryResponse) GetError() string {
  460. if m != nil {
  461. return m.Error
  462. }
  463. return ""
  464. }
  465. type UpdateEntryRequest struct {
  466. Directory string `protobuf:"bytes,1,opt,name=directory" json:"directory,omitempty"`
  467. Entry *Entry `protobuf:"bytes,2,opt,name=entry" json:"entry,omitempty"`
  468. }
  469. func (m *UpdateEntryRequest) Reset() { *m = UpdateEntryRequest{} }
  470. func (m *UpdateEntryRequest) String() string { return proto.CompactTextString(m) }
  471. func (*UpdateEntryRequest) ProtoMessage() {}
  472. func (*UpdateEntryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
  473. func (m *UpdateEntryRequest) GetDirectory() string {
  474. if m != nil {
  475. return m.Directory
  476. }
  477. return ""
  478. }
  479. func (m *UpdateEntryRequest) GetEntry() *Entry {
  480. if m != nil {
  481. return m.Entry
  482. }
  483. return nil
  484. }
  485. type UpdateEntryResponse struct {
  486. }
  487. func (m *UpdateEntryResponse) Reset() { *m = UpdateEntryResponse{} }
  488. func (m *UpdateEntryResponse) String() string { return proto.CompactTextString(m) }
  489. func (*UpdateEntryResponse) ProtoMessage() {}
  490. func (*UpdateEntryResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
  491. type DeleteEntryRequest struct {
  492. Directory string `protobuf:"bytes,1,opt,name=directory" json:"directory,omitempty"`
  493. Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
  494. // bool is_directory = 3;
  495. IsDeleteData bool `protobuf:"varint,4,opt,name=is_delete_data,json=isDeleteData" json:"is_delete_data,omitempty"`
  496. IsRecursive bool `protobuf:"varint,5,opt,name=is_recursive,json=isRecursive" json:"is_recursive,omitempty"`
  497. IgnoreRecursiveError bool `protobuf:"varint,6,opt,name=ignore_recursive_error,json=ignoreRecursiveError" json:"ignore_recursive_error,omitempty"`
  498. }
  499. func (m *DeleteEntryRequest) Reset() { *m = DeleteEntryRequest{} }
  500. func (m *DeleteEntryRequest) String() string { return proto.CompactTextString(m) }
  501. func (*DeleteEntryRequest) ProtoMessage() {}
  502. func (*DeleteEntryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
  503. func (m *DeleteEntryRequest) GetDirectory() string {
  504. if m != nil {
  505. return m.Directory
  506. }
  507. return ""
  508. }
  509. func (m *DeleteEntryRequest) GetName() string {
  510. if m != nil {
  511. return m.Name
  512. }
  513. return ""
  514. }
  515. func (m *DeleteEntryRequest) GetIsDeleteData() bool {
  516. if m != nil {
  517. return m.IsDeleteData
  518. }
  519. return false
  520. }
  521. func (m *DeleteEntryRequest) GetIsRecursive() bool {
  522. if m != nil {
  523. return m.IsRecursive
  524. }
  525. return false
  526. }
  527. func (m *DeleteEntryRequest) GetIgnoreRecursiveError() bool {
  528. if m != nil {
  529. return m.IgnoreRecursiveError
  530. }
  531. return false
  532. }
  533. type DeleteEntryResponse struct {
  534. Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
  535. }
  536. func (m *DeleteEntryResponse) Reset() { *m = DeleteEntryResponse{} }
  537. func (m *DeleteEntryResponse) String() string { return proto.CompactTextString(m) }
  538. func (*DeleteEntryResponse) ProtoMessage() {}
  539. func (*DeleteEntryResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
  540. func (m *DeleteEntryResponse) GetError() string {
  541. if m != nil {
  542. return m.Error
  543. }
  544. return ""
  545. }
  546. type AtomicRenameEntryRequest struct {
  547. OldDirectory string `protobuf:"bytes,1,opt,name=old_directory,json=oldDirectory" json:"old_directory,omitempty"`
  548. OldName string `protobuf:"bytes,2,opt,name=old_name,json=oldName" json:"old_name,omitempty"`
  549. NewDirectory string `protobuf:"bytes,3,opt,name=new_directory,json=newDirectory" json:"new_directory,omitempty"`
  550. NewName string `protobuf:"bytes,4,opt,name=new_name,json=newName" json:"new_name,omitempty"`
  551. }
  552. func (m *AtomicRenameEntryRequest) Reset() { *m = AtomicRenameEntryRequest{} }
  553. func (m *AtomicRenameEntryRequest) String() string { return proto.CompactTextString(m) }
  554. func (*AtomicRenameEntryRequest) ProtoMessage() {}
  555. func (*AtomicRenameEntryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
  556. func (m *AtomicRenameEntryRequest) GetOldDirectory() string {
  557. if m != nil {
  558. return m.OldDirectory
  559. }
  560. return ""
  561. }
  562. func (m *AtomicRenameEntryRequest) GetOldName() string {
  563. if m != nil {
  564. return m.OldName
  565. }
  566. return ""
  567. }
  568. func (m *AtomicRenameEntryRequest) GetNewDirectory() string {
  569. if m != nil {
  570. return m.NewDirectory
  571. }
  572. return ""
  573. }
  574. func (m *AtomicRenameEntryRequest) GetNewName() string {
  575. if m != nil {
  576. return m.NewName
  577. }
  578. return ""
  579. }
  580. type AtomicRenameEntryResponse struct {
  581. }
  582. func (m *AtomicRenameEntryResponse) Reset() { *m = AtomicRenameEntryResponse{} }
  583. func (m *AtomicRenameEntryResponse) String() string { return proto.CompactTextString(m) }
  584. func (*AtomicRenameEntryResponse) ProtoMessage() {}
  585. func (*AtomicRenameEntryResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} }
  586. type AssignVolumeRequest struct {
  587. Count int32 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
  588. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  589. Replication string `protobuf:"bytes,3,opt,name=replication" json:"replication,omitempty"`
  590. TtlSec int32 `protobuf:"varint,4,opt,name=ttl_sec,json=ttlSec" json:"ttl_sec,omitempty"`
  591. DataCenter string `protobuf:"bytes,5,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
  592. ParentPath string `protobuf:"bytes,6,opt,name=parent_path,json=parentPath" json:"parent_path,omitempty"`
  593. }
  594. func (m *AssignVolumeRequest) Reset() { *m = AssignVolumeRequest{} }
  595. func (m *AssignVolumeRequest) String() string { return proto.CompactTextString(m) }
  596. func (*AssignVolumeRequest) ProtoMessage() {}
  597. func (*AssignVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{18} }
  598. func (m *AssignVolumeRequest) GetCount() int32 {
  599. if m != nil {
  600. return m.Count
  601. }
  602. return 0
  603. }
  604. func (m *AssignVolumeRequest) GetCollection() string {
  605. if m != nil {
  606. return m.Collection
  607. }
  608. return ""
  609. }
  610. func (m *AssignVolumeRequest) GetReplication() string {
  611. if m != nil {
  612. return m.Replication
  613. }
  614. return ""
  615. }
  616. func (m *AssignVolumeRequest) GetTtlSec() int32 {
  617. if m != nil {
  618. return m.TtlSec
  619. }
  620. return 0
  621. }
  622. func (m *AssignVolumeRequest) GetDataCenter() string {
  623. if m != nil {
  624. return m.DataCenter
  625. }
  626. return ""
  627. }
  628. func (m *AssignVolumeRequest) GetParentPath() string {
  629. if m != nil {
  630. return m.ParentPath
  631. }
  632. return ""
  633. }
  634. type AssignVolumeResponse struct {
  635. FileId string `protobuf:"bytes,1,opt,name=file_id,json=fileId" json:"file_id,omitempty"`
  636. Url string `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
  637. PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  638. Count int32 `protobuf:"varint,4,opt,name=count" json:"count,omitempty"`
  639. Auth string `protobuf:"bytes,5,opt,name=auth" json:"auth,omitempty"`
  640. Collection string `protobuf:"bytes,6,opt,name=collection" json:"collection,omitempty"`
  641. Replication string `protobuf:"bytes,7,opt,name=replication" json:"replication,omitempty"`
  642. Error string `protobuf:"bytes,8,opt,name=error" json:"error,omitempty"`
  643. }
  644. func (m *AssignVolumeResponse) Reset() { *m = AssignVolumeResponse{} }
  645. func (m *AssignVolumeResponse) String() string { return proto.CompactTextString(m) }
  646. func (*AssignVolumeResponse) ProtoMessage() {}
  647. func (*AssignVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{19} }
  648. func (m *AssignVolumeResponse) GetFileId() string {
  649. if m != nil {
  650. return m.FileId
  651. }
  652. return ""
  653. }
  654. func (m *AssignVolumeResponse) GetUrl() string {
  655. if m != nil {
  656. return m.Url
  657. }
  658. return ""
  659. }
  660. func (m *AssignVolumeResponse) GetPublicUrl() string {
  661. if m != nil {
  662. return m.PublicUrl
  663. }
  664. return ""
  665. }
  666. func (m *AssignVolumeResponse) GetCount() int32 {
  667. if m != nil {
  668. return m.Count
  669. }
  670. return 0
  671. }
  672. func (m *AssignVolumeResponse) GetAuth() string {
  673. if m != nil {
  674. return m.Auth
  675. }
  676. return ""
  677. }
  678. func (m *AssignVolumeResponse) GetCollection() string {
  679. if m != nil {
  680. return m.Collection
  681. }
  682. return ""
  683. }
  684. func (m *AssignVolumeResponse) GetReplication() string {
  685. if m != nil {
  686. return m.Replication
  687. }
  688. return ""
  689. }
  690. func (m *AssignVolumeResponse) GetError() string {
  691. if m != nil {
  692. return m.Error
  693. }
  694. return ""
  695. }
  696. type LookupVolumeRequest struct {
  697. VolumeIds []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
  698. }
  699. func (m *LookupVolumeRequest) Reset() { *m = LookupVolumeRequest{} }
  700. func (m *LookupVolumeRequest) String() string { return proto.CompactTextString(m) }
  701. func (*LookupVolumeRequest) ProtoMessage() {}
  702. func (*LookupVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{20} }
  703. func (m *LookupVolumeRequest) GetVolumeIds() []string {
  704. if m != nil {
  705. return m.VolumeIds
  706. }
  707. return nil
  708. }
  709. type Locations struct {
  710. Locations []*Location `protobuf:"bytes,1,rep,name=locations" json:"locations,omitempty"`
  711. }
  712. func (m *Locations) Reset() { *m = Locations{} }
  713. func (m *Locations) String() string { return proto.CompactTextString(m) }
  714. func (*Locations) ProtoMessage() {}
  715. func (*Locations) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{21} }
  716. func (m *Locations) GetLocations() []*Location {
  717. if m != nil {
  718. return m.Locations
  719. }
  720. return nil
  721. }
  722. type Location struct {
  723. Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
  724. PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
  725. }
  726. func (m *Location) Reset() { *m = Location{} }
  727. func (m *Location) String() string { return proto.CompactTextString(m) }
  728. func (*Location) ProtoMessage() {}
  729. func (*Location) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{22} }
  730. func (m *Location) GetUrl() string {
  731. if m != nil {
  732. return m.Url
  733. }
  734. return ""
  735. }
  736. func (m *Location) GetPublicUrl() string {
  737. if m != nil {
  738. return m.PublicUrl
  739. }
  740. return ""
  741. }
  742. type LookupVolumeResponse struct {
  743. LocationsMap map[string]*Locations `protobuf:"bytes,1,rep,name=locations_map,json=locationsMap" json:"locations_map,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
  744. }
  745. func (m *LookupVolumeResponse) Reset() { *m = LookupVolumeResponse{} }
  746. func (m *LookupVolumeResponse) String() string { return proto.CompactTextString(m) }
  747. func (*LookupVolumeResponse) ProtoMessage() {}
  748. func (*LookupVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{23} }
  749. func (m *LookupVolumeResponse) GetLocationsMap() map[string]*Locations {
  750. if m != nil {
  751. return m.LocationsMap
  752. }
  753. return nil
  754. }
  755. type DeleteCollectionRequest struct {
  756. Collection string `protobuf:"bytes,1,opt,name=collection" json:"collection,omitempty"`
  757. }
  758. func (m *DeleteCollectionRequest) Reset() { *m = DeleteCollectionRequest{} }
  759. func (m *DeleteCollectionRequest) String() string { return proto.CompactTextString(m) }
  760. func (*DeleteCollectionRequest) ProtoMessage() {}
  761. func (*DeleteCollectionRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{24} }
  762. func (m *DeleteCollectionRequest) GetCollection() string {
  763. if m != nil {
  764. return m.Collection
  765. }
  766. return ""
  767. }
  768. type DeleteCollectionResponse struct {
  769. }
  770. func (m *DeleteCollectionResponse) Reset() { *m = DeleteCollectionResponse{} }
  771. func (m *DeleteCollectionResponse) String() string { return proto.CompactTextString(m) }
  772. func (*DeleteCollectionResponse) ProtoMessage() {}
  773. func (*DeleteCollectionResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{25} }
  774. type StatisticsRequest struct {
  775. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  776. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  777. Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
  778. }
  779. func (m *StatisticsRequest) Reset() { *m = StatisticsRequest{} }
  780. func (m *StatisticsRequest) String() string { return proto.CompactTextString(m) }
  781. func (*StatisticsRequest) ProtoMessage() {}
  782. func (*StatisticsRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{26} }
  783. func (m *StatisticsRequest) GetReplication() string {
  784. if m != nil {
  785. return m.Replication
  786. }
  787. return ""
  788. }
  789. func (m *StatisticsRequest) GetCollection() string {
  790. if m != nil {
  791. return m.Collection
  792. }
  793. return ""
  794. }
  795. func (m *StatisticsRequest) GetTtl() string {
  796. if m != nil {
  797. return m.Ttl
  798. }
  799. return ""
  800. }
  801. type StatisticsResponse struct {
  802. Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
  803. Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
  804. Ttl string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
  805. TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize" json:"total_size,omitempty"`
  806. UsedSize uint64 `protobuf:"varint,5,opt,name=used_size,json=usedSize" json:"used_size,omitempty"`
  807. FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
  808. }
  809. func (m *StatisticsResponse) Reset() { *m = StatisticsResponse{} }
  810. func (m *StatisticsResponse) String() string { return proto.CompactTextString(m) }
  811. func (*StatisticsResponse) ProtoMessage() {}
  812. func (*StatisticsResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{27} }
  813. func (m *StatisticsResponse) GetReplication() string {
  814. if m != nil {
  815. return m.Replication
  816. }
  817. return ""
  818. }
  819. func (m *StatisticsResponse) GetCollection() string {
  820. if m != nil {
  821. return m.Collection
  822. }
  823. return ""
  824. }
  825. func (m *StatisticsResponse) GetTtl() string {
  826. if m != nil {
  827. return m.Ttl
  828. }
  829. return ""
  830. }
  831. func (m *StatisticsResponse) GetTotalSize() uint64 {
  832. if m != nil {
  833. return m.TotalSize
  834. }
  835. return 0
  836. }
  837. func (m *StatisticsResponse) GetUsedSize() uint64 {
  838. if m != nil {
  839. return m.UsedSize
  840. }
  841. return 0
  842. }
  843. func (m *StatisticsResponse) GetFileCount() uint64 {
  844. if m != nil {
  845. return m.FileCount
  846. }
  847. return 0
  848. }
  849. type GetFilerConfigurationRequest struct {
  850. }
  851. func (m *GetFilerConfigurationRequest) Reset() { *m = GetFilerConfigurationRequest{} }
  852. func (m *GetFilerConfigurationRequest) String() string { return proto.CompactTextString(m) }
  853. func (*GetFilerConfigurationRequest) ProtoMessage() {}
  854. func (*GetFilerConfigurationRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{28} }
  855. type GetFilerConfigurationResponse struct {
  856. Masters []string `protobuf:"bytes,1,rep,name=masters" json:"masters,omitempty"`
  857. Replication string `protobuf:"bytes,2,opt,name=replication" json:"replication,omitempty"`
  858. Collection string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
  859. MaxMb uint32 `protobuf:"varint,4,opt,name=max_mb,json=maxMb" json:"max_mb,omitempty"`
  860. DirBuckets string `protobuf:"bytes,5,opt,name=dir_buckets,json=dirBuckets" json:"dir_buckets,omitempty"`
  861. }
  862. func (m *GetFilerConfigurationResponse) Reset() { *m = GetFilerConfigurationResponse{} }
  863. func (m *GetFilerConfigurationResponse) String() string { return proto.CompactTextString(m) }
  864. func (*GetFilerConfigurationResponse) ProtoMessage() {}
  865. func (*GetFilerConfigurationResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{29} }
  866. func (m *GetFilerConfigurationResponse) GetMasters() []string {
  867. if m != nil {
  868. return m.Masters
  869. }
  870. return nil
  871. }
  872. func (m *GetFilerConfigurationResponse) GetReplication() string {
  873. if m != nil {
  874. return m.Replication
  875. }
  876. return ""
  877. }
  878. func (m *GetFilerConfigurationResponse) GetCollection() string {
  879. if m != nil {
  880. return m.Collection
  881. }
  882. return ""
  883. }
  884. func (m *GetFilerConfigurationResponse) GetMaxMb() uint32 {
  885. if m != nil {
  886. return m.MaxMb
  887. }
  888. return 0
  889. }
  890. func (m *GetFilerConfigurationResponse) GetDirBuckets() string {
  891. if m != nil {
  892. return m.DirBuckets
  893. }
  894. return ""
  895. }
  896. func init() {
  897. proto.RegisterType((*LookupDirectoryEntryRequest)(nil), "filer_pb.LookupDirectoryEntryRequest")
  898. proto.RegisterType((*LookupDirectoryEntryResponse)(nil), "filer_pb.LookupDirectoryEntryResponse")
  899. proto.RegisterType((*ListEntriesRequest)(nil), "filer_pb.ListEntriesRequest")
  900. proto.RegisterType((*ListEntriesResponse)(nil), "filer_pb.ListEntriesResponse")
  901. proto.RegisterType((*Entry)(nil), "filer_pb.Entry")
  902. proto.RegisterType((*FullEntry)(nil), "filer_pb.FullEntry")
  903. proto.RegisterType((*EventNotification)(nil), "filer_pb.EventNotification")
  904. proto.RegisterType((*FileChunk)(nil), "filer_pb.FileChunk")
  905. proto.RegisterType((*FileId)(nil), "filer_pb.FileId")
  906. proto.RegisterType((*FuseAttributes)(nil), "filer_pb.FuseAttributes")
  907. proto.RegisterType((*CreateEntryRequest)(nil), "filer_pb.CreateEntryRequest")
  908. proto.RegisterType((*CreateEntryResponse)(nil), "filer_pb.CreateEntryResponse")
  909. proto.RegisterType((*UpdateEntryRequest)(nil), "filer_pb.UpdateEntryRequest")
  910. proto.RegisterType((*UpdateEntryResponse)(nil), "filer_pb.UpdateEntryResponse")
  911. proto.RegisterType((*DeleteEntryRequest)(nil), "filer_pb.DeleteEntryRequest")
  912. proto.RegisterType((*DeleteEntryResponse)(nil), "filer_pb.DeleteEntryResponse")
  913. proto.RegisterType((*AtomicRenameEntryRequest)(nil), "filer_pb.AtomicRenameEntryRequest")
  914. proto.RegisterType((*AtomicRenameEntryResponse)(nil), "filer_pb.AtomicRenameEntryResponse")
  915. proto.RegisterType((*AssignVolumeRequest)(nil), "filer_pb.AssignVolumeRequest")
  916. proto.RegisterType((*AssignVolumeResponse)(nil), "filer_pb.AssignVolumeResponse")
  917. proto.RegisterType((*LookupVolumeRequest)(nil), "filer_pb.LookupVolumeRequest")
  918. proto.RegisterType((*Locations)(nil), "filer_pb.Locations")
  919. proto.RegisterType((*Location)(nil), "filer_pb.Location")
  920. proto.RegisterType((*LookupVolumeResponse)(nil), "filer_pb.LookupVolumeResponse")
  921. proto.RegisterType((*DeleteCollectionRequest)(nil), "filer_pb.DeleteCollectionRequest")
  922. proto.RegisterType((*DeleteCollectionResponse)(nil), "filer_pb.DeleteCollectionResponse")
  923. proto.RegisterType((*StatisticsRequest)(nil), "filer_pb.StatisticsRequest")
  924. proto.RegisterType((*StatisticsResponse)(nil), "filer_pb.StatisticsResponse")
  925. proto.RegisterType((*GetFilerConfigurationRequest)(nil), "filer_pb.GetFilerConfigurationRequest")
  926. proto.RegisterType((*GetFilerConfigurationResponse)(nil), "filer_pb.GetFilerConfigurationResponse")
  927. }
  928. // Reference imports to suppress errors if they are not otherwise used.
  929. var _ context.Context
  930. var _ grpc.ClientConn
  931. // This is a compile-time assertion to ensure that this generated file
  932. // is compatible with the grpc package it is being compiled against.
  933. const _ = grpc.SupportPackageIsVersion4
  934. // Client API for SeaweedFiler service
  935. type SeaweedFilerClient interface {
  936. LookupDirectoryEntry(ctx context.Context, in *LookupDirectoryEntryRequest, opts ...grpc.CallOption) (*LookupDirectoryEntryResponse, error)
  937. ListEntries(ctx context.Context, in *ListEntriesRequest, opts ...grpc.CallOption) (SeaweedFiler_ListEntriesClient, error)
  938. CreateEntry(ctx context.Context, in *CreateEntryRequest, opts ...grpc.CallOption) (*CreateEntryResponse, error)
  939. UpdateEntry(ctx context.Context, in *UpdateEntryRequest, opts ...grpc.CallOption) (*UpdateEntryResponse, error)
  940. DeleteEntry(ctx context.Context, in *DeleteEntryRequest, opts ...grpc.CallOption) (*DeleteEntryResponse, error)
  941. StreamDeleteEntries(ctx context.Context, opts ...grpc.CallOption) (SeaweedFiler_StreamDeleteEntriesClient, error)
  942. AtomicRenameEntry(ctx context.Context, in *AtomicRenameEntryRequest, opts ...grpc.CallOption) (*AtomicRenameEntryResponse, error)
  943. AssignVolume(ctx context.Context, in *AssignVolumeRequest, opts ...grpc.CallOption) (*AssignVolumeResponse, error)
  944. LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error)
  945. DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
  946. Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
  947. GetFilerConfiguration(ctx context.Context, in *GetFilerConfigurationRequest, opts ...grpc.CallOption) (*GetFilerConfigurationResponse, error)
  948. }
  949. type seaweedFilerClient struct {
  950. cc *grpc.ClientConn
  951. }
  952. func NewSeaweedFilerClient(cc *grpc.ClientConn) SeaweedFilerClient {
  953. return &seaweedFilerClient{cc}
  954. }
  955. func (c *seaweedFilerClient) LookupDirectoryEntry(ctx context.Context, in *LookupDirectoryEntryRequest, opts ...grpc.CallOption) (*LookupDirectoryEntryResponse, error) {
  956. out := new(LookupDirectoryEntryResponse)
  957. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/LookupDirectoryEntry", in, out, c.cc, opts...)
  958. if err != nil {
  959. return nil, err
  960. }
  961. return out, nil
  962. }
  963. func (c *seaweedFilerClient) ListEntries(ctx context.Context, in *ListEntriesRequest, opts ...grpc.CallOption) (SeaweedFiler_ListEntriesClient, error) {
  964. stream, err := grpc.NewClientStream(ctx, &_SeaweedFiler_serviceDesc.Streams[0], c.cc, "/filer_pb.SeaweedFiler/ListEntries", opts...)
  965. if err != nil {
  966. return nil, err
  967. }
  968. x := &seaweedFilerListEntriesClient{stream}
  969. if err := x.ClientStream.SendMsg(in); err != nil {
  970. return nil, err
  971. }
  972. if err := x.ClientStream.CloseSend(); err != nil {
  973. return nil, err
  974. }
  975. return x, nil
  976. }
  977. type SeaweedFiler_ListEntriesClient interface {
  978. Recv() (*ListEntriesResponse, error)
  979. grpc.ClientStream
  980. }
  981. type seaweedFilerListEntriesClient struct {
  982. grpc.ClientStream
  983. }
  984. func (x *seaweedFilerListEntriesClient) Recv() (*ListEntriesResponse, error) {
  985. m := new(ListEntriesResponse)
  986. if err := x.ClientStream.RecvMsg(m); err != nil {
  987. return nil, err
  988. }
  989. return m, nil
  990. }
  991. func (c *seaweedFilerClient) CreateEntry(ctx context.Context, in *CreateEntryRequest, opts ...grpc.CallOption) (*CreateEntryResponse, error) {
  992. out := new(CreateEntryResponse)
  993. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/CreateEntry", in, out, c.cc, opts...)
  994. if err != nil {
  995. return nil, err
  996. }
  997. return out, nil
  998. }
  999. func (c *seaweedFilerClient) UpdateEntry(ctx context.Context, in *UpdateEntryRequest, opts ...grpc.CallOption) (*UpdateEntryResponse, error) {
  1000. out := new(UpdateEntryResponse)
  1001. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/UpdateEntry", in, out, c.cc, opts...)
  1002. if err != nil {
  1003. return nil, err
  1004. }
  1005. return out, nil
  1006. }
  1007. func (c *seaweedFilerClient) DeleteEntry(ctx context.Context, in *DeleteEntryRequest, opts ...grpc.CallOption) (*DeleteEntryResponse, error) {
  1008. out := new(DeleteEntryResponse)
  1009. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/DeleteEntry", in, out, c.cc, opts...)
  1010. if err != nil {
  1011. return nil, err
  1012. }
  1013. return out, nil
  1014. }
  1015. func (c *seaweedFilerClient) StreamDeleteEntries(ctx context.Context, opts ...grpc.CallOption) (SeaweedFiler_StreamDeleteEntriesClient, error) {
  1016. stream, err := grpc.NewClientStream(ctx, &_SeaweedFiler_serviceDesc.Streams[1], c.cc, "/filer_pb.SeaweedFiler/StreamDeleteEntries", opts...)
  1017. if err != nil {
  1018. return nil, err
  1019. }
  1020. x := &seaweedFilerStreamDeleteEntriesClient{stream}
  1021. return x, nil
  1022. }
  1023. type SeaweedFiler_StreamDeleteEntriesClient interface {
  1024. Send(*DeleteEntryRequest) error
  1025. Recv() (*DeleteEntryResponse, error)
  1026. grpc.ClientStream
  1027. }
  1028. type seaweedFilerStreamDeleteEntriesClient struct {
  1029. grpc.ClientStream
  1030. }
  1031. func (x *seaweedFilerStreamDeleteEntriesClient) Send(m *DeleteEntryRequest) error {
  1032. return x.ClientStream.SendMsg(m)
  1033. }
  1034. func (x *seaweedFilerStreamDeleteEntriesClient) Recv() (*DeleteEntryResponse, error) {
  1035. m := new(DeleteEntryResponse)
  1036. if err := x.ClientStream.RecvMsg(m); err != nil {
  1037. return nil, err
  1038. }
  1039. return m, nil
  1040. }
  1041. func (c *seaweedFilerClient) AtomicRenameEntry(ctx context.Context, in *AtomicRenameEntryRequest, opts ...grpc.CallOption) (*AtomicRenameEntryResponse, error) {
  1042. out := new(AtomicRenameEntryResponse)
  1043. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/AtomicRenameEntry", in, out, c.cc, opts...)
  1044. if err != nil {
  1045. return nil, err
  1046. }
  1047. return out, nil
  1048. }
  1049. func (c *seaweedFilerClient) AssignVolume(ctx context.Context, in *AssignVolumeRequest, opts ...grpc.CallOption) (*AssignVolumeResponse, error) {
  1050. out := new(AssignVolumeResponse)
  1051. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/AssignVolume", in, out, c.cc, opts...)
  1052. if err != nil {
  1053. return nil, err
  1054. }
  1055. return out, nil
  1056. }
  1057. func (c *seaweedFilerClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) {
  1058. out := new(LookupVolumeResponse)
  1059. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/LookupVolume", in, out, c.cc, opts...)
  1060. if err != nil {
  1061. return nil, err
  1062. }
  1063. return out, nil
  1064. }
  1065. func (c *seaweedFilerClient) DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error) {
  1066. out := new(DeleteCollectionResponse)
  1067. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/DeleteCollection", in, out, c.cc, opts...)
  1068. if err != nil {
  1069. return nil, err
  1070. }
  1071. return out, nil
  1072. }
  1073. func (c *seaweedFilerClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) {
  1074. out := new(StatisticsResponse)
  1075. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/Statistics", in, out, c.cc, opts...)
  1076. if err != nil {
  1077. return nil, err
  1078. }
  1079. return out, nil
  1080. }
  1081. func (c *seaweedFilerClient) GetFilerConfiguration(ctx context.Context, in *GetFilerConfigurationRequest, opts ...grpc.CallOption) (*GetFilerConfigurationResponse, error) {
  1082. out := new(GetFilerConfigurationResponse)
  1083. err := grpc.Invoke(ctx, "/filer_pb.SeaweedFiler/GetFilerConfiguration", in, out, c.cc, opts...)
  1084. if err != nil {
  1085. return nil, err
  1086. }
  1087. return out, nil
  1088. }
  1089. // Server API for SeaweedFiler service
  1090. type SeaweedFilerServer interface {
  1091. LookupDirectoryEntry(context.Context, *LookupDirectoryEntryRequest) (*LookupDirectoryEntryResponse, error)
  1092. ListEntries(*ListEntriesRequest, SeaweedFiler_ListEntriesServer) error
  1093. CreateEntry(context.Context, *CreateEntryRequest) (*CreateEntryResponse, error)
  1094. UpdateEntry(context.Context, *UpdateEntryRequest) (*UpdateEntryResponse, error)
  1095. DeleteEntry(context.Context, *DeleteEntryRequest) (*DeleteEntryResponse, error)
  1096. StreamDeleteEntries(SeaweedFiler_StreamDeleteEntriesServer) error
  1097. AtomicRenameEntry(context.Context, *AtomicRenameEntryRequest) (*AtomicRenameEntryResponse, error)
  1098. AssignVolume(context.Context, *AssignVolumeRequest) (*AssignVolumeResponse, error)
  1099. LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
  1100. DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
  1101. Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
  1102. GetFilerConfiguration(context.Context, *GetFilerConfigurationRequest) (*GetFilerConfigurationResponse, error)
  1103. }
  1104. func RegisterSeaweedFilerServer(s *grpc.Server, srv SeaweedFilerServer) {
  1105. s.RegisterService(&_SeaweedFiler_serviceDesc, srv)
  1106. }
  1107. func _SeaweedFiler_LookupDirectoryEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1108. in := new(LookupDirectoryEntryRequest)
  1109. if err := dec(in); err != nil {
  1110. return nil, err
  1111. }
  1112. if interceptor == nil {
  1113. return srv.(SeaweedFilerServer).LookupDirectoryEntry(ctx, in)
  1114. }
  1115. info := &grpc.UnaryServerInfo{
  1116. Server: srv,
  1117. FullMethod: "/filer_pb.SeaweedFiler/LookupDirectoryEntry",
  1118. }
  1119. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1120. return srv.(SeaweedFilerServer).LookupDirectoryEntry(ctx, req.(*LookupDirectoryEntryRequest))
  1121. }
  1122. return interceptor(ctx, in, info, handler)
  1123. }
  1124. func _SeaweedFiler_ListEntries_Handler(srv interface{}, stream grpc.ServerStream) error {
  1125. m := new(ListEntriesRequest)
  1126. if err := stream.RecvMsg(m); err != nil {
  1127. return err
  1128. }
  1129. return srv.(SeaweedFilerServer).ListEntries(m, &seaweedFilerListEntriesServer{stream})
  1130. }
  1131. type SeaweedFiler_ListEntriesServer interface {
  1132. Send(*ListEntriesResponse) error
  1133. grpc.ServerStream
  1134. }
  1135. type seaweedFilerListEntriesServer struct {
  1136. grpc.ServerStream
  1137. }
  1138. func (x *seaweedFilerListEntriesServer) Send(m *ListEntriesResponse) error {
  1139. return x.ServerStream.SendMsg(m)
  1140. }
  1141. func _SeaweedFiler_CreateEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1142. in := new(CreateEntryRequest)
  1143. if err := dec(in); err != nil {
  1144. return nil, err
  1145. }
  1146. if interceptor == nil {
  1147. return srv.(SeaweedFilerServer).CreateEntry(ctx, in)
  1148. }
  1149. info := &grpc.UnaryServerInfo{
  1150. Server: srv,
  1151. FullMethod: "/filer_pb.SeaweedFiler/CreateEntry",
  1152. }
  1153. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1154. return srv.(SeaweedFilerServer).CreateEntry(ctx, req.(*CreateEntryRequest))
  1155. }
  1156. return interceptor(ctx, in, info, handler)
  1157. }
  1158. func _SeaweedFiler_UpdateEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1159. in := new(UpdateEntryRequest)
  1160. if err := dec(in); err != nil {
  1161. return nil, err
  1162. }
  1163. if interceptor == nil {
  1164. return srv.(SeaweedFilerServer).UpdateEntry(ctx, in)
  1165. }
  1166. info := &grpc.UnaryServerInfo{
  1167. Server: srv,
  1168. FullMethod: "/filer_pb.SeaweedFiler/UpdateEntry",
  1169. }
  1170. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1171. return srv.(SeaweedFilerServer).UpdateEntry(ctx, req.(*UpdateEntryRequest))
  1172. }
  1173. return interceptor(ctx, in, info, handler)
  1174. }
  1175. func _SeaweedFiler_DeleteEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1176. in := new(DeleteEntryRequest)
  1177. if err := dec(in); err != nil {
  1178. return nil, err
  1179. }
  1180. if interceptor == nil {
  1181. return srv.(SeaweedFilerServer).DeleteEntry(ctx, in)
  1182. }
  1183. info := &grpc.UnaryServerInfo{
  1184. Server: srv,
  1185. FullMethod: "/filer_pb.SeaweedFiler/DeleteEntry",
  1186. }
  1187. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1188. return srv.(SeaweedFilerServer).DeleteEntry(ctx, req.(*DeleteEntryRequest))
  1189. }
  1190. return interceptor(ctx, in, info, handler)
  1191. }
  1192. func _SeaweedFiler_StreamDeleteEntries_Handler(srv interface{}, stream grpc.ServerStream) error {
  1193. return srv.(SeaweedFilerServer).StreamDeleteEntries(&seaweedFilerStreamDeleteEntriesServer{stream})
  1194. }
  1195. type SeaweedFiler_StreamDeleteEntriesServer interface {
  1196. Send(*DeleteEntryResponse) error
  1197. Recv() (*DeleteEntryRequest, error)
  1198. grpc.ServerStream
  1199. }
  1200. type seaweedFilerStreamDeleteEntriesServer struct {
  1201. grpc.ServerStream
  1202. }
  1203. func (x *seaweedFilerStreamDeleteEntriesServer) Send(m *DeleteEntryResponse) error {
  1204. return x.ServerStream.SendMsg(m)
  1205. }
  1206. func (x *seaweedFilerStreamDeleteEntriesServer) Recv() (*DeleteEntryRequest, error) {
  1207. m := new(DeleteEntryRequest)
  1208. if err := x.ServerStream.RecvMsg(m); err != nil {
  1209. return nil, err
  1210. }
  1211. return m, nil
  1212. }
  1213. func _SeaweedFiler_AtomicRenameEntry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1214. in := new(AtomicRenameEntryRequest)
  1215. if err := dec(in); err != nil {
  1216. return nil, err
  1217. }
  1218. if interceptor == nil {
  1219. return srv.(SeaweedFilerServer).AtomicRenameEntry(ctx, in)
  1220. }
  1221. info := &grpc.UnaryServerInfo{
  1222. Server: srv,
  1223. FullMethod: "/filer_pb.SeaweedFiler/AtomicRenameEntry",
  1224. }
  1225. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1226. return srv.(SeaweedFilerServer).AtomicRenameEntry(ctx, req.(*AtomicRenameEntryRequest))
  1227. }
  1228. return interceptor(ctx, in, info, handler)
  1229. }
  1230. func _SeaweedFiler_AssignVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1231. in := new(AssignVolumeRequest)
  1232. if err := dec(in); err != nil {
  1233. return nil, err
  1234. }
  1235. if interceptor == nil {
  1236. return srv.(SeaweedFilerServer).AssignVolume(ctx, in)
  1237. }
  1238. info := &grpc.UnaryServerInfo{
  1239. Server: srv,
  1240. FullMethod: "/filer_pb.SeaweedFiler/AssignVolume",
  1241. }
  1242. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1243. return srv.(SeaweedFilerServer).AssignVolume(ctx, req.(*AssignVolumeRequest))
  1244. }
  1245. return interceptor(ctx, in, info, handler)
  1246. }
  1247. func _SeaweedFiler_LookupVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1248. in := new(LookupVolumeRequest)
  1249. if err := dec(in); err != nil {
  1250. return nil, err
  1251. }
  1252. if interceptor == nil {
  1253. return srv.(SeaweedFilerServer).LookupVolume(ctx, in)
  1254. }
  1255. info := &grpc.UnaryServerInfo{
  1256. Server: srv,
  1257. FullMethod: "/filer_pb.SeaweedFiler/LookupVolume",
  1258. }
  1259. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1260. return srv.(SeaweedFilerServer).LookupVolume(ctx, req.(*LookupVolumeRequest))
  1261. }
  1262. return interceptor(ctx, in, info, handler)
  1263. }
  1264. func _SeaweedFiler_DeleteCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1265. in := new(DeleteCollectionRequest)
  1266. if err := dec(in); err != nil {
  1267. return nil, err
  1268. }
  1269. if interceptor == nil {
  1270. return srv.(SeaweedFilerServer).DeleteCollection(ctx, in)
  1271. }
  1272. info := &grpc.UnaryServerInfo{
  1273. Server: srv,
  1274. FullMethod: "/filer_pb.SeaweedFiler/DeleteCollection",
  1275. }
  1276. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1277. return srv.(SeaweedFilerServer).DeleteCollection(ctx, req.(*DeleteCollectionRequest))
  1278. }
  1279. return interceptor(ctx, in, info, handler)
  1280. }
  1281. func _SeaweedFiler_Statistics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1282. in := new(StatisticsRequest)
  1283. if err := dec(in); err != nil {
  1284. return nil, err
  1285. }
  1286. if interceptor == nil {
  1287. return srv.(SeaweedFilerServer).Statistics(ctx, in)
  1288. }
  1289. info := &grpc.UnaryServerInfo{
  1290. Server: srv,
  1291. FullMethod: "/filer_pb.SeaweedFiler/Statistics",
  1292. }
  1293. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1294. return srv.(SeaweedFilerServer).Statistics(ctx, req.(*StatisticsRequest))
  1295. }
  1296. return interceptor(ctx, in, info, handler)
  1297. }
  1298. func _SeaweedFiler_GetFilerConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1299. in := new(GetFilerConfigurationRequest)
  1300. if err := dec(in); err != nil {
  1301. return nil, err
  1302. }
  1303. if interceptor == nil {
  1304. return srv.(SeaweedFilerServer).GetFilerConfiguration(ctx, in)
  1305. }
  1306. info := &grpc.UnaryServerInfo{
  1307. Server: srv,
  1308. FullMethod: "/filer_pb.SeaweedFiler/GetFilerConfiguration",
  1309. }
  1310. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1311. return srv.(SeaweedFilerServer).GetFilerConfiguration(ctx, req.(*GetFilerConfigurationRequest))
  1312. }
  1313. return interceptor(ctx, in, info, handler)
  1314. }
  1315. var _SeaweedFiler_serviceDesc = grpc.ServiceDesc{
  1316. ServiceName: "filer_pb.SeaweedFiler",
  1317. HandlerType: (*SeaweedFilerServer)(nil),
  1318. Methods: []grpc.MethodDesc{
  1319. {
  1320. MethodName: "LookupDirectoryEntry",
  1321. Handler: _SeaweedFiler_LookupDirectoryEntry_Handler,
  1322. },
  1323. {
  1324. MethodName: "CreateEntry",
  1325. Handler: _SeaweedFiler_CreateEntry_Handler,
  1326. },
  1327. {
  1328. MethodName: "UpdateEntry",
  1329. Handler: _SeaweedFiler_UpdateEntry_Handler,
  1330. },
  1331. {
  1332. MethodName: "DeleteEntry",
  1333. Handler: _SeaweedFiler_DeleteEntry_Handler,
  1334. },
  1335. {
  1336. MethodName: "AtomicRenameEntry",
  1337. Handler: _SeaweedFiler_AtomicRenameEntry_Handler,
  1338. },
  1339. {
  1340. MethodName: "AssignVolume",
  1341. Handler: _SeaweedFiler_AssignVolume_Handler,
  1342. },
  1343. {
  1344. MethodName: "LookupVolume",
  1345. Handler: _SeaweedFiler_LookupVolume_Handler,
  1346. },
  1347. {
  1348. MethodName: "DeleteCollection",
  1349. Handler: _SeaweedFiler_DeleteCollection_Handler,
  1350. },
  1351. {
  1352. MethodName: "Statistics",
  1353. Handler: _SeaweedFiler_Statistics_Handler,
  1354. },
  1355. {
  1356. MethodName: "GetFilerConfiguration",
  1357. Handler: _SeaweedFiler_GetFilerConfiguration_Handler,
  1358. },
  1359. },
  1360. Streams: []grpc.StreamDesc{
  1361. {
  1362. StreamName: "ListEntries",
  1363. Handler: _SeaweedFiler_ListEntries_Handler,
  1364. ServerStreams: true,
  1365. },
  1366. {
  1367. StreamName: "StreamDeleteEntries",
  1368. Handler: _SeaweedFiler_StreamDeleteEntries_Handler,
  1369. ServerStreams: true,
  1370. ClientStreams: true,
  1371. },
  1372. },
  1373. Metadata: "filer.proto",
  1374. }
  1375. func init() { proto.RegisterFile("filer.proto", fileDescriptor0) }
  1376. var fileDescriptor0 = []byte{
  1377. // 1697 bytes of a gzipped FileDescriptorProto
  1378. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xb4, 0x58, 0xdb, 0x6e, 0xdb, 0xc8,
  1379. 0x19, 0x36, 0x75, 0xe6, 0x2f, 0x29, 0xb1, 0x47, 0x76, 0xa2, 0xc8, 0x87, 0x3a, 0x74, 0x93, 0xba,
  1380. 0x48, 0xe0, 0x1a, 0x6e, 0x2e, 0x92, 0xa6, 0xbd, 0x48, 0x7c, 0x28, 0x8c, 0x3a, 0x07, 0xd0, 0x49,
  1381. 0x91, 0xa2, 0x40, 0x09, 0x9a, 0x1c, 0xc9, 0x53, 0x93, 0x1c, 0x75, 0x38, 0xb4, 0x9d, 0x3e, 0x4a,
  1382. 0x81, 0x5e, 0xf4, 0x19, 0x7a, 0xbb, 0xd8, 0x9b, 0xc5, 0x02, 0xfb, 0x1c, 0xfb, 0x00, 0x7b, 0xb9,
  1383. 0xd7, 0x8b, 0x99, 0x21, 0xa9, 0xa1, 0x28, 0xdb, 0xc9, 0x2e, 0x72, 0xc7, 0xf9, 0x4f, 0xf3, 0xcf,
  1384. 0xf7, 0x1f, 0x25, 0x68, 0x0f, 0x49, 0x80, 0xd9, 0xd6, 0x98, 0x51, 0x4e, 0x51, 0x4b, 0x1e, 0x9c,
  1385. 0xf1, 0x89, 0xf5, 0x06, 0x96, 0x8f, 0x28, 0x3d, 0x4b, 0xc6, 0x7b, 0x84, 0x61, 0x8f, 0x53, 0xf6,
  1386. 0x71, 0x3f, 0xe2, 0xec, 0xa3, 0x8d, 0xff, 0x95, 0xe0, 0x98, 0xa3, 0x15, 0x30, 0xfd, 0x8c, 0xd1,
  1387. 0x37, 0xd6, 0x8d, 0x4d, 0xd3, 0x9e, 0x10, 0x10, 0x82, 0x5a, 0xe4, 0x86, 0xb8, 0x5f, 0x91, 0x0c,
  1388. 0xf9, 0x6d, 0xed, 0xc3, 0xca, 0x6c, 0x83, 0xf1, 0x98, 0x46, 0x31, 0x46, 0x0f, 0xa0, 0x8e, 0x05,
  1389. 0x41, 0x5a, 0x6b, 0xef, 0xdc, 0xde, 0xca, 0x5c, 0xd9, 0x52, 0x72, 0x8a, 0x6b, 0x7d, 0x6d, 0x00,
  1390. 0x3a, 0x22, 0x31, 0x17, 0x44, 0x82, 0xe3, 0x4f, 0xf3, 0xe7, 0x0e, 0x34, 0xc6, 0x0c, 0x0f, 0xc9,
  1391. 0x65, 0xea, 0x51, 0x7a, 0x42, 0x8f, 0x61, 0x21, 0xe6, 0x2e, 0xe3, 0x07, 0x8c, 0x86, 0x07, 0x24,
  1392. 0xc0, 0xaf, 0x85, 0xd3, 0x55, 0x29, 0x52, 0x66, 0xa0, 0x2d, 0x40, 0x24, 0xf2, 0x82, 0x24, 0x26,
  1393. 0xe7, 0xf8, 0x38, 0xe3, 0xf6, 0x6b, 0xeb, 0xc6, 0x66, 0xcb, 0x9e, 0xc1, 0x41, 0x8b, 0x50, 0x0f,
  1394. 0x48, 0x48, 0x78, 0xbf, 0xbe, 0x6e, 0x6c, 0x76, 0x6d, 0x75, 0xb0, 0xfe, 0x08, 0xbd, 0x82, 0xff,
  1395. 0x9f, 0xf7, 0xfc, 0xff, 0x56, 0xa0, 0x2e, 0x09, 0x39, 0xc6, 0xc6, 0x04, 0x63, 0x74, 0x1f, 0x3a,
  1396. 0x24, 0x76, 0x26, 0x40, 0x54, 0xa4, 0x6f, 0x6d, 0x12, 0xe7, 0x98, 0xa3, 0x47, 0xd0, 0xf0, 0x4e,
  1397. 0x93, 0xe8, 0x2c, 0xee, 0x57, 0xd7, 0xab, 0x9b, 0xed, 0x9d, 0xde, 0xe4, 0x22, 0xf1, 0xd0, 0x5d,
  1398. 0xc1, 0xb3, 0x53, 0x11, 0xf4, 0x14, 0xc0, 0xe5, 0x9c, 0x91, 0x93, 0x84, 0xe3, 0x58, 0xbe, 0xb4,
  1399. 0xbd, 0xd3, 0xd7, 0x14, 0x92, 0x18, 0xbf, 0xc8, 0xf9, 0xb6, 0x26, 0x8b, 0x9e, 0x41, 0x0b, 0x5f,
  1400. 0x72, 0x1c, 0xf9, 0xd8, 0xef, 0xd7, 0xe5, 0x45, 0xab, 0x53, 0x2f, 0xda, 0xda, 0x4f, 0xf9, 0xea,
  1401. 0x7d, 0xb9, 0xf8, 0xe0, 0x39, 0x74, 0x0b, 0x2c, 0x34, 0x0f, 0xd5, 0x33, 0x9c, 0x45, 0x55, 0x7c,
  1402. 0x0a, 0x64, 0xcf, 0xdd, 0x20, 0x51, 0x09, 0xd6, 0xb1, 0xd5, 0xe1, 0x0f, 0x95, 0xa7, 0x86, 0xb5,
  1403. 0x07, 0xe6, 0x41, 0x12, 0x04, 0xb9, 0xa2, 0x4f, 0x58, 0xa6, 0xe8, 0x13, 0x36, 0x41, 0xb9, 0x72,
  1404. 0x2d, 0xca, 0x5f, 0x19, 0xb0, 0xb0, 0x7f, 0x8e, 0x23, 0xfe, 0x9a, 0x72, 0x32, 0x24, 0x9e, 0xcb,
  1405. 0x09, 0x8d, 0xd0, 0x63, 0x30, 0x69, 0xe0, 0x3b, 0xd7, 0x86, 0xa9, 0x45, 0x83, 0xd4, 0xeb, 0xc7,
  1406. 0x60, 0x46, 0xf8, 0xc2, 0xb9, 0xf6, 0xba, 0x56, 0x84, 0x2f, 0x94, 0xf4, 0x06, 0x74, 0x7d, 0x1c,
  1407. 0x60, 0x8e, 0x9d, 0x3c, 0x3a, 0x22, 0x74, 0x1d, 0x45, 0xdc, 0x55, 0xe1, 0x78, 0x08, 0xb7, 0x85,
  1408. 0xc9, 0xb1, 0xcb, 0x70, 0xc4, 0x9d, 0xb1, 0xcb, 0x4f, 0x65, 0x4c, 0x4c, 0xbb, 0x1b, 0xe1, 0x8b,
  1409. 0xb7, 0x92, 0xfa, 0xd6, 0xe5, 0xa7, 0xd6, 0x8f, 0x06, 0x98, 0x79, 0x30, 0xd1, 0x5d, 0x68, 0x8a,
  1410. 0x6b, 0x1d, 0xe2, 0xa7, 0x48, 0x34, 0xc4, 0xf1, 0xd0, 0x17, 0x55, 0x41, 0x87, 0xc3, 0x18, 0x73,
  1411. 0xe9, 0x5e, 0xd5, 0x4e, 0x4f, 0x22, 0xb3, 0x62, 0xf2, 0x6f, 0x55, 0x08, 0x35, 0x5b, 0x7e, 0x0b,
  1412. 0xc4, 0x43, 0x4e, 0x42, 0x2c, 0x2f, 0xac, 0xda, 0xea, 0x80, 0x7a, 0x50, 0xc7, 0x0e, 0x77, 0x47,
  1413. 0x32, 0xc3, 0x4d, 0xbb, 0x86, 0xdf, 0xb9, 0x23, 0xf4, 0x6b, 0xb8, 0x15, 0xd3, 0x84, 0x79, 0xd8,
  1414. 0xc9, 0xae, 0x6d, 0x48, 0x6e, 0x47, 0x51, 0x0f, 0xd4, 0xe5, 0x16, 0x54, 0x87, 0xc4, 0xef, 0x37,
  1415. 0x25, 0x30, 0xf3, 0xc5, 0x24, 0x3c, 0xf4, 0x6d, 0xc1, 0x44, 0xbf, 0x03, 0xc8, 0x2d, 0xf9, 0xfd,
  1416. 0xd6, 0x15, 0xa2, 0x66, 0x66, 0xd7, 0xb7, 0x3e, 0x40, 0x23, 0x35, 0xbf, 0x0c, 0xe6, 0x39, 0x0d,
  1417. 0x92, 0x30, 0x7f, 0x76, 0xd7, 0x6e, 0x29, 0xc2, 0xa1, 0x8f, 0xee, 0x81, 0xec, 0x73, 0x8e, 0xc8,
  1418. 0xaa, 0x8a, 0x7c, 0xa4, 0x44, 0xe8, 0x2f, 0x58, 0x76, 0x0a, 0x8f, 0xd2, 0x33, 0xa2, 0x5e, 0xdf,
  1419. 0xb4, 0xd3, 0x93, 0xf5, 0x43, 0x05, 0x6e, 0x15, 0xd3, 0x5d, 0x5c, 0x21, 0xad, 0x48, 0xac, 0x0c,
  1420. 0x69, 0x46, 0x9a, 0x3d, 0x2e, 0xe0, 0x55, 0xd1, 0xf1, 0xca, 0x54, 0x42, 0xea, 0xab, 0x0b, 0xba,
  1421. 0x4a, 0xe5, 0x15, 0xf5, 0xb1, 0xc8, 0xd6, 0x84, 0xf8, 0x12, 0xe0, 0xae, 0x2d, 0x3e, 0x05, 0x65,
  1422. 0x44, 0xfc, 0xb4, 0x7d, 0x88, 0x4f, 0xe9, 0x1e, 0x93, 0x76, 0x1b, 0x2a, 0x64, 0xea, 0x24, 0x42,
  1423. 0x16, 0x0a, 0x6a, 0x53, 0xc5, 0x41, 0x7c, 0xa3, 0x75, 0x68, 0x33, 0x3c, 0x0e, 0xd2, 0xec, 0x95,
  1424. 0xf0, 0x99, 0xb6, 0x4e, 0x42, 0x6b, 0x00, 0x1e, 0x0d, 0x02, 0xec, 0x49, 0x01, 0x53, 0x0a, 0x68,
  1425. 0x14, 0x91, 0x39, 0x9c, 0x07, 0x4e, 0x8c, 0xbd, 0x3e, 0xac, 0x1b, 0x9b, 0x75, 0xbb, 0xc1, 0x79,
  1426. 0x70, 0x8c, 0x3d, 0xf1, 0x8e, 0x24, 0xc6, 0xcc, 0x91, 0x0d, 0xa8, 0x2d, 0xf5, 0x5a, 0x82, 0x20,
  1427. 0xdb, 0xe4, 0x2a, 0xc0, 0x88, 0xd1, 0x64, 0xac, 0xb8, 0x9d, 0xf5, 0xaa, 0xe8, 0xc5, 0x92, 0x22,
  1428. 0xd9, 0x0f, 0xe0, 0x56, 0xfc, 0x31, 0x0c, 0x48, 0x74, 0xe6, 0x70, 0x97, 0x8d, 0x30, 0xef, 0x77,
  1429. 0x55, 0x0e, 0xa7, 0xd4, 0x77, 0x92, 0x68, 0x8d, 0x01, 0xed, 0x32, 0xec, 0x72, 0xfc, 0x19, 0x63,
  1430. 0xe7, 0xd3, 0xaa, 0x1b, 0x2d, 0x41, 0x83, 0x3a, 0xf8, 0xd2, 0x0b, 0xd2, 0x22, 0xab, 0xd3, 0xfd,
  1431. 0x4b, 0x2f, 0xb0, 0x1e, 0x41, 0xaf, 0x70, 0x63, 0xda, 0x98, 0x17, 0xa1, 0x8e, 0x19, 0xa3, 0x59,
  1432. 0x1b, 0x51, 0x07, 0xeb, 0x6f, 0x80, 0xde, 0x8f, 0xfd, 0x2f, 0xe1, 0x9e, 0xb5, 0x04, 0xbd, 0x82,
  1433. 0x69, 0xe5, 0x87, 0xf5, 0xad, 0x01, 0x68, 0x4f, 0x76, 0x83, 0x5f, 0x36, 0x88, 0x45, 0x7d, 0x8a,
  1434. 0x21, 0xa1, 0xba, 0x8d, 0xef, 0x72, 0x37, 0x1d, 0x61, 0x1d, 0x12, 0x2b, 0xfb, 0x7b, 0x2e, 0x77,
  1435. 0xd3, 0x51, 0xc2, 0xb0, 0x97, 0x30, 0x31, 0xd5, 0x64, 0x12, 0xca, 0x51, 0x62, 0x67, 0x24, 0xf4,
  1436. 0x04, 0xee, 0x90, 0x51, 0x44, 0x19, 0x9e, 0x88, 0x39, 0x0a, 0xaa, 0x86, 0x14, 0x5e, 0x54, 0xdc,
  1437. 0x5c, 0x61, 0x5f, 0x22, 0xf7, 0x08, 0x7a, 0x85, 0x67, 0x5c, 0x0b, 0xf3, 0x7f, 0x0c, 0xe8, 0xbf,
  1438. 0xe0, 0x34, 0x24, 0x9e, 0x8d, 0x85, 0xf3, 0x85, 0xa7, 0x6f, 0x40, 0x57, 0xf4, 0xe3, 0xe9, 0xe7,
  1439. 0x77, 0x68, 0xe0, 0x4f, 0xe6, 0xdd, 0x3d, 0x10, 0x2d, 0xd9, 0xd1, 0x50, 0x68, 0xd2, 0xc0, 0x97,
  1440. 0x99, 0xb8, 0x01, 0xa2, 0x6f, 0x6a, 0xfa, 0x6a, 0xf2, 0x77, 0x22, 0x7c, 0x51, 0xd0, 0x17, 0x42,
  1441. 0x52, 0x5f, 0x35, 0xdb, 0x66, 0x84, 0x2f, 0x84, 0xbe, 0xb5, 0x0c, 0xf7, 0x66, 0xf8, 0x96, 0x86,
  1442. 0xeb, 0x3b, 0x03, 0x7a, 0x2f, 0xe2, 0x98, 0x8c, 0xa2, 0xbf, 0xca, 0xb6, 0x93, 0x39, 0xbd, 0x08,
  1443. 0x75, 0x8f, 0x26, 0x11, 0x97, 0xce, 0xd6, 0x6d, 0x75, 0x98, 0xaa, 0xc4, 0x4a, 0xa9, 0x12, 0xa7,
  1444. 0x6a, 0xb9, 0x5a, 0xae, 0x65, 0xad, 0x56, 0x6b, 0x85, 0x5a, 0xfd, 0x15, 0xb4, 0x45, 0x90, 0x1d,
  1445. 0x0f, 0x47, 0x1c, 0xb3, 0xb4, 0x53, 0x83, 0x20, 0xed, 0x4a, 0x8a, 0x10, 0xd0, 0x27, 0x8a, 0x6a,
  1446. 0xd6, 0x30, 0x9e, 0x8c, 0x93, 0xef, 0x0d, 0x58, 0x2c, 0x3e, 0x25, 0x8d, 0xd9, 0x95, 0x93, 0x45,
  1447. 0xb4, 0x32, 0x16, 0xa4, 0xef, 0x10, 0x9f, 0xa2, 0x29, 0x8c, 0x93, 0x93, 0x80, 0x78, 0x8e, 0x60,
  1448. 0x28, 0xff, 0x4d, 0x45, 0x79, 0xcf, 0x82, 0x09, 0x2a, 0x35, 0x1d, 0x15, 0x04, 0x35, 0x37, 0xe1,
  1449. 0xa7, 0xd9, 0x74, 0x11, 0xdf, 0x53, 0x48, 0x35, 0x6e, 0x42, 0xaa, 0x59, 0x46, 0x2a, 0xcf, 0xb4,
  1450. 0x96, 0x9e, 0x69, 0x4f, 0xa0, 0xa7, 0xd6, 0xd3, 0x62, 0xb8, 0x56, 0x01, 0xf2, 0x39, 0x12, 0xf7,
  1451. 0x0d, 0xd5, 0xcc, 0xb2, 0x41, 0x12, 0x5b, 0x7f, 0x02, 0xf3, 0x88, 0x2a, 0xbb, 0x31, 0xda, 0x06,
  1452. 0x33, 0xc8, 0x0e, 0x52, 0xb4, 0xbd, 0x83, 0x26, 0x35, 0x9e, 0xc9, 0xd9, 0x13, 0x21, 0xeb, 0x39,
  1453. 0xb4, 0x32, 0x72, 0x86, 0x99, 0x71, 0x15, 0x66, 0x95, 0x29, 0xcc, 0xac, 0x6f, 0x0c, 0x58, 0x2c,
  1454. 0xba, 0x9c, 0x86, 0xe5, 0x3d, 0x74, 0xf3, 0x2b, 0x9c, 0xd0, 0x1d, 0xa7, 0xbe, 0x6c, 0xeb, 0xbe,
  1455. 0x94, 0xd5, 0x72, 0x07, 0xe3, 0x57, 0xee, 0x58, 0xe5, 0x72, 0x27, 0xd0, 0x48, 0x83, 0x77, 0xb0,
  1456. 0x50, 0x12, 0x99, 0xb1, 0x9b, 0xfd, 0x56, 0xdf, 0xcd, 0x0a, 0xfb, 0x65, 0xae, 0xad, 0x2f, 0x6c,
  1457. 0xcf, 0xe0, 0xae, 0x6a, 0x07, 0xbb, 0x79, 0x0c, 0x33, 0xec, 0x8b, 0xa1, 0x36, 0xa6, 0x43, 0x6d,
  1458. 0x0d, 0xa0, 0x5f, 0x56, 0x4d, 0xcb, 0x6f, 0x04, 0x0b, 0xc7, 0xdc, 0xe5, 0x24, 0xe6, 0xc4, 0xcb,
  1459. 0x7f, 0x24, 0x4c, 0xe5, 0x86, 0x71, 0xd3, 0x44, 0x2c, 0xd7, 0xe1, 0x3c, 0x54, 0x39, 0xcf, 0xf2,
  1460. 0x57, 0x7c, 0x8a, 0x28, 0x20, 0xfd, 0xa6, 0x34, 0x06, 0x5f, 0xe0, 0x2a, 0x91, 0x0f, 0x9c, 0x72,
  1461. 0x37, 0x50, 0x1b, 0x47, 0x4d, 0x6e, 0x1c, 0xa6, 0xa4, 0xc8, 0x95, 0x43, 0x0d, 0x65, 0x5f, 0x71,
  1462. 0xeb, 0x6a, 0x1f, 0x11, 0x04, 0xc9, 0x5c, 0x05, 0x90, 0xa5, 0xaa, 0xaa, 0xac, 0xa1, 0x74, 0x05,
  1463. 0x65, 0x57, 0x10, 0xac, 0x35, 0x58, 0xf9, 0x33, 0xe6, 0x62, 0x77, 0x62, 0xbb, 0x34, 0x1a, 0x92,
  1464. 0x51, 0xc2, 0x5c, 0x2d, 0x14, 0xd6, 0xff, 0x0d, 0x58, 0xbd, 0x42, 0x20, 0x7d, 0x70, 0x1f, 0x9a,
  1465. 0xa1, 0x1b, 0x73, 0xcc, 0xb2, 0x2a, 0xc9, 0x8e, 0xd3, 0x50, 0x54, 0x6e, 0x82, 0xa2, 0x5a, 0x82,
  1466. 0x62, 0x09, 0x1a, 0xa1, 0x7b, 0xe9, 0x84, 0x27, 0xe9, 0x72, 0x54, 0x0f, 0xdd, 0xcb, 0x57, 0x27,
  1467. 0xb2, 0xb3, 0x11, 0xe6, 0x9c, 0x24, 0xde, 0x19, 0xe6, 0x71, 0xde, 0xd9, 0x08, 0x7b, 0xa9, 0x28,
  1468. 0x3b, 0xff, 0x6b, 0x41, 0xe7, 0x18, 0xbb, 0x17, 0x18, 0xfb, 0xd2, 0x73, 0x34, 0xca, 0x2a, 0xa6,
  1469. 0xf8, 0x1b, 0x14, 0x3d, 0x98, 0x2e, 0x8d, 0x99, 0x3f, 0x7a, 0x07, 0x0f, 0x6f, 0x12, 0x4b, 0x93,
  1470. 0x6f, 0x0e, 0xbd, 0x86, 0xb6, 0xf6, 0x23, 0x0f, 0xad, 0x68, 0x8a, 0xa5, 0xdf, 0xae, 0x83, 0xd5,
  1471. 0x2b, 0xb8, 0x99, 0xb5, 0x6d, 0x03, 0x1d, 0x41, 0x5b, 0xdb, 0x4d, 0x74, 0x7b, 0xe5, 0x25, 0x49,
  1472. 0xb7, 0x37, 0x63, 0xa1, 0xb1, 0xe6, 0x84, 0x35, 0x6d, 0xc3, 0xd0, 0xad, 0x95, 0x77, 0x1a, 0xdd,
  1473. 0xda, 0xac, 0xb5, 0x44, 0x5a, 0xd3, 0x06, 0xba, 0x6e, 0xad, 0xbc, 0xae, 0xe8, 0xd6, 0x66, 0x6c,
  1474. 0x01, 0xd6, 0x1c, 0xfa, 0x00, 0xbd, 0x63, 0xce, 0xb0, 0x1b, 0x4e, 0xd8, 0x53, 0x08, 0xfe, 0x0c,
  1475. 0xab, 0x9b, 0xc6, 0xb6, 0x81, 0xfe, 0x01, 0x0b, 0xa5, 0x71, 0x8d, 0xac, 0x89, 0xe6, 0x55, 0x7b,
  1476. 0xc6, 0x60, 0xe3, 0x5a, 0x99, 0xdc, 0xf3, 0x37, 0xd0, 0xd1, 0xa7, 0x24, 0xd2, 0x9c, 0x9a, 0xb1,
  1477. 0x08, 0x0c, 0xd6, 0xae, 0x62, 0xeb, 0x06, 0xf5, 0x46, 0xad, 0x1b, 0x9c, 0x31, 0xaa, 0x74, 0x83,
  1478. 0xb3, 0xfa, 0xbb, 0x35, 0x87, 0xfe, 0x0e, 0xf3, 0xd3, 0x0d, 0x13, 0xdd, 0x9f, 0x86, 0xae, 0xd4,
  1479. 0x87, 0x07, 0xd6, 0x75, 0x22, 0xb9, 0xf1, 0x43, 0x80, 0x49, 0x1f, 0x44, 0xcb, 0x13, 0x9d, 0x52,
  1480. 0x1f, 0x1e, 0xac, 0xcc, 0x66, 0xe6, 0xa6, 0xfe, 0x09, 0x4b, 0x33, 0x9b, 0x0d, 0xd2, 0x0a, 0xf0,
  1481. 0xba, 0x76, 0x35, 0xf8, 0xcd, 0x8d, 0x72, 0xd9, 0x5d, 0x2f, 0xd7, 0x60, 0x3e, 0x56, 0x2d, 0x62,
  1482. 0x18, 0x6f, 0x79, 0x01, 0xc1, 0x11, 0x7f, 0x09, 0x52, 0xe3, 0x2d, 0xa3, 0x9c, 0x9e, 0x34, 0xe4,
  1483. 0x1f, 0x63, 0xbf, 0xff, 0x29, 0x00, 0x00, 0xff, 0xff, 0x83, 0xa2, 0xc7, 0xb2, 0x27, 0x13, 0x00,
  1484. 0x00,
  1485. }