pub struct RpcConnectionPool { /* private fields */ }Expand description
RPC connection pool for managing connections to multiple nodes
Implementations§
Source§impl RpcConnectionPool
impl RpcConnectionPool
Sourcepub fn get_client(&self, node_id: &str, address: &str) -> Arc<RpcClient>
pub fn get_client(&self, node_id: &str, address: &str) -> Arc<RpcClient>
Get or create a client for a node
Sourcepub fn remove_client(&self, node_id: &str)
pub fn remove_client(&self, node_id: &str)
Remove a client from the pool
Sourcepub fn connection_count(&self) -> usize
pub fn connection_count(&self) -> usize
Get number of active connections
Trait Implementations§
Auto Trait Implementations§
impl Freeze for RpcConnectionPool
impl !RefUnwindSafe for RpcConnectionPool
impl Send for RpcConnectionPool
impl Sync for RpcConnectionPool
impl Unpin for RpcConnectionPool
impl !UnwindSafe for RpcConnectionPool
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request