Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Manages session lifecycle: create, suspend, resume, expire.

Framework-agnostic — the user’s WebSocket integration code is responsible for calling the lifecycle methods at the right times (on connect, on message, on disconnect).

Mirrors the Go SDK’s SessionManager and the Swift SDK’s SessionManager in shape.

Example

use hypen_server::remote::SessionManager;

let manager = SessionManager::new(Default::default());

// On connect:
let session = manager.create_session(Default::default());
manager.track_connection(&session.id, conn_id);

// On disconnect:
manager.untrack_connection(&session.id, conn_id);
if manager.connection_count(&session.id) == 0 {
    let state = /* snapshot state */;
    manager.suspend_session(&session.id, state, || { /* on expire */ });
}

// On reconnect (client sends hello with session_id):
if let Some(pending) = manager.resume_session(&session_id) {
    // Apply pending.saved_state to the new session
}

Implementations

impl SessionManager

pub fn new(config: SessionManagerConfig) -> Self

Create a new session manager with the given configuration.

pub fn create_session(&self, props: HashMap<String, Value>) -> SessionInfo

Create a new active session.

pub fn get_active_session(&self, id: &str) -> Option<SessionInfo>

Get an active session by ID.

pub fn suspend_session<F>( &self, id: &str, saved_state: Value, on_expire: F, ) -> bool

where F: FnOnce() + Send + 'static,

Suspend an active session with a saved state snapshot.

The on_expire callback fires after the TTL elapses without a reconnect. If resume_session is called before the TTL, the callback is cancelled.

Returns true if the session was suspended, false if no active session with the given ID exists.

pub fn resume_session(&self, id: &str) -> Option<PendingSession>

Resume a suspended session. Returns the pending session with its saved state, or None if the session is unknown or already expired.

pub fn destroy_session(&self, id: &str)

Destroy a session (active or pending), cancelling any TTL timer.

pub fn track_connection(&self, session_id: &str, conn_id: u64)

Track a connection for a session. conn_id should be a unique identifier for the connection (e.g. a monotonic counter or hash).

pub fn untrack_connection(&self, session_id: &str, conn_id: u64)

Untrack a connection.

pub fn connection_count(&self, session_id: &str) -> usize

Get the number of active connections for a session.

pub fn shutdown(&self)

Shut down the manager, cancelling all TTL timers.