Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for coordinator client connections.

Manages a pool of connections with automatic reconnection, lifetime management, and configurable pool sizing.

Implementations

impl ConnectionPool

pub fn new(config: ConnectionPoolConfig) -> Self

Create a new connection pool with the given configuration.

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

Initialize the pool by creating min_idle connections.

pub async fn checkout(&self) -> Result<u64>

Checkout a connection from the pool.

Returns a connection ID that should be returned via checkin after use. If no idle connections are available and the pool is not at capacity, a new connection is created. Retries with exponential backoff on failure.

pub async fn checkin(&self, conn_id: u64) -> Result<()>

Return a connection to the pool after use.

pub async fn mark_broken(&self, conn_id: u64) -> Result<()>

Mark a connection as broken (will be removed on next cleanup).

pub async fn execute_with_retry<F, T>(&self, operation: F) -> Result<T>

where F: FnMut(u64) -> Result<T>,

Execute an operation with automatic retry on failure.

operation is a closure that receives a connection ID and returns Ok(T) on success or Err on failure. On failure, the connection is marked broken and a new one is obtained for the next attempt.

pub fn advance_tick(&self, millis: u64)

Advance the internal tick (for testing and lifetime management).

pub async fn stats(&self) -> PoolStats

Get current pool statistics.

pub async fn size(&self) -> usize

Get the current pool size.

pub async fn idle_count(&self) -> usize

Get the current number of idle connections.

pub fn retry_policy(&self) -> &RetryPolicy

Get the retry policy.

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

Perform health checks on idle connections, removing broken/expired ones.

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

Shut down the pool, closing all connections.