Struct hdfs_client::hrpc::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>