Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing database connections

This pool provides:

• Concurrency limits via semaphore (max_connections)
• Connection health validation
• Performance metrics
• Graceful shutdown

Implementations

impl ConnectionPool

pub async fn new(db: Arc<Database>, config: PoolConfig) -> Result<Self>

Create a new connection pool

Arguments

• db - Database instance to create connections from
• config - Pool configuration

Example

use std::sync::Arc;
use libsql::Builder;
use do_memory_storage_turso::pool::{ConnectionPool, PoolConfig};

let db = Builder::new_local("test.db").build().await?;
let config = PoolConfig::default();
let pool = ConnectionPool::new(Arc::new(db), config).await?;

pub async fn get(&self) -> Result<PooledConnection>

Get a connection from the pool

This will:

1. Wait for a semaphore permit (respects max_connections limit)
2. Create a new connection from the database
3. Optionally validate the connection health
4. Return a PooledConnection guard that releases the permit on drop

Errors

Returns error if:

• Timeout waiting for available connection slot
• Failed to create connection
• Connection health check fails

pub async fn statistics(&self) -> PoolStatistics

Get current pool statistics

pub async fn utilization(&self) -> f32

Get current pool utilization (0.0 to 1.0)

pub async fn available_connections(&self) -> usize

Get number of available connection slots

pub async fn has_capacity(&self) -> bool

Check if pool has available capacity

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

Gracefully shutdown the pool

Waits for active connections to be returned (up to 30 seconds).