Struct ConnectionPool 

pub struct ConnectionPool<Connector: ClientConnector> { /* private fields */ }

A connection pool for protosocket rpc clients.

Protosocket-rpc connections are shared and multiplexed, so this vends cloned handles. You can hold onto a handle from the pool for as long as you want. There is a small synchronization cost to getting a handle from a pool, so caching is a good idea - but if you want to load balance a lot, you can just make a pool with as many “slots” as you want to dilute any contention on connection state locks. The locks are typically held for the time it takes to clone an Arc, so it’s usually nanosecond-scale synchronization, per connection. So if you have several connections, you’ll rarely contend.

Implementations

impl<Connector: ClientConnector> ConnectionPool<Connector>

pub fn new(connector: Connector, connection_count: usize) -> Self

Create a new connection pool.

It will try to maintain connection_count healthy connections.

pub async fn get_connection_for_key( &self, key: usize, ) -> Result<RpcClient<Connector::Request, Connector::Response>>

Get a consistent connection from the pool for a given key.

pub async fn get_connection( &self, ) -> Result<RpcClient<Connector::Request, Connector::Response>>

Get a connection from the pool.

Trait Implementations

impl<Connector: Debug + ClientConnector> Debug for ConnectionPool<Connector>

where Connector::Request: Debug, Connector::Response: Debug,

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

Formats the value using the given formatter.