Struct Checkpoint 

pub struct Checkpoint {
    pub last_completed_step: Option<String>,
    pub completed_steps: Vec<String>,
    pub in_progress_step: Option<String>,
    pub cursor_step: Option<String>,
    pub cursor: Option<Vec<u8>>,
    pub schema_version: u32,
    pub step_set_hash: String,
    pub crashes_by_step: Vec<(String, u32)>,
}

Durable progress within a resumable job.

Fields

last_completed_step: Option<String>

completed_steps: Vec<String>

Completed steps in execution order. Replay compares them positionally.

in_progress_step: Option<String>

The step recorded before its side effects began.

cursor_step: Option<String>

cursor: Option<Vec<u8>>

Stored outside checkpoint JSON to avoid base64 encoding native binary data.

schema_version: u32

step_set_hash: String

crashes_by_step: Vec<(String, u32)>

Implementations

impl Checkpoint

pub fn resumability( &self, current_version: u32, current_step_set_hash: &str, ) -> Resume

Decide whether a checkpoint can continue against the current task definition.

Trait Implementations

impl Clone for Checkpoint

fn clone(&self) -> Checkpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Checkpoint

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

Formats the value using the given formatter.

impl Default for Checkpoint

fn default() -> Checkpoint

Returns the “default value” for a type.

impl PartialEq for Checkpoint

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Checkpoint