Struct SnapshotManager 

pub struct SnapshotManager { /* private fields */ }

Manages a directory of numbered snapshot files.

All operations are synchronous (no async I/O) to keep things simple and testable. In production the caller is responsible for spawning these calls onto a blocking thread via tokio::task::spawn_blocking.

Implementations

impl SnapshotManager

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

Create a SnapshotManager that stores files in snapshot_dir.

The directory is created if it does not yet exist.

pub fn write_snapshot(&self, id: u64, data: &[u8]) -> ServerResult<SnapshotMeta>

Compress data with LZ4 and write it to disk as snapshot id.

Returns SnapshotMeta describing the written file.

pub fn read_snapshot(&self, id: u64) -> ServerResult<Vec<u8>>

Read back the snapshot with the given id and decompress it.

Returns an error if the file is missing, the header is corrupted, the checksum does not match, or LZ4 decompression fails.

pub fn list_snapshots(&self) -> ServerResult<Vec<SnapshotMeta>>

List all available snapshots, sorted by ID descending (newest first).

pub fn delete_snapshot(&self, id: u64) -> ServerResult<()>

Delete the snapshot file for id.

Returns an error if the file does not exist.

impl SnapshotManager

pub fn set_uploader(&mut self, uploader: Arc<dyn SnapshotUploader>)

Attach an uploader to this manager.

pub fn upload(&self, id: u64) -> ServerResult<String>

Upload the local snapshot with id via the configured uploader.

Returns the remote URI on success, or an error if no uploader is set or the snapshot does not exist locally.

pub fn restore_from_remote( &self, uri: &str, local_id: u64, ) -> ServerResult<SnapshotMeta>

Download a snapshot from uri and store it locally under local_id.

Returns the SnapshotMeta of the newly written local snapshot.