Struct RpcClient 

pub struct RpcClient { /* private fields */ }

Connects gRPC clients using a common set of deadline and concurrency safeguards.

Implementations

impl RpcClient

pub fn new(config: RpcClientConfig) -> Self

pub fn try_new(config: RpcClientConfig) -> Result<Self, RpcConfigError>

pub fn config(&self) -> &RpcClientConfig

pub async fn connect(&self) -> Result<Channel, RpcClientError>

pub fn connect_service( &self, registry: &ServiceRegistry, service: impl Into<String>, ) -> Result<Channel, RpcClientError>

Creates a channel that follows a service registry and balances calls across its endpoints.

Existing endpoints are installed before this method returns. A background task applies subsequent publications and withdrawals; it stops automatically when all channel clones have been dropped.

pub fn connect_discovered<S>(&self, subscription: S) -> Channel

where S: EndpointSubscription,

Creates a channel driven by any discovery backend that publishes complete snapshots.

Empty snapshots are supported and recover when endpoints appear. Malformed endpoints are ignored without poisoning the rest of a snapshot. The watcher exits when the discovery stream closes or all clones of the returned channel have been dropped.

pub fn connect_discovered_with_status<S>( &self, subscription: S, ) -> (Channel, DiscoveryStatus)

where S: EndpointSubscription,

Creates a weighted discovery channel and a watchable readiness handle.

Invalid endpoint URIs are excluded and make the snapshot degraded. When active health checking is configured, failed probes are removed until a later probe succeeds.

Trait Implementations

impl Clone for RpcClient

fn clone(&self) -> RpcClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RpcClient

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

Formats the value using the given formatter.