Struct svc_pricing_client_grpc::client::rpc_service_client::RpcServiceClient

pub struct RpcServiceClient<T> { /* private fields */ }

Implementations

impl RpcServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> RpcServiceClient<T>where
    T: GrpcService<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

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>(
    inner: T,
    interceptor: F
) -> RpcServiceClient<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,

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.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub async fn is_ready(
    &mut self,
    request: impl IntoRequest<ReadyRequest>
) -> Result<Response<ReadyResponse>, Status>

pub async fn get_pricing(
    &mut self,
    request: impl IntoRequest<PricingRequests>
) -> Result<Response<PricingResponse>, Status>

Trait Implementations

impl Client<RpcServiceClient<Channel>> for GrpcClient<RpcServiceClient<Channel>>

type ReadyRequest = ReadyRequest

The type expected for ReadyRequest structs.

type ReadyResponse = ReadyResponse

The type expected for ReadyResponse structs.

type PricingRequests = PricingRequests

The type expected for PricingRequests structs.

type PricingResponse = PricingResponse

The type expected for PricingResponse structs.

fn is_ready<'life0, 'async_trait>(
    &'life0 self,
    request: Self::ReadyRequest
) -> Pin<Box<dyn Future<Output = Result<Response<Self::ReadyResponse>, Status>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,

Returns a tonic::Response containing a ReadyResponse Takes an ReadyRequest.

fn get_pricing<'life0, 'async_trait>(
    &'life0 self,
    request: Self::PricingRequests
) -> Pin<Box<dyn Future<Output = Result<Response<Self::PricingResponse>, Status>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,

Returns a tonic::Response containing a PricingResponse Takes an PricingRequests.

impl ClientConnect<RpcServiceClient<Channel>> for GrpcClient<RpcServiceClient<Channel>>

fn connect<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<RpcServiceClient<Channel>, Error>> + Send + 'async_trait>>where
    Self: 'async_trait,
    'life0: 'async_trait,

Get a connected client object

fn get_client<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<T, Status>> + Send + 'async_trait, Global>>where
    'life0: 'async_trait,
    Self: Sync + 'async_trait,

Get a copy of the connected client

impl<T: Clone> Clone for RpcServiceClient<T>

fn clone(&self) -> RpcServiceClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for RpcServiceClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.