Struct SessionRegistry 

pub struct SessionRegistry {
    pub sessions: RwLock<HashMap<String, Arc<Mutex<Session>>>>,
    /* private fields */
}

Fields

sessions: RwLock<HashMap<String, Arc<Mutex<Session>>>>

Implementations

impl SessionRegistry

pub fn new() -> SessionRegistry

pub fn with_persistence<P>(dir: P) -> Result<SessionRegistry, Error>

where P: AsRef<Path>,

pub async fn persist_snapshot(&self) -> Result<(), Error>

Snapshot every session (locking each briefly) and persist. Never holds the map lock across the per-session locks or the fs write.

pub async fn get_shared(&self, session_id: &str) -> Option<Arc<Mutex<Session>>>

Clone the shared handle for a session (brief map read; no session lock).

pub async fn get_session(&self, session_id: &str) -> Option<Session>

pub async fn get_all_sessions(&self) -> Vec<Session>

pub async fn insert_recovered_session( &self, session_id: String, session: Session, )

pub async fn count_open_sessions_for_initiator(&self, sender: &str) -> usize

Trait Implementations

impl Default for SessionRegistry

fn default() -> SessionRegistry

Returns the “default value” for a type.