Struct HRpc

pub struct HRpc<S> { /* private fields */ }

hdfs rpc

Implementations

impl<S: Write + Read> HRpc<S>

pub fn connect( stream: S, effective_user: impl Into<Option<String>>, real_user: impl Into<Option<String>>, context: impl Into<Option<RpcCallerContextProto>>, handshake: impl Into<Option<Handshake>>, ) -> Result<Self, HDFSError>

pub fn send_raw_req( &mut self, method_name: &str, req: &[u8], ) -> Result<(RpcResponseHeaderProto, BytesMut), HDFSError>

impl<S: Write + Read> HRpc<S>

pub fn get_replica_visible_length( &mut self, req: GetReplicaVisibleLengthRequestProto, ) -> Result<(RpcResponseHeaderProto, GetReplicaVisibleLengthResponseProto), HDFSError>

pub fn refresh_namenodes( &mut self, req: RefreshNamenodesRequestProto, ) -> Result<(RpcResponseHeaderProto, RefreshNamenodesResponseProto), HDFSError>

pub fn delete_block_pool( &mut self, req: DeleteBlockPoolRequestProto, ) -> Result<(RpcResponseHeaderProto, DeleteBlockPoolResponseProto), HDFSError>

pub fn get_block_local_path_info( &mut self, req: GetBlockLocalPathInfoRequestProto, ) -> Result<(RpcResponseHeaderProto, GetBlockLocalPathInfoResponseProto), HDFSError>

pub fn shutdown_datanode( &mut self, req: ShutdownDatanodeRequestProto, ) -> Result<(RpcResponseHeaderProto, ShutdownDatanodeResponseProto), HDFSError>

pub fn evict_writers( &mut self, req: EvictWritersRequestProto, ) -> Result<(RpcResponseHeaderProto, EvictWritersResponseProto), HDFSError>

pub fn get_datanode_info( &mut self, req: GetDatanodeInfoRequestProto, ) -> Result<(RpcResponseHeaderProto, GetDatanodeInfoResponseProto), HDFSError>

pub fn get_volume_report( &mut self, req: GetVolumeReportRequestProto, ) -> Result<(RpcResponseHeaderProto, GetVolumeReportResponseProto), HDFSError>

pub fn start_reconfiguration( &mut self, req: StartReconfigurationRequestProto, ) -> Result<(RpcResponseHeaderProto, StartReconfigurationResponseProto), HDFSError>

pub fn trigger_block_report( &mut self, req: TriggerBlockReportRequestProto, ) -> Result<(RpcResponseHeaderProto, TriggerBlockReportResponseProto), HDFSError>

pub fn get_balancer_bandwidth( &mut self, req: GetBalancerBandwidthRequestProto, ) -> Result<(RpcResponseHeaderProto, GetBalancerBandwidthResponseProto), HDFSError>

pub fn get_reconfiguration_status( &mut self, req: GetReconfigurationStatusRequestProto, ) -> Result<(RpcResponseHeaderProto, GetReconfigurationStatusResponseProto), HDFSError>

pub fn get_disk_balancer_setting( &mut self, req: DiskBalancerSettingRequestProto, ) -> Result<(RpcResponseHeaderProto, DiskBalancerSettingResponseProto), HDFSError>

impl<S: Write + Read> HRpc<S>

pub fn create( &mut self, req: CreateRequestProto, ) -> Result<(RpcResponseHeaderProto, CreateResponseProto), HDFSError>

pub fn get_server_defaults( &mut self, req: GetServerDefaultsRequestProto, ) -> Result<(RpcResponseHeaderProto, GetServerDefaultsResponseProto), HDFSError>

pub fn get_block_locations( &mut self, req: GetBlockLocationsRequestProto, ) -> Result<(RpcResponseHeaderProto, GetBlockLocationsResponseProto), HDFSError>

pub fn append( &mut self, req: AppendRequestProto, ) -> Result<(RpcResponseHeaderProto, AppendResponseProto), HDFSError>

pub fn set_replication( &mut self, req: SetReplicationRequestProto, ) -> Result<(RpcResponseHeaderProto, SetReplicationResponseProto), HDFSError>

pub fn set_storage_policy( &mut self, req: SetStoragePolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, SetStoragePolicyResponseProto), HDFSError>

pub fn unset_storage_policy( &mut self, req: UnsetStoragePolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, UnsetStoragePolicyResponseProto), HDFSError>

