Struct ConnectionPool 

pub struct ConnectionPool<S: SessionStore> { /* private fields */ }

Manages daemon connections, one active slot per session id.

Implementations

impl<S: SessionStore + 'static> ConnectionPool<S>

pub fn new( daemon_url: impl Into<String>, store: Arc<S>, cfg: Option<PoolConfig>, ) -> Self

Construct a pool for daemon_url. cfg defaults via PoolConfig::default.

pub fn with_client_factory( self, f: Box<dyn Fn(&str) -> Client + Send + Sync>, ) -> Self

Override the client factory (logging/metrics wrappers, test fakes).

pub fn with_bootstrap( self, f: impl Fn(Client, String, String, String) -> Pin<Box<dyn Future<Output = Result<String>> + Send>> + Send + Sync + 'static, ) -> Self

Override loop bootstrap (loop_new + subscribe).

pub async fn stats(&self) -> PoolStats

Snapshot active and idle slot counts.

pub async fn acquire( &self, session_id: &str, workspace_id: &str, user_id: &str, ) -> Result<Arc<PooledConn>>

Acquire a live connection for session_id, bootstrapping or reattaching as needed.

The caller must call Self::release when the session connection should be torn down (TurnRunner keeps the slot active across turns on the same session).

pub async fn release(&self, session_id: &str)

Tear down the connection for session_id and return a fresh slot to the pool.

pub async fn reset_session(&self, session_id: &str)

Tear down the connection so the next acquire bootstraps fresh.

pub async fn stop(&self)

Gracefully shut down all active and idle connections.