Struct ReadPool 

pub struct ReadPool { /* private fields */ }

A bounded pool of reader connections. Clones share one pool.

Implementations

impl ReadPool

pub fn get(&self) -> Result<PooledReadConnection>

Checks out an idle reader, opens a new one while under the cap, or waits for a return. Fails with DbError::ReadPoolClosed once the pool is closed, including while waiting.

pub fn close(&self)

Stops handing out readers and drops the idle ones now. A reader still checked out closes when it is returned. Calling it again does nothing.

pub fn close_and_wait(&self, timeout: Duration) -> Result<()>

Self::close, then waits up to timeout for every checked-out reader to be returned. Ok(()) means every connection is closed and its database file released. Otherwise it returns DbError::ReadPoolCloseTimeout with the number still out. Do not call it while holding a reader from this pool: that reader cannot come back, so the call times out. A timeout too large for the clock waits in bounded slices until the readers return.

pub fn capacity(&self) -> usize

pub fn idle_len(&self) -> usize

pub fn total_len(&self) -> usize

Trait Implementations

impl Clone for ReadPool

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.