Struct ydb_grpc::generated::ydb::scheme::v1::scheme_service_client::SchemeServiceClient
source · pub struct SchemeServiceClient<T> { /* private fields */ }
Implementations§
source§impl<T> SchemeServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> SchemeServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
sourcepub fn new(inner: T) -> Self
pub fn new(inner: T) -> Self
Examples found in repository?
src/generated/ydb.scheme.v1.rs (line 18)
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54
pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
where
D: std::convert::TryInto<tonic::transport::Endpoint>,
D::Error: Into<StdError>,
{
let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
Ok(Self::new(conn))
}
}
impl<T> SchemeServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
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 {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SchemeServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + Send + Sync,
{
SchemeServiceClient::new(InterceptedService::new(inner, interceptor))
}
pub fn with_origin(inner: T, origin: Uri) -> Self
pub fn with_interceptor<F>(
inner: T,
interceptor: F
) -> SchemeServiceClient<InterceptedService<T, F>>where
F: Interceptor,
T::ResponseBody: Default,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::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 async fn make_directory(
&mut self,
request: impl IntoRequest<MakeDirectoryRequest>
) -> Result<Response<MakeDirectoryResponse>, Status>
pub async fn make_directory(
&mut self,
request: impl IntoRequest<MakeDirectoryRequest>
) -> Result<Response<MakeDirectoryResponse>, Status>
Make Directory.
sourcepub async fn remove_directory(
&mut self,
request: impl IntoRequest<RemoveDirectoryRequest>
) -> Result<Response<RemoveDirectoryResponse>, Status>
pub async fn remove_directory(
&mut self,
request: impl IntoRequest<RemoveDirectoryRequest>
) -> Result<Response<RemoveDirectoryResponse>, Status>
Remove Directory.
sourcepub async fn list_directory(
&mut self,
request: impl IntoRequest<ListDirectoryRequest>
) -> Result<Response<ListDirectoryResponse>, Status>
pub async fn list_directory(
&mut self,
request: impl IntoRequest<ListDirectoryRequest>
) -> Result<Response<ListDirectoryResponse>, Status>
Returns information about given directory and objects inside it.
sourcepub async fn describe_path(
&mut self,
request: impl IntoRequest<DescribePathRequest>
) -> Result<Response<DescribePathResponse>, Status>
pub async fn describe_path(
&mut self,
request: impl IntoRequest<DescribePathRequest>
) -> Result<Response<DescribePathResponse>, Status>
Returns information about object with given path.
sourcepub async fn modify_permissions(
&mut self,
request: impl IntoRequest<ModifyPermissionsRequest>
) -> Result<Response<ModifyPermissionsResponse>, Status>
pub async fn modify_permissions(
&mut self,
request: impl IntoRequest<ModifyPermissionsRequest>
) -> Result<Response<ModifyPermissionsResponse>, Status>
Modify permissions.
Trait Implementations§
source§impl<T: Clone> Clone for SchemeServiceClient<T>
impl<T: Clone> Clone for SchemeServiceClient<T>
source§fn clone(&self) -> SchemeServiceClient<T>
fn clone(&self) -> SchemeServiceClient<T>
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl<T> RefUnwindSafe for SchemeServiceClient<T>where
T: RefUnwindSafe,
impl<T> Send for SchemeServiceClient<T>where
T: Send,
impl<T> Sync for SchemeServiceClient<T>where
T: Sync,
impl<T> Unpin for SchemeServiceClient<T>where
T: Unpin,
impl<T> UnwindSafe for SchemeServiceClient<T>where
T: UnwindSafe,
Blanket Implementations§
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