Struct FileSessionStoreWal 

pub struct FileSessionStoreWal { /* private fields */ }

Durable append-only JSONL WAL under a FileSessionStore root.

Implementations

impl FileSessionStoreWal

pub fn new(store_root: impl AsRef<Path>) -> Self

pub fn path(&self) -> &Path

pub async fn load_entries(&self) -> Result<(Vec<SessionStoreWalEntryV1>, u64)>

Load every validated entry and return the next one-based sequence.

pub fn is_sequence_conflict(error: &Error) -> bool

Whether an open/load error is the fail-closed duplicate-sequence case.

pub async fn quarantine_corrupt(&self) -> Result<PathBuf>

Rename a corrupt WAL aside so a fresh log can be opened. Session snapshots under v1/sessions/ are left untouched.

pub async fn append(&self, entry: &SessionStoreWalEntryV1) -> Result<()>

Append one validated entry with a data sync so reopen can observe it.

pub async fn recover<F, Fut>(&self, snapshot_digest_for: F) -> Result<u64>

where F: FnMut(&str) -> Fut, Fut: Future<Output = Result<Option<String>>>,

Seal open intents whose durable snapshot already matches.

snapshot_digest_for returns the digest of the currently durable snapshot for a session, if any. Matching intents are acknowledged with a Committed record so crash recovery does not leave a generation half-published.