Struct SessionStatusTracker 

pub struct SessionStatusTracker { /* private fields */ }

Tracks the status of all active sessions.

Thread-safe via interior Mutex. Status changes are published to an optional EventBus.

Implementations

impl SessionStatusTracker

pub fn new() -> Self

Create a new tracker without event publishing.

pub fn with_event_bus(event_bus: EventBus) -> Self

Create a new tracker that publishes status changes to the event bus.

pub fn get(&self, session_id: &str) -> SessionStatus

Get the current status of a session.

Returns SessionStatus::Idle if the session has no tracked status.

pub fn set(&self, session_id: impl Into<String>, status: SessionStatus)

Set the status of a session.

Setting Idle removes the session from tracking (it’s the default). Publishes a SessionStatusChanged event if an event bus is configured.

pub fn set_busy(&self, session_id: impl Into<String>)

Mark a session as busy.

pub fn set_idle(&self, session_id: impl Into<String>)

Mark a session as idle.

pub fn set_retry( &self, session_id: impl Into<String>, attempt: u32, message: impl Into<String>, next_retry_ms: u64, )

Mark a session as retrying.

pub fn list(&self) -> HashMap<String, SessionStatus>

Get all tracked sessions and their statuses.

pub fn active_count(&self) -> usize

Get the number of tracked (non-idle) sessions.

pub fn has_retrying(&self) -> bool

Check if any session is currently retrying.

Trait Implementations

impl Debug for SessionStatusTracker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SessionStatusTracker

fn default() -> Self

Returns the “default value” for a type.