Struct DistributedSessionManager 

pub struct DistributedSessionManager { /* private fields */ }

Manages concurrent distributed inference sessions.

The manager is cheap to clone because all state is held behind an Arc-guarded lock. Clone the manager to share it across threads or async tasks.

Thread safety

All public methods acquire a short-lived read or write lock on the internal registry. Metrics are updated via lock-free atomics.

Implementations

impl DistributedSessionManager

pub fn new() -> Self

Create a new, empty session manager.

pub fn create_session( &self, goal: &str, peers: Vec<PeerId>, ) -> Result<SessionId, SessionError>

Create a new distributed inference session.

Errors

• SessionError::CapacityExceeded when there are already MAX_CONCURRENT_SESSIONS active sessions.
• SessionError::IdGeneration when OS entropy is unavailable.

pub fn set_running(&self, id: &SessionId) -> Result<(), SessionError>

Transition a session to SessionStatus::Running.

Only valid from the SessionStatus::Pending state.

Errors

• SessionError::NotFound when id is not registered.
• SessionError::InvalidTransition when the current state is not Pending.

pub fn set_completed( &self, id: &SessionId, result_cid: Option<String>, ) -> Result<(), SessionError>

Transition a session to SessionStatus::Completed.

Valid from either Pending or Running.

Errors

• SessionError::NotFound when id is not registered.
• SessionError::InvalidTransition when the state is not Pending or Running.

pub fn set_failed( &self, id: &SessionId, reason: impl Into<String>, ) -> Result<(), SessionError>

Transition a session to SessionStatus::Failed.

Valid from either Pending or Running.

Errors

• SessionError::NotFound when id is not registered.
• SessionError::InvalidTransition when the state is terminal.

pub fn cancel_session(&self, id: &SessionId) -> Result<(), SessionError>

Cancel a session.

The session is transitioned to SessionStatus::Cancelled. Only non-terminal sessions (Pending, Running) may be cancelled.

Errors

• SessionError::NotFound when id is not registered.
• SessionError::InvalidTransition when the session is already in a terminal state.

pub fn session_status(&self, id: &SessionId) -> Option<SessionStatus>

Return the current status of a session, or None if it does not exist.

pub fn session_goal(&self, id: &SessionId) -> Option<String>

Return the goal string associated with a session.

pub fn session_peers(&self, id: &SessionId) -> Option<Vec<PeerId>>

Return the peers associated with a session.

pub fn active_count(&self) -> usize

Return the number of sessions currently in the registry.

This includes both active and terminal (Completed / Failed / Cancelled) sessions that have not yet been garbage-collected.

pub fn gc_expired_sessions(&self, max_age: Duration) -> usize

Remove sessions whose created_at age exceeds max_age.

This includes sessions in any state (Pending, Running, Completed, Failed, Cancelled) that are older than the threshold. The method returns the number of sessions that were removed.

pub fn metrics(&self) -> &SessionMetrics

Return a reference to the live metrics object.

Use SessionMetrics::snapshot to get a plain-value copy.

Trait Implementations

impl Clone for DistributedSessionManager

fn clone(&self) -> DistributedSessionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DistributedSessionManager

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

Formats the value using the given formatter.

impl Default for DistributedSessionManager

fn default() -> Self

Returns the “default value” for a type.