Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing LANCE client connections, ensuring we reuse TCP/TLS sessions per Architecture §14 instead of spawning new ones per request. The pool keeps pre-warmed connections, enforces max/idle caps, and wires up background health checks so ingestion/consumer threads avoid blocking on connect storms.

Implementations

impl ConnectionPool

pub async fn new( addr: &str, config: ConnectionPoolConfig, ) -> Result<Self, ClientError>

Creates a new connection pool bound to the provided address in keeping with Architecture §14’s pinning and reuse strategy.

Arguments

• addr - Target endpoint ("host:port") shared by pooled clients.
• config - Pool configuration describing capacity, timeouts, and TLS.

Returns

• Result<Self> - Ready-to-use pool with min_idle connections opened and a health-check task running (if enabled).

Errors

Propagates connection failures when seeding initial idle clients.

pub async fn get(&self) -> Result<PooledClient, ClientError>

Acquires a pooled connection, respecting the configured acquire timeout and returning the RAII guard used throughout the client APIs.

Returns

• Result<PooledClient> - Guard wrapping the loaned connection.

Errors

• ClientError::Timeout if acquisition exceeds acquire_timeout.
• ClientError::ConnectionClosed if the semaphore is closed.

pub fn stats(&self) -> PoolStats

Get pool statistics

pub async fn close(&self)

Gracefully shuts down the pool, clearing idle connections and marking future get calls as invalid per Architecture §14 teardown guidance.