Struct ConnectionPool 

pub struct ConnectionPool {
    pub db_path: PathBuf,
    pub max_connections: usize,
    /* private fields */
}

Connection pool for database connections.

The pool limits the number of concurrent connections using a semaphore permit system.

Examples

use forgekit_core::pool::ConnectionPool;

let pool = ConnectionPool::new("/path/to/db.sqlite", 10);

// Acquire a connection
let _permit = pool.acquire().await?;
// Use connection here

Fields

db_path: PathBuf

Path to the database file.

max_connections: usize

Maximum number of connections.

Implementations

impl ConnectionPool

pub fn new(db_path: impl AsRef<Path>, max_connections: usize) -> Self

Creates a new connection pool.

Arguments

• db_path - Path to the SQLite database file
• max_connections - Maximum number of concurrent connections

Examples

use forgekit_core::pool::ConnectionPool;

let pool = ConnectionPool::new("./db.sqlite", 10);

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

Acquires a permit from the pool.

This will wait until a connection is available. The permit is released when dropped.

Returns

A ConnectionPermit that represents the acquired connection.

Examples

let permit = pool.acquire().await?;
// Use connection
drop(permit); // Release back to pool

pub fn available_connections(&self) -> usize

Returns the current number of available connections.

Examples

let available = pool.available_connections();
println!("Available connections: {}", available);

pub async fn try_acquire(&self) -> Option<ConnectionPermit>

Tries to acquire a permit without waiting.

Returns

• Some(permit) if a connection is immediately available
• None if all connections are in use

Examples

if let Some(permit) = pool.try_acquire().await {
    // Use connection
} else {
    // No connection available
}

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> ConnectionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.