ClientNamenodeProtocol.proto 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one
  3. * or more contributor license agreements. See the NOTICE file
  4. * distributed with this work for additional information
  5. * regarding copyright ownership. The ASF licenses this file
  6. * to you under the Apache License, Version 2.0 (the
  7. * "License"); you may not use this file except in compliance
  8. * with the License. You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing, software
  13. * distributed under the License is distributed on an "AS IS" BASIS,
  14. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. * See the License for the specific language governing permissions and
  16. * limitations under the License.
  17. */
  18. /**
  19. * These .proto interfaces are private and stable.
  20. * Please see http://wiki.apache.org/hadoop/Compatibility
  21. * for what changes are allowed for a *stable* .proto interface.
  22. */
  23. option java_package = "org.apache.hadoop.hdfs.protocol.proto";
  24. option java_outer_classname = "ClientNamenodeProtocolProtos";
  25. option java_generic_services = true;
  26. option java_generate_equals_and_hash = true;
  27. package hadoop.hdfs;
  28. import "Security.proto";
  29. import "hdfs.proto";
  30. import "acl.proto";
  31. import "xattr.proto";
  32. /**
  33. * The ClientNamenodeProtocol Service defines the interface between a client
  34. * (as runnign inside a MR Task) and the Namenode.
  35. * See org.apache.hadoop.hdfs.protocol.ClientProtocol for the javadoc
  36. * for each of the methods.
  37. * The exceptions declared in the above class also apply to this protocol.
  38. * Exceptions are unwrapped and thrown by the PB libraries.
  39. */
  40. message GetBlockLocationsRequestProto {
  41. required string src = 1; // file name
  42. required uint64 offset = 2; // range start offset
  43. required uint64 length = 3; // range length
  44. }
  45. message GetBlockLocationsResponseProto {
  46. optional LocatedBlocksProto locations = 1;
  47. }
  48. message GetServerDefaultsRequestProto { // No parameters
  49. }
  50. message GetServerDefaultsResponseProto {
  51. required FsServerDefaultsProto serverDefaults = 1;
  52. }
  53. enum CreateFlagProto {
  54. CREATE = 0x01; // Create a file
  55. OVERWRITE = 0x02; // Truncate/overwrite a file. Same as POSIX O_TRUNC
  56. APPEND = 0x04; // Append to a file
  57. }
  58. message CreateRequestProto {
  59. required string src = 1;
  60. required FsPermissionProto masked = 2;
  61. required string clientName = 3;
  62. required uint32 createFlag = 4; // bits set using CreateFlag
  63. required bool createParent = 5;
  64. required uint32 replication = 6; // Short: Only 16 bits used
  65. required uint64 blockSize = 7;
  66. }
  67. message CreateResponseProto {
  68. optional HdfsFileStatusProto fs = 1;
  69. }
  70. message AppendRequestProto {
  71. required string src = 1;
  72. required string clientName = 2;
  73. }
  74. message AppendResponseProto {
  75. optional LocatedBlockProto block = 1;
  76. }
  77. message SetReplicationRequestProto {
  78. required string src = 1;
  79. required uint32 replication = 2; // Short: Only 16 bits used
  80. }
  81. message SetReplicationResponseProto {
  82. required bool result = 1;
  83. }
  84. message SetPermissionRequestProto {
  85. required string src = 1;
  86. required FsPermissionProto permission = 2;
  87. }
  88. message SetPermissionResponseProto { // void response
  89. }
  90. message SetOwnerRequestProto {
  91. required string src = 1;
  92. optional string username = 2;
  93. optional string groupname = 3;
  94. }
  95. message SetOwnerResponseProto { // void response
  96. }
  97. message AbandonBlockRequestProto {
  98. required ExtendedBlockProto b = 1;
  99. required string src = 2;
  100. required string holder = 3;
  101. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  102. }
  103. message AbandonBlockResponseProto { // void response
  104. }
  105. message AddBlockRequestProto {
  106. required string src = 1;
  107. required string clientName = 2;
  108. optional ExtendedBlockProto previous = 3;
  109. repeated DatanodeInfoProto excludeNodes = 4;
  110. optional uint64 fileId = 5 [default = 0]; // default as a bogus id
  111. repeated string favoredNodes = 6; //the set of datanodes to use for the block
  112. }
  113. message AddBlockResponseProto {
  114. required LocatedBlockProto block = 1;
  115. }
  116. message GetAdditionalDatanodeRequestProto {
  117. required string src = 1;
  118. required ExtendedBlockProto blk = 2;
  119. repeated DatanodeInfoProto existings = 3;
  120. repeated DatanodeInfoProto excludes = 4;
  121. required uint32 numAdditionalNodes = 5;
  122. required string clientName = 6;
  123. repeated string existingStorageUuids = 7;
  124. optional uint64 fileId = 8 [default = 0]; // default to GRANDFATHER_INODE_ID
  125. }
  126. message GetAdditionalDatanodeResponseProto {
  127. required LocatedBlockProto block = 1;
  128. }
  129. message CompleteRequestProto {
  130. required string src = 1;
  131. required string clientName = 2;
  132. optional ExtendedBlockProto last = 3;
  133. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  134. }
  135. message CompleteResponseProto {
  136. required bool result = 1;
  137. }
  138. message ReportBadBlocksRequestProto {
  139. repeated LocatedBlockProto blocks = 1;
  140. }
  141. message ReportBadBlocksResponseProto { // void response
  142. }
  143. message ConcatRequestProto {
  144. required string trg = 1;
  145. repeated string srcs = 2;
  146. }
  147. message ConcatResponseProto { // void response
  148. }
  149. message RenameRequestProto {
  150. required string src = 1;
  151. required string dst = 2;
  152. }
  153. message RenameResponseProto {
  154. required bool result = 1;
  155. }
  156. message Rename2RequestProto {
  157. required string src = 1;
  158. required string dst = 2;
  159. required bool overwriteDest = 3;
  160. }
  161. message Rename2ResponseProto { // void response
  162. }
  163. message DeleteRequestProto {
  164. required string src = 1;
  165. required bool recursive = 2;
  166. }
  167. message DeleteResponseProto {
  168. required bool result = 1;
  169. }
  170. message MkdirsRequestProto {
  171. required string src = 1;
  172. required FsPermissionProto masked = 2;
  173. required bool createParent = 3;
  174. }
  175. message MkdirsResponseProto {
  176. required bool result = 1;
  177. }
  178. message GetListingRequestProto {
  179. required string src = 1;
  180. required bytes startAfter = 2;
  181. required bool needLocation = 3;
  182. }
  183. message GetListingResponseProto {
  184. optional DirectoryListingProto dirList = 1;
  185. }
  186. message GetSnapshottableDirListingRequestProto { // no input parameters
  187. }
  188. message GetSnapshottableDirListingResponseProto {
  189. optional SnapshottableDirectoryListingProto snapshottableDirList = 1;
  190. }
  191. message GetSnapshotDiffReportRequestProto {
  192. required string snapshotRoot = 1;
  193. required string fromSnapshot = 2;
  194. required string toSnapshot = 3;
  195. }
  196. message GetSnapshotDiffReportResponseProto {
  197. required SnapshotDiffReportProto diffReport = 1;
  198. }
  199. message RenewLeaseRequestProto {
  200. required string clientName = 1;
  201. }
  202. message RenewLeaseResponseProto { //void response
  203. }
  204. message RecoverLeaseRequestProto {
  205. required string src = 1;
  206. required string clientName = 2;
  207. }
  208. message RecoverLeaseResponseProto {
  209. required bool result = 1;
  210. }
  211. message GetFsStatusRequestProto { // no input paramters
  212. }
  213. message GetFsStatsResponseProto {
  214. required uint64 capacity = 1;
  215. required uint64 used = 2;
  216. required uint64 remaining = 3;
  217. required uint64 under_replicated = 4;
  218. required uint64 corrupt_blocks = 5;
  219. required uint64 missing_blocks = 6;
  220. }
  221. enum DatanodeReportTypeProto { // type of the datanode report
  222. ALL = 1;
  223. LIVE = 2;
  224. DEAD = 3;
  225. DECOMMISSIONING = 4;
  226. }
  227. message GetDatanodeReportRequestProto {
  228. required DatanodeReportTypeProto type = 1;
  229. }
  230. message GetDatanodeReportResponseProto {
  231. repeated DatanodeInfoProto di = 1;
  232. }
  233. message GetDatanodeStorageReportRequestProto {
  234. required DatanodeReportTypeProto type = 1;
  235. }
  236. message DatanodeStorageReportProto {
  237. required DatanodeInfoProto datanodeInfo = 1;
  238. repeated StorageReportProto storageReports = 2;
  239. }
  240. message GetDatanodeStorageReportResponseProto {
  241. repeated DatanodeStorageReportProto datanodeStorageReports = 1;
  242. }
  243. message GetPreferredBlockSizeRequestProto {
  244. required string filename = 1;
  245. }
  246. message GetPreferredBlockSizeResponseProto {
  247. required uint64 bsize = 1;
  248. }
  249. enum SafeModeActionProto {
  250. SAFEMODE_LEAVE = 1;
  251. SAFEMODE_ENTER = 2;
  252. SAFEMODE_GET = 3;
  253. }
  254. message SetSafeModeRequestProto {
  255. required SafeModeActionProto action = 1;
  256. optional bool checked = 2 [default = false];
  257. }
  258. message SetSafeModeResponseProto {
  259. required bool result = 1;
  260. }
  261. message SaveNamespaceRequestProto { // no parameters
  262. }
  263. message SaveNamespaceResponseProto { // void response
  264. }
  265. message RollEditsRequestProto { // no parameters
  266. }
  267. message RollEditsResponseProto { // response
  268. required uint64 newSegmentTxId = 1;
  269. }
  270. message RestoreFailedStorageRequestProto {
  271. required string arg = 1;
  272. }
  273. message RestoreFailedStorageResponseProto {
  274. required bool result = 1;
  275. }
  276. message RefreshNodesRequestProto { // no parameters
  277. }
  278. message RefreshNodesResponseProto { // void response
  279. }
  280. message FinalizeUpgradeRequestProto { // no parameters
  281. }
  282. message FinalizeUpgradeResponseProto { // void response
  283. }
  284. enum RollingUpgradeActionProto {
  285. QUERY = 1;
  286. START = 2;
  287. FINALIZE = 3;
  288. }
  289. message RollingUpgradeRequestProto {
  290. required RollingUpgradeActionProto action = 1;
  291. }
  292. message RollingUpgradeInfoProto {
  293. required RollingUpgradeStatusProto status = 1;
  294. required uint64 startTime = 2;
  295. required uint64 finalizeTime = 3;
  296. required bool createdRollbackImages = 4;
  297. }
  298. message RollingUpgradeResponseProto {
  299. optional RollingUpgradeInfoProto rollingUpgradeInfo= 1;
  300. }
  301. message ListCorruptFileBlocksRequestProto {
  302. required string path = 1;
  303. optional string cookie = 2;
  304. }
  305. message ListCorruptFileBlocksResponseProto {
  306. required CorruptFileBlocksProto corrupt = 1;
  307. }
  308. message MetaSaveRequestProto {
  309. required string filename = 1;
  310. }
  311. message MetaSaveResponseProto { // void response
  312. }
  313. message GetFileInfoRequestProto {
  314. required string src = 1;
  315. }
  316. message GetFileInfoResponseProto {
  317. optional HdfsFileStatusProto fs = 1;
  318. }
  319. message IsFileClosedRequestProto {
  320. required string src = 1;
  321. }
  322. message IsFileClosedResponseProto {
  323. required bool result = 1;
  324. }
  325. message CacheDirectiveInfoProto {
  326. optional int64 id = 1;
  327. optional string path = 2;
  328. optional uint32 replication = 3;
  329. optional string pool = 4;
  330. optional CacheDirectiveInfoExpirationProto expiration = 5;
  331. }
  332. message CacheDirectiveInfoExpirationProto {
  333. required int64 millis = 1;
  334. required bool isRelative = 2;
  335. }
  336. message CacheDirectiveStatsProto {
  337. required int64 bytesNeeded = 1;
  338. required int64 bytesCached = 2;
  339. required int64 filesNeeded = 3;
  340. required int64 filesCached = 4;
  341. required bool hasExpired = 5;
  342. }
  343. enum CacheFlagProto {
  344. FORCE = 0x01; // Ignore pool resource limits
  345. }
  346. message AddCacheDirectiveRequestProto {
  347. required CacheDirectiveInfoProto info = 1;
  348. optional uint32 cacheFlags = 2; // bits set using CacheFlag
  349. }
  350. message AddCacheDirectiveResponseProto {
  351. required int64 id = 1;
  352. }
  353. message ModifyCacheDirectiveRequestProto {
  354. required CacheDirectiveInfoProto info = 1;
  355. optional uint32 cacheFlags = 2; // bits set using CacheFlag
  356. }
  357. message ModifyCacheDirectiveResponseProto {
  358. }
  359. message RemoveCacheDirectiveRequestProto {
  360. required int64 id = 1;
  361. }
  362. message RemoveCacheDirectiveResponseProto {
  363. }
  364. message ListCacheDirectivesRequestProto {
  365. required int64 prevId = 1;
  366. required CacheDirectiveInfoProto filter = 2;
  367. }
  368. message CacheDirectiveEntryProto {
  369. required CacheDirectiveInfoProto info = 1;
  370. required CacheDirectiveStatsProto stats = 2;
  371. }
  372. message ListCacheDirectivesResponseProto {
  373. repeated CacheDirectiveEntryProto elements = 1;
  374. required bool hasMore = 2;
  375. }
  376. message CachePoolInfoProto {
  377. optional string poolName = 1;
  378. optional string ownerName = 2;
  379. optional string groupName = 3;
  380. optional int32 mode = 4;
  381. optional int64 limit = 5;
  382. optional int64 maxRelativeExpiry = 6;
  383. }
  384. message CachePoolStatsProto {
  385. required int64 bytesNeeded = 1;
  386. required int64 bytesCached = 2;
  387. required int64 bytesOverlimit = 3;
  388. required int64 filesNeeded = 4;
  389. required int64 filesCached = 5;
  390. }
  391. message AddCachePoolRequestProto {
  392. required CachePoolInfoProto info = 1;
  393. }
  394. message AddCachePoolResponseProto { // void response
  395. }
  396. message ModifyCachePoolRequestProto {
  397. required CachePoolInfoProto info = 1;
  398. }
  399. message ModifyCachePoolResponseProto { // void response
  400. }
  401. message RemoveCachePoolRequestProto {
  402. required string poolName = 1;
  403. }
  404. message RemoveCachePoolResponseProto { // void response
  405. }
  406. message ListCachePoolsRequestProto {
  407. required string prevPoolName = 1;
  408. }
  409. message ListCachePoolsResponseProto {
  410. repeated CachePoolEntryProto entries = 1;
  411. required bool hasMore = 2;
  412. }
  413. message CachePoolEntryProto {
  414. required CachePoolInfoProto info = 1;
  415. required CachePoolStatsProto stats = 2;
  416. }
  417. message GetFileLinkInfoRequestProto {
  418. required string src = 1;
  419. }
  420. message GetFileLinkInfoResponseProto {
  421. optional HdfsFileStatusProto fs = 1;
  422. }
  423. message GetContentSummaryRequestProto {
  424. required string path = 1;
  425. }
  426. message GetContentSummaryResponseProto {
  427. required ContentSummaryProto summary = 1;
  428. }
  429. message SetQuotaRequestProto {
  430. required string path = 1;
  431. required uint64 namespaceQuota = 2;
  432. required uint64 diskspaceQuota = 3;
  433. }
  434. message SetQuotaResponseProto { // void response
  435. }
  436. message FsyncRequestProto {
  437. required string src = 1;
  438. required string client = 2;
  439. optional sint64 lastBlockLength = 3 [default = -1];
  440. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  441. }
  442. message FsyncResponseProto { // void response
  443. }
  444. message SetTimesRequestProto {
  445. required string src = 1;
  446. required uint64 mtime = 2;
  447. required uint64 atime = 3;
  448. }
  449. message SetTimesResponseProto { // void response
  450. }
  451. message CreateSymlinkRequestProto {
  452. required string target = 1;
  453. required string link = 2;
  454. required FsPermissionProto dirPerm = 3;
  455. required bool createParent = 4;
  456. }
  457. message CreateSymlinkResponseProto { // void response
  458. }
  459. message GetLinkTargetRequestProto {
  460. required string path = 1;
  461. }
  462. message GetLinkTargetResponseProto {
  463. optional string targetPath = 1;
  464. }
  465. message UpdateBlockForPipelineRequestProto {
  466. required ExtendedBlockProto block = 1;
  467. required string clientName = 2;
  468. }
  469. message UpdateBlockForPipelineResponseProto {
  470. required LocatedBlockProto block = 1;
  471. }
  472. message UpdatePipelineRequestProto {
  473. required string clientName = 1;
  474. required ExtendedBlockProto oldBlock = 2;
  475. required ExtendedBlockProto newBlock = 3;
  476. repeated DatanodeIDProto newNodes = 4;
  477. repeated string storageIDs = 5;
  478. }
  479. message UpdatePipelineResponseProto { // void response
  480. }
  481. message SetBalancerBandwidthRequestProto {
  482. required int64 bandwidth = 1;
  483. }
  484. message SetBalancerBandwidthResponseProto { // void response
  485. }
  486. message GetDataEncryptionKeyRequestProto { // no parameters
  487. }
  488. message GetDataEncryptionKeyResponseProto {
  489. optional DataEncryptionKeyProto dataEncryptionKey = 1;
  490. }
  491. message CreateSnapshotRequestProto {
  492. required string snapshotRoot = 1;
  493. optional string snapshotName = 2;
  494. }
  495. message CreateSnapshotResponseProto {
  496. required string snapshotPath = 1;
  497. }
  498. message RenameSnapshotRequestProto {
  499. required string snapshotRoot = 1;
  500. required string snapshotOldName = 2;
  501. required string snapshotNewName = 3;
  502. }
  503. message RenameSnapshotResponseProto { // void response
  504. }
  505. message AllowSnapshotRequestProto {
  506. required string snapshotRoot = 1;
  507. }
  508. message AllowSnapshotResponseProto {
  509. }
  510. message DisallowSnapshotRequestProto {
  511. required string snapshotRoot = 1;
  512. }
  513. message DisallowSnapshotResponseProto {
  514. }
  515. message DeleteSnapshotRequestProto {
  516. required string snapshotRoot = 1;
  517. required string snapshotName = 2;
  518. }
  519. message DeleteSnapshotResponseProto { // void response
  520. }
  521. message CheckAccessRequestProto {
  522. required string path = 1;
  523. required AclEntryProto.FsActionProto mode = 2;
  524. }
  525. message CheckAccessResponseProto { // void response
  526. }
  527. service ClientNamenodeProtocol {
  528. rpc getBlockLocations(GetBlockLocationsRequestProto)
  529. returns(GetBlockLocationsResponseProto);
  530. rpc getServerDefaults(GetServerDefaultsRequestProto)
  531. returns(GetServerDefaultsResponseProto);
  532. rpc create(CreateRequestProto)returns(CreateResponseProto);
  533. rpc append(AppendRequestProto) returns(AppendResponseProto);
  534. rpc setReplication(SetReplicationRequestProto)
  535. returns(SetReplicationResponseProto);
  536. rpc setPermission(SetPermissionRequestProto)
  537. returns(SetPermissionResponseProto);
  538. rpc setOwner(SetOwnerRequestProto) returns(SetOwnerResponseProto);
  539. rpc abandonBlock(AbandonBlockRequestProto) returns(AbandonBlockResponseProto);
  540. rpc addBlock(AddBlockRequestProto) returns(AddBlockResponseProto);
  541. rpc getAdditionalDatanode(GetAdditionalDatanodeRequestProto)
  542. returns(GetAdditionalDatanodeResponseProto);
  543. rpc complete(CompleteRequestProto) returns(CompleteResponseProto);
  544. rpc reportBadBlocks(ReportBadBlocksRequestProto)
  545. returns(ReportBadBlocksResponseProto);
  546. rpc concat(ConcatRequestProto) returns(ConcatResponseProto);
  547. rpc rename(RenameRequestProto) returns(RenameResponseProto);
  548. rpc rename2(Rename2RequestProto) returns(Rename2ResponseProto);
  549. rpc delete(DeleteRequestProto) returns(DeleteResponseProto);
  550. rpc mkdirs(MkdirsRequestProto) returns(MkdirsResponseProto);
  551. rpc getListing(GetListingRequestProto) returns(GetListingResponseProto);
  552. rpc renewLease(RenewLeaseRequestProto) returns(RenewLeaseResponseProto);
  553. rpc recoverLease(RecoverLeaseRequestProto)
  554. returns(RecoverLeaseResponseProto);
  555. rpc getFsStats(GetFsStatusRequestProto) returns(GetFsStatsResponseProto);
  556. rpc getDatanodeReport(GetDatanodeReportRequestProto)
  557. returns(GetDatanodeReportResponseProto);
  558. rpc getDatanodeStorageReport(GetDatanodeStorageReportRequestProto)
  559. returns(GetDatanodeStorageReportResponseProto);
  560. rpc getPreferredBlockSize(GetPreferredBlockSizeRequestProto)
  561. returns(GetPreferredBlockSizeResponseProto);
  562. rpc setSafeMode(SetSafeModeRequestProto)
  563. returns(SetSafeModeResponseProto);
  564. rpc saveNamespace(SaveNamespaceRequestProto)
  565. returns(SaveNamespaceResponseProto);
  566. rpc rollEdits(RollEditsRequestProto)
  567. returns(RollEditsResponseProto);
  568. rpc restoreFailedStorage(RestoreFailedStorageRequestProto)
  569. returns(RestoreFailedStorageResponseProto);
  570. rpc refreshNodes(RefreshNodesRequestProto) returns(RefreshNodesResponseProto);
  571. rpc finalizeUpgrade(FinalizeUpgradeRequestProto)
  572. returns(FinalizeUpgradeResponseProto);
  573. rpc rollingUpgrade(RollingUpgradeRequestProto)
  574. returns(RollingUpgradeResponseProto);
  575. rpc listCorruptFileBlocks(ListCorruptFileBlocksRequestProto)
  576. returns(ListCorruptFileBlocksResponseProto);
  577. rpc metaSave(MetaSaveRequestProto) returns(MetaSaveResponseProto);
  578. rpc getFileInfo(GetFileInfoRequestProto) returns(GetFileInfoResponseProto);
  579. rpc addCacheDirective(AddCacheDirectiveRequestProto)
  580. returns (AddCacheDirectiveResponseProto);
  581. rpc modifyCacheDirective(ModifyCacheDirectiveRequestProto)
  582. returns (ModifyCacheDirectiveResponseProto);
  583. rpc removeCacheDirective(RemoveCacheDirectiveRequestProto)
  584. returns (RemoveCacheDirectiveResponseProto);
  585. rpc listCacheDirectives(ListCacheDirectivesRequestProto)
  586. returns (ListCacheDirectivesResponseProto);
  587. rpc addCachePool(AddCachePoolRequestProto)
  588. returns(AddCachePoolResponseProto);
  589. rpc modifyCachePool(ModifyCachePoolRequestProto)
  590. returns(ModifyCachePoolResponseProto);
  591. rpc removeCachePool(RemoveCachePoolRequestProto)
  592. returns(RemoveCachePoolResponseProto);
  593. rpc listCachePools(ListCachePoolsRequestProto)
  594. returns(ListCachePoolsResponseProto);
  595. rpc getFileLinkInfo(GetFileLinkInfoRequestProto)
  596. returns(GetFileLinkInfoResponseProto);
  597. rpc getContentSummary(GetContentSummaryRequestProto)
  598. returns(GetContentSummaryResponseProto);
  599. rpc setQuota(SetQuotaRequestProto) returns(SetQuotaResponseProto);
  600. rpc fsync(FsyncRequestProto) returns(FsyncResponseProto);
  601. rpc setTimes(SetTimesRequestProto) returns(SetTimesResponseProto);
  602. rpc createSymlink(CreateSymlinkRequestProto)
  603. returns(CreateSymlinkResponseProto);
  604. rpc getLinkTarget(GetLinkTargetRequestProto)
  605. returns(GetLinkTargetResponseProto);
  606. rpc updateBlockForPipeline(UpdateBlockForPipelineRequestProto)
  607. returns(UpdateBlockForPipelineResponseProto);
  608. rpc updatePipeline(UpdatePipelineRequestProto)
  609. returns(UpdatePipelineResponseProto);
  610. rpc getDelegationToken(hadoop.common.GetDelegationTokenRequestProto)
  611. returns(hadoop.common.GetDelegationTokenResponseProto);
  612. rpc renewDelegationToken(hadoop.common.RenewDelegationTokenRequestProto)
  613. returns(hadoop.common.RenewDelegationTokenResponseProto);
  614. rpc cancelDelegationToken(hadoop.common.CancelDelegationTokenRequestProto)
  615. returns(hadoop.common.CancelDelegationTokenResponseProto);
  616. rpc setBalancerBandwidth(SetBalancerBandwidthRequestProto)
  617. returns(SetBalancerBandwidthResponseProto);
  618. rpc getDataEncryptionKey(GetDataEncryptionKeyRequestProto)
  619. returns(GetDataEncryptionKeyResponseProto);
  620. rpc createSnapshot(CreateSnapshotRequestProto)
  621. returns(CreateSnapshotResponseProto);
  622. rpc renameSnapshot(RenameSnapshotRequestProto)
  623. returns(RenameSnapshotResponseProto);
  624. rpc allowSnapshot(AllowSnapshotRequestProto)
  625. returns(AllowSnapshotResponseProto);
  626. rpc disallowSnapshot(DisallowSnapshotRequestProto)
  627. returns(DisallowSnapshotResponseProto);
  628. rpc getSnapshottableDirListing(GetSnapshottableDirListingRequestProto)
  629. returns(GetSnapshottableDirListingResponseProto);
  630. rpc deleteSnapshot(DeleteSnapshotRequestProto)
  631. returns(DeleteSnapshotResponseProto);
  632. rpc getSnapshotDiffReport(GetSnapshotDiffReportRequestProto)
  633. returns(GetSnapshotDiffReportResponseProto);
  634. rpc isFileClosed(IsFileClosedRequestProto)
  635. returns(IsFileClosedResponseProto);
  636. rpc modifyAclEntries(ModifyAclEntriesRequestProto)
  637. returns(ModifyAclEntriesResponseProto);
  638. rpc removeAclEntries(RemoveAclEntriesRequestProto)
  639. returns(RemoveAclEntriesResponseProto);
  640. rpc removeDefaultAcl(RemoveDefaultAclRequestProto)
  641. returns(RemoveDefaultAclResponseProto);
  642. rpc removeAcl(RemoveAclRequestProto)
  643. returns(RemoveAclResponseProto);
  644. rpc setAcl(SetAclRequestProto)
  645. returns(SetAclResponseProto);
  646. rpc getAclStatus(GetAclStatusRequestProto)
  647. returns(GetAclStatusResponseProto);
  648. rpc setXAttr(SetXAttrRequestProto)
  649. returns(SetXAttrResponseProto);
  650. rpc getXAttrs(GetXAttrsRequestProto)
  651. returns(GetXAttrsResponseProto);
  652. rpc listXAttrs(ListXAttrsRequestProto)
  653. returns(ListXAttrsResponseProto);
  654. rpc removeXAttr(RemoveXAttrRequestProto)
  655. returns(RemoveXAttrResponseProto);
  656. rpc checkAccess(CheckAccessRequestProto)
  657. returns(CheckAccessResponseProto);
  658. }