Struct DatabasePool 

pub struct DatabasePool { /* private fields */ }

Database connection pool

Implementations

impl DatabasePool

pub async fn new(config: DatabaseConfig) -> Result<Self>

Create a new database pool

pub fn from_pool(pool: SqlitePool) -> Self

Create a DatabasePool from an existing SqlitePool

pub async fn warmup(&self, target_connections: Option<u32>) -> Result<u32>

Warm up the connection pool

Pre-populates the pool with connections to avoid cold start latency. This is useful during application startup to ensure connections are ready before handling requests.

Arguments

• target_connections - Number of connections to pre-create (defaults to min_connections)

Example

let pool = DatabasePool::new(config).await?;
pool.warmup(Some(5)).await?; // Pre-create 5 connections

pub async fn migrate(&self) -> Result<()>

Run database migrations

pub fn pool(&self) -> &SqlitePool

Get a reference to the underlying pool

pub async fn health_check(&self) -> Result<()>

Check if database is healthy

pub async fn begin(&self) -> Result<Transaction<'static, Sqlite>>

Begin a new transaction

pub async fn transaction<F, T, Fut>(&self, f: F) -> Result<T>

where F: FnOnce(Transaction<'static, Sqlite>) -> Fut, Fut: Future<Output = Result<(Transaction<'static, Sqlite>, T)>>,

Execute a closure within a transaction The transaction is committed if the closure returns Ok, rolled back otherwise

pub fn stats(&self) -> PoolStats

Get pool statistics

pub fn metrics(&self) -> PoolMetrics

Get comprehensive pool metrics including health status

pub fn health_status(&self) -> PoolHealth

Get pool health status based on utilization and state

pub async fn close(&self)

Close the pool gracefully

pub fn is_closed(&self) -> bool

Check if the pool is closed

pub async fn acquire(&self) -> Result<PoolConnection<Sqlite>>

Acquire a connection from the pool

pub fn export_metrics(&self) -> HashMap<String, f64>

Export metrics in a format suitable for monitoring systems

Returns a map of metric names to values for integration with monitoring systems like Prometheus, DataDog, etc.

Trait Implementations

impl Clone for DatabasePool

fn clone(&self) -> DatabasePool

Returns a duplicate of the value.

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

Performs copy-assignment from source.