pub fn get_storage_policy( &mut self, req: GetStoragePolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, GetStoragePolicyResponseProto), HDFSError>

pub fn get_storage_policies( &mut self, req: GetStoragePoliciesRequestProto, ) -> Result<(RpcResponseHeaderProto, GetStoragePoliciesResponseProto), HDFSError>

pub fn set_permission( &mut self, req: SetPermissionRequestProto, ) -> Result<(RpcResponseHeaderProto, SetPermissionResponseProto), HDFSError>

pub fn set_owner( &mut self, req: SetOwnerRequestProto, ) -> Result<(RpcResponseHeaderProto, SetOwnerResponseProto), HDFSError>

pub fn abandon_block( &mut self, req: AbandonBlockRequestProto, ) -> Result<(RpcResponseHeaderProto, AbandonBlockResponseProto), HDFSError>

pub fn add_block( &mut self, req: AddBlockRequestProto, ) -> Result<(RpcResponseHeaderProto, AddBlockResponseProto), HDFSError>

pub fn get_additional_datanode( &mut self, req: GetAdditionalDatanodeRequestProto, ) -> Result<(RpcResponseHeaderProto, GetAdditionalDatanodeResponseProto), HDFSError>

pub fn complete( &mut self, req: CompleteRequestProto, ) -> Result<(RpcResponseHeaderProto, CompleteResponseProto), HDFSError>

pub fn report_bad_blocks( &mut self, req: ReportBadBlocksRequestProto, ) -> Result<(RpcResponseHeaderProto, ReportBadBlocksResponseProto), HDFSError>

pub fn concat( &mut self, req: ConcatRequestProto, ) -> Result<(RpcResponseHeaderProto, ConcatResponseProto), HDFSError>

pub fn truncate( &mut self, req: TruncateRequestProto, ) -> Result<(RpcResponseHeaderProto, TruncateResponseProto), HDFSError>

pub fn rename( &mut self, req: RenameRequestProto, ) -> Result<(RpcResponseHeaderProto, RenameResponseProto), HDFSError>

pub fn rename2( &mut self, req: Rename2RequestProto, ) -> Result<(RpcResponseHeaderProto, Rename2ResponseProto), HDFSError>

pub fn delete( &mut self, req: DeleteRequestProto, ) -> Result<(RpcResponseHeaderProto, DeleteResponseProto), HDFSError>

pub fn mkdirs( &mut self, req: MkdirsRequestProto, ) -> Result<(RpcResponseHeaderProto, MkdirsResponseProto), HDFSError>

pub fn get_listing( &mut self, req: GetListingRequestProto, ) -> Result<(RpcResponseHeaderProto, GetListingResponseProto), HDFSError>

pub fn renew_lease( &mut self, req: RenewLeaseRequestProto, ) -> Result<(RpcResponseHeaderProto, RenewLeaseResponseProto), HDFSError>

pub fn recover_lease( &mut self, req: RecoverLeaseRequestProto, ) -> Result<(RpcResponseHeaderProto, RecoverLeaseResponseProto), HDFSError>

pub fn get_fs_stats( &mut self, req: GetFsStatusRequestProto, ) -> Result<(RpcResponseHeaderProto, GetFsStatsResponseProto), HDFSError>

pub fn get_datanode_report( &mut self, req: GetDatanodeReportRequestProto, ) -> Result<(RpcResponseHeaderProto, GetDatanodeReportResponseProto), HDFSError>

pub fn get_preferred_block_size( &mut self, req: GetPreferredBlockSizeRequestProto, ) -> Result<(RpcResponseHeaderProto, GetPreferredBlockSizeResponseProto), HDFSError>

pub fn set_safe_mode( &mut self, req: SetSafeModeRequestProto, ) -> Result<(RpcResponseHeaderProto, SetSafeModeResponseProto), HDFSError>

pub fn save_namespace( &mut self, req: SaveNamespaceRequestProto, ) -> Result<(RpcResponseHeaderProto, SaveNamespaceResponseProto), HDFSError>

pub fn roll_edits( &mut self, req: RollEditsRequestProto, ) -> Result<(RpcResponseHeaderProto, RollEditsResponseProto), HDFSError>

pub fn restore_failed_storage( &mut self, req: RestoreFailedStorageRequestProto, ) -> Result<(RpcResponseHeaderProto, RestoreFailedStorageResponseProto), HDFSError>

