Struct SyncCheckpoint 

pub struct SyncCheckpoint { /* private fields */ }

Manages sync session checkpointing for crash recovery.

Tracks which entries have been processed, failed, or skipped during a sync session so that interrupted syncs can resume without re-downloading already-transferred blobs.

Implementations

impl SyncCheckpoint

pub fn new(database: &NodeDatabase, namespace_id: NamespaceId) -> Self

Create a new checkpoint manager for the given namespace.

pub fn session_id(&self) -> &str

The current session ID.

pub const fn namespace_id(&self) -> NamespaceId

The namespace ID for this checkpoint.

pub fn create_session( database: &NodeDatabase, namespace_id: NamespaceId, ) -> Result<Self>

Create a new sync session in the database and return the checkpoint.

Errors

Returns an error if the database write fails.

pub fn mark_completed( &self, entry_key: &[u8], hash: Hash, size: u64, ) -> Result<()>

Mark an entry as completed (downloaded successfully).

Errors

Returns an error if the database write fails.

pub fn mark_failed(&self, entry_key: &[u8], error: &str) -> Result<()>

Mark an entry as failed with error message.

Errors

Returns an error if the database write fails.

pub fn mark_skipped( &self, entry_key: &[u8], hash: Hash, size: u64, ) -> Result<()>

Mark an entry as skipped (already present locally or deleted).

Errors

Returns an error if the database write fails.

pub fn completed_entries(&self) -> Result<Vec<EntryProgress>>

Get all completed entries for this session (for resume filtering).

Errors

Returns an error if the database query fails.

pub fn failed_entries(&self) -> Result<Vec<EntryProgress>>

Get all failed entries for this session (for retry).

Errors

Returns an error if the database query fails.

pub fn completed_keys(&self) -> Result<HashSet<Vec<u8>>>

Get all completed entry keys as a HashSet for fast lookup.

Errors

Returns an error if the database query fails.

pub fn progress(&self) -> Result<CheckpointProgress>

Get overall progress.

Errors

Returns an error if the database query fails.

pub fn complete(&self) -> Result<()>

Mark session as completed.

Errors

Returns an error if the database write fails.

pub const fn leave_unfinished(&self) -> Result<()>

Leave the session status as running so it is picked up on resume.

Unlike complete, this does not persist a terminal status. The checkpoint remains active for the next daemon start.

Errors

This method always returns Ok(()).

pub fn delete(&self) -> Result<()>

Delete the checkpoint and its entries.

Errors

Returns an error if the database write fails.

pub fn resume( database: &NodeDatabase, namespace_id: NamespaceId, ) -> Result<Option<Self>>

Load the most recent unfinished checkpoint for a folder.

Returns None if no unfinished checkpoint exists.

Errors

Returns an error if the database query fails.

Trait Implementations

impl Clone for SyncCheckpoint

fn clone(&self) -> SyncCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncCheckpoint

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.