Struct CheckpointEvent 

pub struct CheckpointEvent {
    pub run_id: i64,
    pub step: u32,
    pub kind: String,
    pub detail: Option<String>,
}

One durable checkpoint-lifecycle event: a step was checkpointed, a run was resumed, or an already-committed step was skipped on resume. Together they make a crashed-and-resumed run’s history reconstructable from the store.

use io_harness::{CheckpointEvent, Store};

// Answers the question a crashed run leaves behind: did it restart, and did
// the restart re-do work that was already committed?
let events = store.checkpoint_events(run_id)?;
let resumes = events.iter().filter(|e| e.kind == "resume").count();
let replayed: Vec<u32> = events.iter().filter(|e| e.kind == "skipped").map(|e| e.step).collect();

assert_eq!(resumes, 1, "this run died once and came back");
// Two steps were replayed and recognised as already done, so they cost
// nothing the second time — that is what makes a resume idempotent rather
// than a second charge for the same steps.
assert_eq!(replayed, [1, 2]);

Fields

run_id: i64

The run this event belongs to.

step: u32

The step it concerns.

kind: String

"checkpoint", "resume", or "skipped".

detail: Option<String>

Optional human-readable detail (never file contents or secrets).

Implementations

impl CheckpointEvent

pub fn checkpoint(run_id: i64, step: u32) -> Self

A step was durably checkpointed.

pub fn resume(run_id: i64, step: u32, detail: impl Into<String>) -> Self

A run was resumed, re-driving from step.

pub fn skipped(run_id: i64, step: u32) -> Self

An already-committed step was skipped on resume.

Trait Implementations

impl Clone for CheckpointEvent

fn clone(&self) -> CheckpointEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointEvent

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

Formats the value using the given formatter.

impl PartialEq for CheckpointEvent

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for CheckpointEvent