pub fn refresh_nodes( &mut self, req: RefreshNodesRequestProto, ) -> Result<(RpcResponseHeaderProto, RefreshNodesResponseProto), HDFSError>

pub fn finalize_upgrade( &mut self, req: FinalizeUpgradeRequestProto, ) -> Result<(RpcResponseHeaderProto, FinalizeUpgradeResponseProto), HDFSError>

pub fn upgrade_status( &mut self, req: UpgradeStatusRequestProto, ) -> Result<(RpcResponseHeaderProto, UpgradeStatusResponseProto), HDFSError>

pub fn rolling_upgrade( &mut self, req: RollingUpgradeRequestProto, ) -> Result<(RpcResponseHeaderProto, RollingUpgradeResponseProto), HDFSError>

pub fn list_corrupt_file_blocks( &mut self, req: ListCorruptFileBlocksRequestProto, ) -> Result<(RpcResponseHeaderProto, ListCorruptFileBlocksResponseProto), HDFSError>

pub fn meta_save( &mut self, req: MetaSaveRequestProto, ) -> Result<(RpcResponseHeaderProto, MetaSaveResponseProto), HDFSError>

pub fn get_file_info( &mut self, req: GetFileInfoRequestProto, ) -> Result<(RpcResponseHeaderProto, GetFileInfoResponseProto), HDFSError>

pub fn get_located_file_info( &mut self, req: GetLocatedFileInfoRequestProto, ) -> Result<(RpcResponseHeaderProto, GetLocatedFileInfoResponseProto), HDFSError>

pub fn add_cache_pool( &mut self, req: AddCachePoolRequestProto, ) -> Result<(RpcResponseHeaderProto, AddCachePoolResponseProto), HDFSError>

pub fn modify_cache_pool( &mut self, req: ModifyCachePoolRequestProto, ) -> Result<(RpcResponseHeaderProto, ModifyCachePoolResponseProto), HDFSError>

pub fn remove_cache_pool( &mut self, req: RemoveCachePoolRequestProto, ) -> Result<(RpcResponseHeaderProto, RemoveCachePoolResponseProto), HDFSError>

pub fn list_cache_pools( &mut self, req: ListCachePoolsRequestProto, ) -> Result<(RpcResponseHeaderProto, ListCachePoolsResponseProto), HDFSError>

pub fn get_file_link_info( &mut self, req: GetFileLinkInfoRequestProto, ) -> Result<(RpcResponseHeaderProto, GetFileLinkInfoResponseProto), HDFSError>

pub fn get_content_summary( &mut self, req: GetContentSummaryRequestProto, ) -> Result<(RpcResponseHeaderProto, GetContentSummaryResponseProto), HDFSError>

pub fn set_quota( &mut self, req: SetQuotaRequestProto, ) -> Result<(RpcResponseHeaderProto, SetQuotaResponseProto), HDFSError>

pub fn fsync( &mut self, req: FsyncRequestProto, ) -> Result<(RpcResponseHeaderProto, FsyncResponseProto), HDFSError>

pub fn set_times( &mut self, req: SetTimesRequestProto, ) -> Result<(RpcResponseHeaderProto, SetTimesResponseProto), HDFSError>

pub fn create_symlink( &mut self, req: CreateSymlinkRequestProto, ) -> Result<(RpcResponseHeaderProto, CreateSymlinkResponseProto), HDFSError>

pub fn get_link_target( &mut self, req: GetLinkTargetRequestProto, ) -> Result<(RpcResponseHeaderProto, GetLinkTargetResponseProto), HDFSError>

pub fn update_block_for_pipeline( &mut self, req: UpdateBlockForPipelineRequestProto, ) -> Result<(RpcResponseHeaderProto, UpdateBlockForPipelineResponseProto), HDFSError>

pub fn update_pipeline( &mut self, req: UpdatePipelineRequestProto, ) -> Result<(RpcResponseHeaderProto, UpdatePipelineResponseProto), HDFSError>

pub fn set_balancer_bandwidth( &mut self, req: SetBalancerBandwidthRequestProto, ) -> Result<(RpcResponseHeaderProto, SetBalancerBandwidthResponseProto), HDFSError>

pub fn get_data_encryption_key( &mut self, req: GetDataEncryptionKeyRequestProto, ) -> Result<(RpcResponseHeaderProto, GetDataEncryptionKeyResponseProto), HDFSError>

