Struct FileDurableSessionStore 

pub struct FileDurableSessionStore { /* private fields */ }

Durable store that persists lease/snapshot/journal state to local files.

This backend is suitable for single-host durable recovery and conformance testing. Multi-node distributed deployments should still use a shared backend implementation.

Implementations

impl FileDurableSessionStore

pub fn new(root_dir: impl Into<PathBuf>) -> Self

Trait Implementations

impl Clone for FileDurableSessionStore

fn clone(&self) -> FileDurableSessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DurableSessionStore for FileDurableSessionStore

fn acquire_lease( &self, request: DurableLeaseRequest, ) -> Result<DurableLeaseGrant, DurableStoreError>

fn renew_lease( &self, session_id: &str, node_id: &str, fence_token: u64, ttl_ms: u64, ) -> Result<DurableLeaseGrant, DurableStoreError>

fn release_lease(&self, session_id: &str, node_id: &str, fence_token: u64)

fn load_record(&self, session_id: &str) -> Option<DurableSessionRecord>

fn save_snapshot(&self, session_id: &str, snapshot: DurableSessionSnapshot)

fn append_journal_entry( &self, session_id: &str, node_id: &str, fence_token: u64, message: ClientMessage, max_journal: usize, ) -> Result<DurableJournalEntry, DurableStoreError>

fn set_node_draining(&self, node_id: &str, draining: bool)

fn is_node_draining(&self, node_id: &str) -> bool