Struct RpcClientPool

pub struct RpcClientPool<S> {
    pub(crate) connection_pool_size: u16,
    pub(crate) clients: Cache<HostAddr, Arc<Vec<S>>>,
}

Fields

connection_pool_size: u16

clients: Cache<HostAddr, Arc<Vec<S>>>

Implementations

impl<S> RpcClientPool<S>

where S: RpcClient,

pub fn new(connection_pool_size: u16) -> Self

Create a new pool with the given connection_pool_size, which is the number of connections to each node that will be reused.

pub fn for_test() -> Self

Create a pool for testing purposes. Same as Self::adhoc.

pub fn adhoc() -> Self

Create a pool for ad-hoc usage, where the number of connections to each node is 1.

pub async fn get(&self, node: &WorkerNode) -> Result<S>

Gets the RPC client for the given node. If the connection is not established, a new client will be created and returned.

pub async fn get_by_addr(&self, addr: HostAddr) -> Result<S>

Gets the RPC client for the given addr. If the connection is not established, a new client will be created and returned.

pub fn invalidate_all(&self)

Trait Implementations

impl<S: Clone> Clone for RpcClientPool<S>

fn clone(&self) -> RpcClientPool<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> Debug for RpcClientPool<S>

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

Formats the value using the given formatter.

impl<S> !Default for RpcClientPool<S>

Intentionally not implementing Default to let callers be explicit about the pool size.