Struct volo_grpc::client::Client

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

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

impl<S> Client<S>

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

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

Trait Implementations

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

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S, Req: Send + 'static> OneShotService<ClientContext, Req> for Client<S>

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

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

Responses given by the service.

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

Errors produced by the service.

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

Process the request and return the response asynchronously.

impl<S, Req: Send + 'static> Service<ClientContext, Req> for Client<S>

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

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

Responses given by the service.

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

Errors produced by the service.

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

Process the request and return the response asynchronously.