Struct ConnectionPool 

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

Maps chat sessions to daemon loops.

Implementations

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

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

Create a pool.

pub async fn stats(&self) -> PoolStats

Snapshot stats.

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

Acquire (or bootstrap) a connection for a session.

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

Release session connection back to idle.

pub async fn reset_session(&self, session_id: &str) -> Result<()>

Reset session (close + clear loop binding).

pub async fn stop(&self)

Stop pool and close all connections.