pub fn create_snapshot( &mut self, req: CreateSnapshotRequestProto, ) -> Result<(RpcResponseHeaderProto, CreateSnapshotResponseProto), HDFSError>

pub fn rename_snapshot( &mut self, req: RenameSnapshotRequestProto, ) -> Result<(RpcResponseHeaderProto, RenameSnapshotResponseProto), HDFSError>

pub fn allow_snapshot( &mut self, req: AllowSnapshotRequestProto, ) -> Result<(RpcResponseHeaderProto, AllowSnapshotResponseProto), HDFSError>

pub fn disallow_snapshot( &mut self, req: DisallowSnapshotRequestProto, ) -> Result<(RpcResponseHeaderProto, DisallowSnapshotResponseProto), HDFSError>

pub fn get_snapshot_listing( &mut self, req: GetSnapshotListingRequestProto, ) -> Result<(RpcResponseHeaderProto, GetSnapshotListingResponseProto), HDFSError>

pub fn delete_snapshot( &mut self, req: DeleteSnapshotRequestProto, ) -> Result<(RpcResponseHeaderProto, DeleteSnapshotResponseProto), HDFSError>

pub fn get_snapshot_diff_report( &mut self, req: GetSnapshotDiffReportRequestProto, ) -> Result<(RpcResponseHeaderProto, GetSnapshotDiffReportResponseProto), HDFSError>

pub fn is_file_closed( &mut self, req: IsFileClosedRequestProto, ) -> Result<(RpcResponseHeaderProto, IsFileClosedResponseProto), HDFSError>

pub fn modify_acl_entries( &mut self, req: ModifyAclEntriesRequestProto, ) -> Result<(RpcResponseHeaderProto, ModifyAclEntriesResponseProto), HDFSError>

pub fn remove_acl_entries( &mut self, req: RemoveAclEntriesRequestProto, ) -> Result<(RpcResponseHeaderProto, RemoveAclEntriesResponseProto), HDFSError>

pub fn remove_default_acl( &mut self, req: RemoveDefaultAclRequestProto, ) -> Result<(RpcResponseHeaderProto, RemoveDefaultAclResponseProto), HDFSError>

pub fn remove_acl( &mut self, req: RemoveAclRequestProto, ) -> Result<(RpcResponseHeaderProto, RemoveAclResponseProto), HDFSError>

pub fn set_acl( &mut self, req: SetAclRequestProto, ) -> Result<(RpcResponseHeaderProto, SetAclResponseProto), HDFSError>

pub fn get_acl_status( &mut self, req: GetAclStatusRequestProto, ) -> Result<(RpcResponseHeaderProto, GetAclStatusResponseProto), HDFSError>

pub fn set_x_attr( &mut self, req: SetXAttrRequestProto, ) -> Result<(RpcResponseHeaderProto, SetXAttrResponseProto), HDFSError>

pub fn get_x_attrs( &mut self, req: GetXAttrsRequestProto, ) -> Result<(RpcResponseHeaderProto, GetXAttrsResponseProto), HDFSError>

pub fn list_x_attrs( &mut self, req: ListXAttrsRequestProto, ) -> Result<(RpcResponseHeaderProto, ListXAttrsResponseProto), HDFSError>

pub fn remove_x_attr( &mut self, req: RemoveXAttrRequestProto, ) -> Result<(RpcResponseHeaderProto, RemoveXAttrResponseProto), HDFSError>

pub fn check_access( &mut self, req: CheckAccessRequestProto, ) -> Result<(RpcResponseHeaderProto, CheckAccessResponseProto), HDFSError>

pub fn create_encryption_zone( &mut self, req: CreateEncryptionZoneRequestProto, ) -> Result<(RpcResponseHeaderProto, CreateEncryptionZoneResponseProto), HDFSError>

pub fn list_encryption_zones( &mut self, req: ListEncryptionZonesRequestProto, ) -> Result<(RpcResponseHeaderProto, ListEncryptionZonesResponseProto), HDFSError>

pub fn reencrypt_encryption_zone( &mut self, req: ReencryptEncryptionZoneRequestProto, ) -> Result<(RpcResponseHeaderProto, ReencryptEncryptionZoneResponseProto), HDFSError>

pub fn list_reencryption_status( &mut self, req: ListReencryptionStatusRequestProto, ) -> Result<(RpcResponseHeaderProto, ListReencryptionStatusResponseProto), HDFSError>

