Struct sqlsrv::ConnPool

pub struct ConnPool { /* private fields */ }

SQLite connection pool.

This is a somewhat specialized connection pool that only allows a single writer but multiple readers.

Implementations

impl ConnPool

pub fn reader(&self) -> Result<PooledConnection<SqliteConnectionManager>, Error>

Acquire a read-only connection.

pub fn writer(&self) -> WrConn

Acquire the read/write connection.

If the writer is already taken, then block and wait for it to become available.

pub fn try_writer(&self) -> Option<WrConn>

Attempt to acquire the writer connection.

Returns Some(conn) if the writer connection was available at the time of the request. Returns None if the writer has already been taken.

pub fn ro_run<F>(&self, f: F) -> Result<(), Error>

where F: FnOnce(&Connection) + Send + 'static,

Run a closure with a read-only connection

pub fn ro_run_result<F, T, E>(&self, f: F) -> Result<WaitCtx<T, (), E>, Error>

where F: FnOnce(&Connection, SetCtx<T, (), E>) + Send + 'static, T: Send + 'static, E: Send + 'static,

Run a closure with read-only connection, returning a channel end-point for retreiving result.

pub fn rw_run<F>(&self, f: F)

where F: FnOnce(&mut Connection) + Send + 'static,

Run a closure with read/write connection

pub fn rw_run_result<F, T, E>(&self, f: F) -> WaitCtx<T, (), E>

where F: FnOnce(&mut Connection, SetCtx<T, (), E>) + Send + 'static, T: Send + 'static, E: Send + 'static,

Run a closure with read/write connection, returning a channel end-point for retreiving result.

pub fn incremental_vacuum(&self, n: Option<usize>) -> WaitCtx<(), (), Error>

Perform an incremental vacuum.

n is the number of freelist nodes to reclaim. If None all nodes will be reclaimed.

pub fn shutdown(self)

Consume self and wait for all threads in thread pool to complete.