Struct ClientContext 

pub struct ClientContext(/* private fields */);

A context for client to pass information such as RpcInfo and Config between middleware during the rpc call lifecycle.

Implementations

impl ClientContext

pub fn new(ri: RpcInfo<Config>) -> Self

Methods from Deref<Target = RpcCx<ClientCxInner, Config>>

pub fn reset(&mut self, inner: I)

Trait Implementations

impl Apply<ClientContext> for CallOpt

type Error = Status

fn apply(self, cx: &mut ClientContext) -> Result<(), Self::Error>

impl Context for ClientContext

type Config = Config

fn rpc_info(&self) -> &RpcInfo<Self::Config>

fn rpc_info_mut(&mut self) -> &mut RpcInfo<Self::Config>

fn extensions_mut(&mut self) -> &mut Extensions

fn extensions(&self) -> &Extensions

impl Default for ClientContext

fn default() -> Self

Returns the “default value” for a type.

impl Deref for ClientContext

type Target = RpcCx<ClientCxInner, Config>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for ClientContext

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

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( self, 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( &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.

impl<T, U, S> Service<ClientContext, Request<T>> for MetaService<S>

where S: Service<ClientContext, Request<T>, Response = Response<U>, Error = Status> + Send + 'static + Sync, T: Send + 'static,

type Response = <S as Service<ClientContext, Request<T>>>::Response

Responses given by the service.

type Error = <S as Service<ClientContext, Request<T>>>::Error

Errors produced by the service.

async fn call( &self, cx: &mut ClientContext, volo_req: Request<T>, ) -> Result<Self::Response, Self::Error>

Available on crate feature service_send only.

Process the request and return the response asynchronously.

impl<S, T> Service<ClientContext, Request<T>> for Timeout<S>

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

type Response = <S as Service<ClientContext, Request<T>>>::Response

Responses given by the service.

type Error = Status

Errors produced by the service.

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

Available on crate feature service_send only.

Process the request and return the response asynchronously.

impl<T, U> Service<ClientContext, Request<T>> for ClientTransport<U>

where T: SendEntryMessage + Send + 'static, U: RecvEntryMessage + 'static,

type Response = Response<U>

Responses given by the service.

type Error = Status

Errors produced by the service.

async fn call( &self, cx: &mut ClientContext, volo_req: Request<T>, ) -> Result<Self::Response, Self::Error>

Available on crate feature service_send only.

Process the request and return the response asynchronously.