Struct cueball::connection_pool::ConnectionPool

pub struct ConnectionPool<C, R, F> where
    C: Connection,
    R: Resolver,
    F: FnMut(&Backend) -> C + Send + 'static,  { /* fields omitted */ }

A pool of connections to a multi-node service

Implementations

impl<C, R, F> ConnectionPool<C, R, F> where
    C: Connection,
    R: Resolver,
    F: FnMut(&Backend) -> C + Send + 'static, 

pub fn new(
    cpo: ConnectionPoolOptions,
    resolver: R,
    create_connection: F
) -> Self

pub fn stop(&mut self) -> Result<(), Error>

Stop the connection pool and resolver and close all connections in a graceful manner. This function may only be called on the original ConnectionPool instance. Thread JoinHandles may not be cloned and therefore invocation of this function by a clone of the pool results in an error. This function will block the caller until all claimed threads are returned to the pool and are closed and until all worker threads except for the thread running the resolver have exited.

pub fn claim(&self) -> Result<PoolConnection<C, R, F>, Error>

pub fn try_claim(&self) -> Option<PoolConnection<C, R, F>>

pub fn get_stats(&self) -> Option<ConnectionPoolStats>

pub fn get_state(&self) -> String

Trait Implementations

impl<C, R, F> Clone for ConnectionPool<C, R, F> where
    C: Connection,
    R: Resolver,
    F: FnMut(&Backend) -> C + Send, 

fn clone(&self) -> ConnectionPool<C, R, F>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Debug, R: Debug, F: Debug> Debug for ConnectionPool<C, R, F> where
    C: Connection,
    R: Resolver,
    F: FnMut(&Backend) -> C + Send, 

fn fmt(&self, f: &mut Formatter) -> FmtResult

Formats the value using the given formatter.

impl<C, R, F> Drop for ConnectionPool<C, R, F> where
    C: Connection,
    R: Resolver,
    F: FnMut(&Backend) -> C + Send, 

fn drop(&mut self)

Executes the destructor for this type.