Struct OpSnapshot 

pub struct OpSnapshot {
    pub head: Vec<u8>,
    pub files: Vec<StateFile>,
    pub incremental: bool,
}

What a task checkpoints at a barrier: a small head written every epoch, and zero or more immutable files uploaded once. A source, or an operator whose whole state is the head, has no files (OpSnapshot::whole).

Fields

head: Vec<u8>

files: Vec<StateFile>

incremental: bool

true: the head is an incremental head (its files travel apart, possibly none this epoch); false: a whole snapshot. Restore must route on this, not on whether files is empty.

Implementations

impl OpSnapshot

pub fn whole(head: Vec<u8>) -> OpSnapshot

A whole-state snapshot: all of it in the head, no separate files.

pub fn head_with_files(head: Vec<u8>, files: Vec<StateFile>) -> OpSnapshot

A file-backed incremental head plus the files it references (which may be empty this epoch).

Trait Implementations

impl Clone for OpSnapshot

fn clone(&self) -> OpSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpSnapshot

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

Formats the value using the given formatter.

impl Eq for OpSnapshot

impl PartialEq for OpSnapshot

fn eq(&self, other: &OpSnapshot) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for OpSnapshot