Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Store of all sessions managed by the VM.

Provides type lookup/update methods that match the Lean SessionStore.lookupType / SessionStore.updateType pattern.

Implementations

impl SessionStore

pub fn new() -> Self

Create an empty session store.

pub fn open_with_sid( &mut self, sid: SessionId, roles: Vec<String>, buffer_config: &BufferConfig, initial_types: &BTreeMap<String, LocalTypeR>, ) -> SessionId

Open a new session with an externally supplied session id.

Callers should source ids from SessionStore::next_session_id().

pub fn open_with_sid_from_plan( &mut self, sid: SessionId, plan: &SessionOpenPlan, buffer_config: &BufferConfig, ) -> SessionId

Open a new session from a reusable precomputed open plan.

pub fn open( &mut self, roles: Vec<String>, buffer_config: &BufferConfig, initial_types: &BTreeMap<String, LocalTypeR>, ) -> SessionId

Open a new session with the given roles, buffer config, and initial local types.

Returns the session ID. Endpoints are constructed as Endpoint { sid, role }.

pub fn next_session_id(&self) -> SessionId

Next session identifier that will be allocated by open.

pub fn lookup_type(&self, ep: &Endpoint) -> Option<&LocalTypeR>

Lookup the current local type for an endpoint.

Matches Lean SessionStore.lookupType.

pub fn update_type(&mut self, ep: &Endpoint, new_type: LocalTypeR)

Update the local type for an endpoint (type advancement on commit).

Matches Lean SessionStore.updateType.

pub fn update_original(&mut self, ep: &Endpoint, new_original: LocalTypeR)

Update the original type (when entering a new Mu scope).

pub fn original_type(&self, ep: &Endpoint) -> Option<&LocalTypeR>

Get the original type for recursive unfolding.

pub fn remove_type(&mut self, ep: &Endpoint)

Remove type entry (on Halt/End — session endpoint completed).

pub fn get(&self, sid: SessionId) -> Option<&SessionState>

Get a reference to a session.

pub fn get_mut(&mut self, sid: SessionId) -> Option<&mut SessionState>

Get a mutable reference to a session.

pub fn iter(&self) -> impl Iterator<Item = &SessionState>

Iterate over all sessions.

pub fn close(&mut self, sid: SessionId) -> Result<(), String>

Close a session.

Errors

Returns an error if the session is not found.

pub fn closed_session_ids(&self) -> Vec<SessionId>

Closed/cancelled/faulted session identifiers still resident in the store.

pub fn reap_sessions( &mut self, session_ids: &[SessionId], ) -> Vec<ClosedSessionSummary>

Reap specific session ids from live storage and archive compact summaries.

Panics

Panics if a session disappears between the initial residency/status check and the subsequent removal from the store.

pub fn reap_closed(&mut self) -> Vec<ClosedSessionSummary>

Reap all closed/cancelled/faulted sessions from live storage.

pub fn active_count(&self) -> usize

Number of active sessions.

pub fn live_count(&self) -> usize

Number of sessions still resident in the store.

pub fn session_ids(&self) -> Vec<SessionId>

All session IDs.

pub fn archived_closed(&self) -> &[ClosedSessionSummary]

Archived closed-session summaries retained after reaping.

pub fn memory_usage(&self) -> SessionStoreMemoryUsage

Approximate retained state for the session store.

pub fn lookup_handler(&self, edge: &Edge) -> Option<&HandlerId>

Lookup edge-bound handler id.

pub fn default_handler_for_session(&self, sid: SessionId) -> Option<&HandlerId>

Lookup a default handler id for a session.

pub fn set_default_handler_for_session( &mut self, sid: SessionId, handler: HandlerId, )

Set the default handler id for a session.

pub fn update_handler(&mut self, edge: &Edge, handler: HandlerId)

Update edge-bound handler id.

pub fn lookup_trace(&self, edge: &Edge) -> Option<&[ValType]>

Lookup coherence trace for an edge.

pub fn update_trace(&mut self, edge: &Edge, trace: Vec<ValType>)

Update coherence trace for an edge.

Trait Implementations

impl Debug for SessionStore

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

Formats the value using the given formatter.

impl Default for SessionStore

fn default() -> SessionStore

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SessionStore

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SessionStore

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.