Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Implementations

impl SessionManager

pub fn new(ttl: Duration, max_turns: usize) -> Self

Creates the manager and spawns the background TTL sweeper.

pub fn with_cap(ttl: Duration, max_turns: usize, max_sessions: usize) -> Self

Creates the manager with a custom concurrent-session cap. Values of 0 disable the cap (unbounded).

pub fn create(&self, agent_id: impl Into<String>) -> Session

pub fn get(&self, id: Uuid) -> Option<Session>

Returns the session, updating last_access. Returns None if not found.

pub fn get_or_create(&self, id: Uuid, agent_id: impl Into<String>) -> Session

Returns existing session or creates a new one bound to agent_id.

pub fn update(&self, session: Session) -> bool

Replaces session state. Returns false if the session does not exist.

The replacement is atomic via DashMap’s get_mut entry lock — this prevents a race where delete() runs between a check and insert and the update silently resurrects the removed session.

pub fn push_message(&self, id: Uuid, interaction: Interaction) -> bool

Atomically append an interaction to the session’s history while holding the DashMap entry lock. The older pattern — clone → mutate clone → update(clone) — could drop history when two handlers raced on the same session (both read the pre-trim state, both pushed their entry, the second overwrote the first’s trim). Returns false if the session no longer exists.

pub fn delete(&self, id: Uuid) -> bool

Removes a session and fires every registered on_expire callback. Returns true if it existed.

pub fn active_count(&self) -> usize

pub fn on_expire<F>(&self, f: F)

where F: Fn(Uuid) + Send + Sync + 'static,

Register a callback fired when a session is dropped — either by explicit delete() or by the TTL sweeper. Each invocation runs on its own tokio::spawn, so callbacks must not assume caller context and should capture owned handles (Arc clones) from the closure’s environment. Safe to call multiple times; callbacks fire in the registration order snapshot at the moment of expiry.

Trait Implementations

impl Clone for SessionManager

fn clone(&self) -> SessionManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.