Struct ContinuitySessionStoreAdapter 

pub struct ContinuitySessionStoreAdapter { /* private fields */ }

Adapts a ContinuityStore to the Meerkat SessionStore interface.

On the external-authoritative path, this is the session persistence layer. No separate local SQLite is created under scratch_dir — the ContinuityStore is the single authoritative session truth.

The adapter maintains a session→identity registry populated by the runtime during restore/activate. This maps SessionId to the owning identity’s continuity parameters (identity, generation, fencing_token).

Implementations

impl ContinuitySessionStoreAdapter

pub fn new(store: Arc<dyn ContinuityStore>) -> Self

Trait Implementations

impl SessionStore for ContinuitySessionStoreAdapter

fn save<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = Result<(), SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a session (create or extend).

fn save_transcript_rewrite<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session: &'life1 Session, commit: &'life2 TranscriptRewriteCommit, ) -> Pin<Box<dyn Future<Output = Result<(), SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Save a same-SessionId transcript rewrite.

fn save_authoritative_projection<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = Result<(), SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a compatibility projection after a separate authority has already committed the session snapshot.

fn save_authoritative_projection_if_current_revision<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, expected_current_revision: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<(), SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save an authoritative projection only if the persisted row is still the revision that the caller already validated.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>, SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load a session by ID.

fn list<'life0, 'async_trait>( &'life0 self, _filter: SessionFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionMeta>, SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List sessions matching filter.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a session.

fn delete_if_current_revision<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 SessionId, expected_current_revision: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, SessionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Delete a compatibility projection only if it is still the revision that the caller already validated as unsafe to expose.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<bool, SessionStoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Check if a session exists.