pub struct NodeServiceClient<T> { /* private fields */ }Implementations§
Source§impl<T> NodeServiceClient<T>where
T: GrpcService<Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> NodeServiceClient<T>where
T: GrpcService<Body>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn new(inner: T) -> Self
pub fn with_origin(inner: T, origin: Uri) -> Self
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> NodeServiceClient<InterceptedService<T, F>>where
F: Interceptor,
T::ResponseBody: Default,
T: Service<Request<Body>, Response = Response<<T as GrpcService<Body>>::ResponseBody>>,
<T as Service<Request<Body>>>::Error: Into<StdError> + Send + Sync,
Sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
pub fn send_compressed(self, encoding: CompressionEncoding) -> Self
Compress requests with the given encoding.
This requires the server to support it otherwise it might respond with an error.
Sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
Sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
Sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
Sourcepub async fn ping(
&mut self,
request: impl IntoRequest<PingRequest>,
) -> Result<Response<PingResponse>, Status>
pub async fn ping( &mut self, request: impl IntoRequest<PingRequest>, ) -> Result<Response<PingResponse>, Status>
—————————––meta service–––––––––––––
pub async fn heal_bucket( &mut self, request: impl IntoRequest<HealBucketRequest>, ) -> Result<Response<HealBucketResponse>, Status>
pub async fn list_bucket( &mut self, request: impl IntoRequest<ListBucketRequest>, ) -> Result<Response<ListBucketResponse>, Status>
pub async fn make_bucket( &mut self, request: impl IntoRequest<MakeBucketRequest>, ) -> Result<Response<MakeBucketResponse>, Status>
pub async fn get_bucket_info( &mut self, request: impl IntoRequest<GetBucketInfoRequest>, ) -> Result<Response<GetBucketInfoResponse>, Status>
pub async fn delete_bucket( &mut self, request: impl IntoRequest<DeleteBucketRequest>, ) -> Result<Response<DeleteBucketResponse>, Status>
pub async fn read_all( &mut self, request: impl IntoRequest<ReadAllRequest>, ) -> Result<Response<ReadAllResponse>, Status>
pub async fn write_all( &mut self, request: impl IntoRequest<WriteAllRequest>, ) -> Result<Response<WriteAllResponse>, Status>
pub async fn delete( &mut self, request: impl IntoRequest<DeleteRequest>, ) -> Result<Response<DeleteResponse>, Status>
pub async fn verify_file( &mut self, request: impl IntoRequest<VerifyFileRequest>, ) -> Result<Response<VerifyFileResponse>, Status>
pub async fn check_parts( &mut self, request: impl IntoRequest<CheckPartsRequest>, ) -> Result<Response<CheckPartsResponse>, Status>
pub async fn rename_part( &mut self, request: impl IntoRequest<RenamePartRequest>, ) -> Result<Response<RenamePartResponse>, Status>
pub async fn rename_file( &mut self, request: impl IntoRequest<RenameFileRequest>, ) -> Result<Response<RenameFileResponse>, Status>
pub async fn write( &mut self, request: impl IntoRequest<WriteRequest>, ) -> Result<Response<WriteResponse>, Status>
pub async fn write_stream( &mut self, request: impl IntoStreamingRequest<Message = WriteRequest>, ) -> Result<Response<Streaming<WriteResponse>>, Status>
Sourcepub async fn read_at(
&mut self,
request: impl IntoStreamingRequest<Message = ReadAtRequest>,
) -> Result<Response<Streaming<ReadAtResponse>>, Status>
pub async fn read_at( &mut self, request: impl IntoStreamingRequest<Message = ReadAtRequest>, ) -> Result<Response<Streaming<ReadAtResponse>>, Status>
rpc Append(AppendRequest) returns (AppendResponse) {};
pub async fn list_dir( &mut self, request: impl IntoRequest<ListDirRequest>, ) -> Result<Response<ListDirResponse>, Status>
pub async fn walk_dir( &mut self, request: impl IntoRequest<WalkDirRequest>, ) -> Result<Response<Streaming<WalkDirResponse>>, Status>
pub async fn rename_data( &mut self, request: impl IntoRequest<RenameDataRequest>, ) -> Result<Response<RenameDataResponse>, Status>
pub async fn make_volumes( &mut self, request: impl IntoRequest<MakeVolumesRequest>, ) -> Result<Response<MakeVolumesResponse>, Status>
pub async fn make_volume( &mut self, request: impl IntoRequest<MakeVolumeRequest>, ) -> Result<Response<MakeVolumeResponse>, Status>
pub async fn list_volumes( &mut self, request: impl IntoRequest<ListVolumesRequest>, ) -> Result<Response<ListVolumesResponse>, Status>
pub async fn stat_volume( &mut self, request: impl IntoRequest<StatVolumeRequest>, ) -> Result<Response<StatVolumeResponse>, Status>
pub async fn delete_paths( &mut self, request: impl IntoRequest<DeletePathsRequest>, ) -> Result<Response<DeletePathsResponse>, Status>
pub async fn update_metadata( &mut self, request: impl IntoRequest<UpdateMetadataRequest>, ) -> Result<Response<UpdateMetadataResponse>, Status>
pub async fn write_metadata( &mut self, request: impl IntoRequest<WriteMetadataRequest>, ) -> Result<Response<WriteMetadataResponse>, Status>
pub async fn read_version( &mut self, request: impl IntoRequest<ReadVersionRequest>, ) -> Result<Response<ReadVersionResponse>, Status>
pub async fn read_xl( &mut self, request: impl IntoRequest<ReadXlRequest>, ) -> Result<Response<ReadXlResponse>, Status>
pub async fn delete_version( &mut self, request: impl IntoRequest<DeleteVersionRequest>, ) -> Result<Response<DeleteVersionResponse>, Status>
pub async fn delete_versions( &mut self, request: impl IntoRequest<DeleteVersionsRequest>, ) -> Result<Response<DeleteVersionsResponse>, Status>
pub async fn read_multiple( &mut self, request: impl IntoRequest<ReadMultipleRequest>, ) -> Result<Response<ReadMultipleResponse>, Status>
pub async fn delete_volume( &mut self, request: impl IntoRequest<DeleteVolumeRequest>, ) -> Result<Response<DeleteVolumeResponse>, Status>
pub async fn disk_info( &mut self, request: impl IntoRequest<DiskInfoRequest>, ) -> Result<Response<DiskInfoResponse>, Status>
pub async fn ns_scanner( &mut self, request: impl IntoStreamingRequest<Message = NsScannerRequest>, ) -> Result<Response<Streaming<NsScannerResponse>>, Status>
pub async fn lock( &mut self, request: impl IntoRequest<GenerallyLockRequest>, ) -> Result<Response<GenerallyLockResponse>, Status>
pub async fn un_lock( &mut self, request: impl IntoRequest<GenerallyLockRequest>, ) -> Result<Response<GenerallyLockResponse>, Status>
pub async fn r_lock( &mut self, request: impl IntoRequest<GenerallyLockRequest>, ) -> Result<Response<GenerallyLockResponse>, Status>
pub async fn r_un_lock( &mut self, request: impl IntoRequest<GenerallyLockRequest>, ) -> Result<Response<GenerallyLockResponse>, Status>
pub async fn force_un_lock( &mut self, request: impl IntoRequest<GenerallyLockRequest>, ) -> Result<Response<GenerallyLockResponse>, Status>
pub async fn refresh( &mut self, request: impl IntoRequest<GenerallyLockRequest>, ) -> Result<Response<GenerallyLockResponse>, Status>
pub async fn local_storage_info( &mut self, request: impl IntoRequest<LocalStorageInfoRequest>, ) -> Result<Response<LocalStorageInfoResponse>, Status>
pub async fn server_info( &mut self, request: impl IntoRequest<ServerInfoRequest>, ) -> Result<Response<ServerInfoResponse>, Status>
pub async fn get_cpus( &mut self, request: impl IntoRequest<GetCpusRequest>, ) -> Result<Response<GetCpusResponse>, Status>
pub async fn get_net_info( &mut self, request: impl IntoRequest<GetNetInfoRequest>, ) -> Result<Response<GetNetInfoResponse>, Status>
pub async fn get_partitions( &mut self, request: impl IntoRequest<GetPartitionsRequest>, ) -> Result<Response<GetPartitionsResponse>, Status>
pub async fn get_os_info( &mut self, request: impl IntoRequest<GetOsInfoRequest>, ) -> Result<Response<GetOsInfoResponse>, Status>
pub async fn get_se_linux_info( &mut self, request: impl IntoRequest<GetSeLinuxInfoRequest>, ) -> Result<Response<GetSeLinuxInfoResponse>, Status>
pub async fn get_sys_config( &mut self, request: impl IntoRequest<GetSysConfigRequest>, ) -> Result<Response<GetSysConfigResponse>, Status>
pub async fn get_sys_errors( &mut self, request: impl IntoRequest<GetSysErrorsRequest>, ) -> Result<Response<GetSysErrorsResponse>, Status>
pub async fn get_mem_info( &mut self, request: impl IntoRequest<GetMemInfoRequest>, ) -> Result<Response<GetMemInfoResponse>, Status>
pub async fn get_metrics( &mut self, request: impl IntoRequest<GetMetricsRequest>, ) -> Result<Response<GetMetricsResponse>, Status>
pub async fn get_proc_info( &mut self, request: impl IntoRequest<GetProcInfoRequest>, ) -> Result<Response<GetProcInfoResponse>, Status>
pub async fn start_profiling( &mut self, request: impl IntoRequest<StartProfilingRequest>, ) -> Result<Response<StartProfilingResponse>, Status>
pub async fn download_profile_data( &mut self, request: impl IntoRequest<DownloadProfileDataRequest>, ) -> Result<Response<DownloadProfileDataResponse>, Status>
pub async fn get_bucket_stats( &mut self, request: impl IntoRequest<GetBucketStatsDataRequest>, ) -> Result<Response<GetBucketStatsDataResponse>, Status>
pub async fn get_sr_metrics( &mut self, request: impl IntoRequest<GetSrMetricsDataRequest>, ) -> Result<Response<GetSrMetricsDataResponse>, Status>
pub async fn get_all_bucket_stats( &mut self, request: impl IntoRequest<GetAllBucketStatsRequest>, ) -> Result<Response<GetAllBucketStatsResponse>, Status>
pub async fn load_bucket_metadata( &mut self, request: impl IntoRequest<LoadBucketMetadataRequest>, ) -> Result<Response<LoadBucketMetadataResponse>, Status>
pub async fn delete_bucket_metadata( &mut self, request: impl IntoRequest<DeleteBucketMetadataRequest>, ) -> Result<Response<DeleteBucketMetadataResponse>, Status>
pub async fn delete_policy( &mut self, request: impl IntoRequest<DeletePolicyRequest>, ) -> Result<Response<DeletePolicyResponse>, Status>
pub async fn load_policy( &mut self, request: impl IntoRequest<LoadPolicyRequest>, ) -> Result<Response<LoadPolicyResponse>, Status>
pub async fn load_policy_mapping( &mut self, request: impl IntoRequest<LoadPolicyMappingRequest>, ) -> Result<Response<LoadPolicyMappingResponse>, Status>
pub async fn delete_user( &mut self, request: impl IntoRequest<DeleteUserRequest>, ) -> Result<Response<DeleteUserResponse>, Status>
pub async fn delete_service_account( &mut self, request: impl IntoRequest<DeleteServiceAccountRequest>, ) -> Result<Response<DeleteServiceAccountResponse>, Status>
pub async fn load_user( &mut self, request: impl IntoRequest<LoadUserRequest>, ) -> Result<Response<LoadUserResponse>, Status>
pub async fn load_service_account( &mut self, request: impl IntoRequest<LoadServiceAccountRequest>, ) -> Result<Response<LoadServiceAccountResponse>, Status>
pub async fn load_group( &mut self, request: impl IntoRequest<LoadGroupRequest>, ) -> Result<Response<LoadGroupResponse>, Status>
pub async fn reload_site_replication_config( &mut self, request: impl IntoRequest<ReloadSiteReplicationConfigRequest>, ) -> Result<Response<ReloadSiteReplicationConfigResponse>, Status>
Sourcepub async fn signal_service(
&mut self,
request: impl IntoRequest<SignalServiceRequest>,
) -> Result<Response<SignalServiceResponse>, Status>
pub async fn signal_service( &mut self, request: impl IntoRequest<SignalServiceRequest>, ) -> Result<Response<SignalServiceResponse>, Status>
rpc VerifyBinary() returns () {}; rpc CommitBinary() returns () {};
pub async fn background_heal_status( &mut self, request: impl IntoRequest<BackgroundHealStatusRequest>, ) -> Result<Response<BackgroundHealStatusResponse>, Status>
pub async fn get_metacache_listing( &mut self, request: impl IntoRequest<GetMetacacheListingRequest>, ) -> Result<Response<GetMetacacheListingResponse>, Status>
pub async fn update_metacache_listing( &mut self, request: impl IntoRequest<UpdateMetacacheListingRequest>, ) -> Result<Response<UpdateMetacacheListingResponse>, Status>
pub async fn reload_pool_meta( &mut self, request: impl IntoRequest<ReloadPoolMetaRequest>, ) -> Result<Response<ReloadPoolMetaResponse>, Status>
pub async fn stop_rebalance( &mut self, request: impl IntoRequest<StopRebalanceRequest>, ) -> Result<Response<StopRebalanceResponse>, Status>
pub async fn load_rebalance_meta( &mut self, request: impl IntoRequest<LoadRebalanceMetaRequest>, ) -> Result<Response<LoadRebalanceMetaResponse>, Status>
pub async fn load_transition_tier_config( &mut self, request: impl IntoRequest<LoadTransitionTierConfigRequest>, ) -> Result<Response<LoadTransitionTierConfigResponse>, Status>
Trait Implementations§
Source§impl<T: Clone> Clone for NodeServiceClient<T>
impl<T: Clone> Clone for NodeServiceClient<T>
Source§fn clone(&self) -> NodeServiceClient<T>
fn clone(&self) -> NodeServiceClient<T>
Returns a duplicate of the value. Read more
1.0.0 · Source§const fn clone_from(&mut self, source: &Self)
const fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl<T> !Freeze for NodeServiceClient<T>
impl<T> RefUnwindSafe for NodeServiceClient<T>where
T: RefUnwindSafe,
impl<T> Send for NodeServiceClient<T>where
T: Send,
impl<T> Sync for NodeServiceClient<T>where
T: Sync,
impl<T> Unpin for NodeServiceClient<T>where
T: Unpin,
impl<T> UnwindSafe for NodeServiceClient<T>where
T: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request