Struct svc_pricing_client_grpc::GrpcClient

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

Wrapper struct for our gRPC clients

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<T> Client<T> for GrpcClient<T>where
    T: Send + Clone,

fn invalidate<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>where
    'life0: 'async_trait,
    GrpcClient<T>: 'async_trait,

Invalidates the client if set

fn get_name(&self) -> String

Get name string for client

fn get_address(&self) -> String

Get connection string for client

fn get_inner(&self) -> &Arc<Mutex<Option<T>>>

Get GrpcClient inner value

fn new_client(server_host: &str, server_port: u16, name: &str) -> GrpcClient<T>

Create new GrpcClient

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 for GrpcClient<T>where
    T: Clone,

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for GrpcClient<T>where
    T: Debug,

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

Formats the value using the given formatter.