pub fn get_e_z_for_path( &mut self, req: GetEzForPathRequestProto, ) -> Result<(RpcResponseHeaderProto, GetEzForPathResponseProto), HDFSError>

pub fn set_erasure_coding_policy( &mut self, req: SetErasureCodingPolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, SetErasureCodingPolicyResponseProto), HDFSError>

pub fn get_current_edit_log_txid( &mut self, req: GetCurrentEditLogTxidRequestProto, ) -> Result<(RpcResponseHeaderProto, GetCurrentEditLogTxidResponseProto), HDFSError>

pub fn get_edits_from_txid( &mut self, req: GetEditsFromTxidRequestProto, ) -> Result<(RpcResponseHeaderProto, GetEditsFromTxidResponseProto), HDFSError>

pub fn get_erasure_coding_policy( &mut self, req: GetErasureCodingPolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, GetErasureCodingPolicyResponseProto), HDFSError>

pub fn get_erasure_coding_codecs( &mut self, req: GetErasureCodingCodecsRequestProto, ) -> Result<(RpcResponseHeaderProto, GetErasureCodingCodecsResponseProto), HDFSError>

pub fn get_quota_usage( &mut self, req: GetQuotaUsageRequestProto, ) -> Result<(RpcResponseHeaderProto, GetQuotaUsageResponseProto), HDFSError>

pub fn list_open_files( &mut self, req: ListOpenFilesRequestProto, ) -> Result<(RpcResponseHeaderProto, ListOpenFilesResponseProto), HDFSError>

pub fn msync( &mut self, req: MsyncRequestProto, ) -> Result<(RpcResponseHeaderProto, MsyncResponseProto), HDFSError>

pub fn satisfy_storage_policy( &mut self, req: SatisfyStoragePolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, SatisfyStoragePolicyResponseProto), HDFSError>

pub fn get_ha_service_state( &mut self, req: HaServiceStateRequestProto, ) -> Result<(RpcResponseHeaderProto, HaServiceStateResponseProto), HDFSError>

pub fn get_datanode_storage_report( &mut self, req: GetDatanodeStorageReportRequestProto, ) -> Result<(RpcResponseHeaderProto, GetDatanodeStorageReportResponseProto), HDFSError>

pub fn get_snapshottable_dir_listing( &mut self, req: GetSnapshottableDirListingRequestProto, ) -> Result<(RpcResponseHeaderProto, GetSnapshottableDirListingResponseProto), HDFSError>

pub fn get_snapshot_diff_report_listing( &mut self, req: GetSnapshotDiffReportListingRequestProto, ) -> Result<(RpcResponseHeaderProto, GetSnapshotDiffReportListingResponseProto), HDFSError>

pub fn unset_erasure_coding_policy( &mut self, req: UnsetErasureCodingPolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, UnsetErasureCodingPolicyResponseProto), HDFSError>

pub fn get_e_c_topology_result_for_policies( &mut self, req: GetEcTopologyResultForPoliciesRequestProto, ) -> Result<(RpcResponseHeaderProto, GetEcTopologyResultForPoliciesResponseProto), HDFSError>

pub fn get_erasure_coding_policies( &mut self, req: GetErasureCodingPoliciesRequestProto, ) -> Result<(RpcResponseHeaderProto, GetErasureCodingPoliciesResponseProto), HDFSError>

pub fn add_erasure_coding_policies( &mut self, req: AddErasureCodingPoliciesRequestProto, ) -> Result<(RpcResponseHeaderProto, AddErasureCodingPoliciesResponseProto), HDFSError>

pub fn remove_erasure_coding_policy( &mut self, req: RemoveErasureCodingPolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, RemoveErasureCodingPolicyResponseProto), HDFSError>

pub fn enable_erasure_coding_policy( &mut self, req: EnableErasureCodingPolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, EnableErasureCodingPolicyResponseProto), HDFSError>

pub fn disable_erasure_coding_policy( &mut self, req: DisableErasureCodingPolicyRequestProto, ) -> Result<(RpcResponseHeaderProto, DisableErasureCodingPolicyResponseProto), HDFSError>

pub fn get_slow_datanode_report( &mut self, req: GetSlowDatanodeReportRequestProto, ) -> Result<(RpcResponseHeaderProto, GetSlowDatanodeReportResponseProto), HDFSError>