ClientNamenodeProtocol.proto 24 KB

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