Struct ConnectionPool

pub struct ConnectionPool {
    pub semaphore: Arc<Semaphore>,
    /* private fields */
}

Connection manager for Unix socket connections.

Creates fresh connections per request (pooling disabled to prevent response mixing). Uses semaphore to limit concurrent connections.

Fields

semaphore: Arc<Semaphore>

Semaphore for limiting concurrent connections

Implementations

impl ConnectionPool

pub fn new(socket_path: String, max_connections: usize) -> Self

pub async fn acquire_with_permit( &self, permit: Option<OwnedSemaphorePermit>, ) -> Result<PooledConnection<'_>, PluginError>

Acquire a connection. Always creates a fresh connection to prevent response mixing. Uses semaphore for concurrency limiting. Accepts optional pre-acquired permit for fast path optimization.

pub async fn acquire(&self) -> Result<PooledConnection<'_>, PluginError>

Convenience method for acquiring without pre-acquired permit

pub fn release(&self, conn: PoolConnection)

Release a connection (closes the socket)

pub fn next_connection_id(&self) -> usize

Get the next connection ID from the atomic counter. This is useful for creating connections outside the pool (e.g., shutdown requests).