Struct SyncStatePersistence 

pub struct SyncStatePersistence { /* private fields */ }

Sync state persistence manager

Provides durable storage for Automerge sync state to enable fast recovery after restart without full resync.

Implementations

impl SyncStatePersistence

pub fn open(path: impl AsRef<Path>) -> Result<SyncStatePersistence, Error>

Open or create sync state storage at the given path

pub fn open_with_interval( path: impl AsRef<Path>, checkpoint_interval: Duration, ) -> Result<SyncStatePersistence, Error>

Open with custom checkpoint interval

pub fn save_sync_state( &self, peer_id: &PublicKey, doc_key: &str, state: &State, sync_count: u64, ) -> Result<(), Error>

Save sync state for a peer and document

pub fn load_sync_state( &self, peer_id: &PublicKey, doc_key: &str, ) -> Result<Option<(State, u64)>, Error>

Load sync state for a peer and document

pub fn delete_sync_state( &self, peer_id: &PublicKey, doc_key: &str, ) -> Result<(), Error>

Delete sync state for a peer and document

pub fn load_all_for_peer( &self, peer_id: &PublicKey, ) -> Result<HashMap<String, State>, Error>

Load all sync states for a peer

pub fn load_all(&self) -> Result<HashMap<(PublicKey, String), State>, Error>

Load all sync states (for full recovery)

pub fn create_checkpoint(&self) -> Result<Checkpoint, Error>

Create a checkpoint

pub fn get_last_checkpoint(&self) -> Result<Option<Checkpoint>, Error>

Get the last checkpoint

pub fn stats(&self) -> Result<PersistenceStats, Error>

Get persistence statistics

pub fn cleanup_old_checkpoints(&self, keep_count: usize) -> Result<usize, Error>

Clean up old checkpoints, keeping only the last N

pub fn delete_peer(&self, peer_id: &PublicKey) -> Result<usize, Error>

Delete all sync state for a peer (when peer is removed from mesh)

pub fn checkpoint_interval(&self) -> Duration

Get checkpoint interval