Struct InMemorySessions 

pub struct InMemorySessions { /* private fields */ }

Implementations

impl InMemorySessions

pub fn seed(&self, state: SessionState)

pub fn pending_of(&self, id: &SessionId) -> Vec<FactId>

Trait Implementations

impl Clone for InMemorySessions

fn clone(&self) -> InMemorySessions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemorySessions

fn default() -> InMemorySessions

Returns the “default value” for a type.

impl SessionRepository for InMemorySessions

async fn get_or_create( &self, id: &SessionId, memory_key: &MemoryKey, ) -> Result<SessionState, RepoError>

Fetch a session by id, creating it if absent (POC get_or_create).

async fn collect_expired( &self, _timeout: Duration, ) -> Result<Vec<(SessionId, SessionState)>, RepoError>

Return and remove sessions inactive for longer than timeout (POC collect_expired). Pairs (id, state) are returned so the caller can drain pending facts before the state is forgotten.

async fn snapshot_all( &self, ) -> Result<Vec<(SessionId, SessionState)>, RepoError>

Read-only snapshot of every session (POC snapshot_all).

async fn add_pending( &self, id: &SessionId, fact_ids: &[FactId], ) -> Result<(), RepoError>

Append fact ids to the pending list (deduplicating in place).

async fn remove_pending_owned( &self, id: &SessionId, owned: &[FactId], ) -> Result<(), RepoError>

Remove only the supplied ids, preserving any concurrent additions (parity with SessionState::remove_owned).

async fn clear_session(&self, id: &SessionId) -> Result<(), RepoError>

Drop the session entirely.

async fn dedup_and_mark( &self, id: &SessionId, _memory_key: &MemoryKey, candidate_ids: &[FactId], ) -> Result<Vec<FactId>, RepoError>

ATOMIC dedup + mark in a single transaction (POC select_new_facts).

async fn save( &self, id: &SessionId, state: &SessionState, ) -> Result<(), RepoError>

Persist a (possibly mutated) SessionState back to storage.