Struct SnapshotManager

pub struct SnapshotManager {
    pub expected: usize,
    pub received: Vec<LocalSnapshot>,
    pub path: Option<PathBuf>,
    pub mode: SnapshotMode,
}

Manages the snapshot collection process

Fields

expected: usize

Number of snapshots expected to be collected

received: Vec<LocalSnapshot>

Vector of received local snapshots

path: Option<PathBuf>

Path to the last snapshot saved

mode: SnapshotMode

Snapshot mode

Implementations

impl SnapshotManager

pub fn new(expected: usize) -> Self

Creates a new snapshot manager expecting the given number of snapshots

pub fn push(&mut self, resp: SnapshotResponse) -> Option<GlobalSnapshot>

Adds a snapshot response to the collection

Returns a global snapshot if all expected snapshots have been received and they are consistent. If the snapshots are inconsistent, it will attempt to find a consistent subset by backtracking to the minimum vector clock values. all_received is defined by the state of our wave diffusion protocol

fn build_snapshot(&self, snaps: &[LocalSnapshot]) -> GlobalSnapshot

Builds a global snapshot from a set of local snapshots

Computes the union of all transactions and identifies missing transactions for each node.