Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

ConnectionPool represents pool of connections to DAPI nodes.

It can be cloned and shared between threads. Cloning the pool will create a new reference to the same pool.

Implementations

impl ConnectionPool

pub fn new(capacity: usize) -> Self

Create a new pool with a given capacity. The pool will evict the least recently used item when the capacity is reached.

Panics

Panics if the capacity is zero.

impl ConnectionPool

pub fn get( &self, prefix: PoolPrefix, uri: &Uri, settings: Option<&AppliedRequestSettings>, ) -> Option<PoolItem>

Get item from the pool for the given uri and settings.

Arguments

• prefix - Prefix for the item in the pool. Used to distinguish between Core and Platform clients.
• uri - URI of the node.
• settings - Applied request settings.

pub fn get_or_create<E>( &self, prefix: PoolPrefix, uri: &Uri, settings: Option<&AppliedRequestSettings>, create: impl FnOnce() -> Result<PoolItem, E>, ) -> Result<PoolItem, E>

Get value from cache or create it using provided closure. If value is already in the cache, it will be returned. If value is not in the cache, it will be created by calling create() and stored in the cache.

Arguments

• prefix - Prefix for the item in the pool. Used to distinguish between Core and Platform clients.
• uri - URI of the node.
• settings - Applied request settings.

pub fn put( &self, uri: &Uri, settings: Option<&AppliedRequestSettings>, value: PoolItem, )

Put item into the pool for the given uri and settings.

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> ConnectionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionPool

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

Formats the value using the given formatter.

impl Default for ConnectionPool

fn default() -> Self

Returns the “default value” for a type.