Struct LocalContinuityStore 

pub struct LocalContinuityStore { /* private fields */ }

SQLite-backed ContinuityStore for the bundled persistent_state(path) path.

Stores ContinuityRecords and SessionSnapshots in a single SQLite database. Enforces compare-and-set on (fencing_token, checkpoint_version).

Implementations

impl LocalContinuityStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, ContinuityStoreError>

Open (or create) a local continuity store at the given path.

Errors

Returns ContinuityStoreError::Io if the database cannot be opened or the schema cannot be initialized.

pub fn in_memory() -> Result<Self, ContinuityStoreError>

Open an in-memory store (for testing).

Errors

Returns ContinuityStoreError::Io if initialization fails.

pub fn max_fencing_token(&self) -> Result<u64, ContinuityStoreError>

The highest fencing token ever committed to this store, across BOTH continuity_records and session_snapshots (0 if the store is empty).

The bundled LocalLeaseProvider seeds its monotonic counter from this on startup so fencing tokens keep advancing across process restarts. Without it the provider’s in-memory counter resets to 1 and restore presents a stale token that this store’s compare-and-set rejects — the v0.7.8 “stale fencing token: presented 1, current N” restart abort.

Errors

Returns ContinuityStoreError::Io on a query failure.

Trait Implementations

impl ContinuityStore for LocalContinuityStore

fn resolve_many<'life0, 'life1, 'async_trait>( &'life0 self, identities: &'life1 [AgentIdentity], ) -> Pin<Box<dyn Future<Output = Result<BTreeMap<AgentIdentity, ContinuityResolveState>, ContinuityStoreError>> + Send + 'async_trait>>

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

Resolve continuity state for the given identities.

fn load_session_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionSnapshot>, ContinuityStoreError>> + Send + 'async_trait>>

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

Load a previously saved session snapshot.

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

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

Delete a saved session snapshot only if its serialized session projection still matches expected_current_revision.

fn save_session_snapshot<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, identity: &'life1 AgentIdentity, session_id: &'life2 SessionId, generation: ContinuityGeneration, version: CheckpointVersion, fencing_token: FencingToken, snapshot: &'life3 SessionSnapshot, ) -> Pin<Box<dyn Future<Output = Result<(), ContinuityStoreError>> + Send + 'async_trait>>

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

Save a session snapshot with fencing and identity-generation version preconditions.

fn upsert_continuity_record<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 ContinuityRecord, fencing_token: FencingToken, ) -> Pin<Box<dyn Future<Output = Result<(), ContinuityStoreError>> + Send + 'async_trait>>

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

Upsert a continuity record with fencing precondition.

fn delete_continuity_record<'life0, 'life1, 'async_trait>( &'life0 self, identity: &'life1 AgentIdentity, fencing_token: FencingToken, ) -> Pin<Box<dyn Future<Output = Result<(), ContinuityStoreError>> + Send + 'async_trait>>

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

Delete a continuity record and associated session snapshots.