Skip to main content

Client

Struct Client 

Source
pub struct Client<S> { /* private fields */ }
Expand description

A client for a gRPC service.

Client is designed to “clone and use”, so it’s cheap to clone it. One important thing is that the CallOpt will not be cloned, because it’s designed to be per-request.

Implementations§

Source§

impl<S> Client<S>

Source

pub fn make_cx(&self, path: &'static str) -> ClientContext

Source

pub fn with_opt<Opt>(self, opt: Opt) -> Client<WithOptService<S, Opt>>

Trait Implementations§

Source§

impl<S: Clone> Clone for Client<S>

Source§

fn clone(&self) -> Client<S>

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<S, Req: Send + 'static> OneShotService<ClientContext, Req> for Client<S>
where S: OneShotService<ClientContext, Req, Error = Status> + Sync + Send + 'static,

Source§

type Response = <S as OneShotService<ClientContext, Req>>::Response

Responses given by the service.
Source§

type Error = <S as OneShotService<ClientContext, Req>>::Error

Errors produced by the service.
Source§

async fn call( self, cx: &mut ClientContext, req: Req, ) -> Result<Self::Response, Self::Error>

Process the request and return the response asynchronously.
Source§

impl<S, Req: Send + 'static> Service<ClientContext, Req> for Client<S>
where S: Service<ClientContext, Req, Error = Status> + Sync + Send + 'static,

Source§

type Response = <S as Service<ClientContext, Req>>::Response

Responses given by the service.
Source§

type Error = <S as Service<ClientContext, Req>>::Error

Errors produced by the service.
Source§

async fn call( &self, cx: &mut ClientContext, req: Req, ) -> Result<Self::Response, Self::Error>

Available on crate feature service_send only.
Process the request and return the response asynchronously.

Auto Trait Implementations§

§

impl<S> Freeze for Client<S>
where S: Freeze,

§

impl<S> RefUnwindSafe for Client<S>
where S: RefUnwindSafe,

§

impl<S> Send for Client<S>
where S: Send,

§

impl<S> Sync for Client<S>
where S: Sync,

§

impl<S> Unpin for Client<S>
where S: Unpin,

§

impl<S> UnsafeUnpin for Client<S>
where S: UnsafeUnpin,

§

impl<S> UnwindSafe for Client<S>
where S: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a volo_grpc::Request
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T, Cx, Req> ServiceExt<Cx, Req> for T
where T: Service<Cx, Req>,

Source§

fn map_err<E, F>(self, f: F) -> MapErr<T, F>
where F: FnOnce(<T as Service<Cx, Req>>::Error) -> E,

Maps this service’s error value to a different value. Read more
Source§

fn map_response<F, Response>(self, f: F) -> MapResponse<T, F>
where F: FnOnce(<T as Service<Cx, Req>>::Response) -> Response,

Maps this service’s response value to a different value. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, Cx, MotoreReq, TowerReq> TowerAdapter<Cx, MotoreReq, TowerReq> for T
where T: Service<Cx, MotoreReq> + ?Sized,

Source§

fn tower<F>(self, f: F) -> Tower<Self, F, Cx, MotoreReq>
where F: FnOnce(TowerReq) -> (Cx, MotoreReq), Self: Sized,

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more