Struct ConnectionPool

pub struct ConnectionPool<T: Driver, A: ConnectionAdapter<T>> { /* private fields */ }

Implementations

impl<T: Driver, A: ConnectionAdapter<T>> ConnectionPool<T, A>

pub fn new( config: ConnectionPoolConfig, ) -> Result<Arc<Self>, ConnectionPoolError<T::ConnectionError>>

Create a new connection pool with the given config.

The write connection is created first, followed by a read connection for every reader.

Errors

Returns error if the connections could not be initialized.

pub fn connection( self: &Arc<Self>, ) -> Result<PooledConnection<T, A>, ConnectionPoolError<T::Error>>

Retrieve a connection from the pool.

If all the connections are currently in use, we will wait until one is returned to the pool. If ConnectionPoolConfig.connection_acquire_timeout has no value, this method will block indefinitely.

Errors

Return error if we could not retrieve a connection from the pool before the timeout triggered.