Struct CheckpointStore 

pub struct CheckpointStore { /* private fields */ }

File-backed store of paused workflow checkpoints, keyed by run_id.

Implementations

impl CheckpointStore

pub fn open(dir: impl AsRef<Path>) -> Result<Self>

Open (creating if needed) a checkpoint store rooted at dir.

pub fn save(&self, paused: &PausedWorkflow) -> Result<()>

Persist a paused run. Write-to-temp + atomic rename so no half-written checkpoint is ever visible. The temp name carries a fresh UUID so concurrent writers for the same run_id never share a temp path.

pub fn load(&self, run_id: &str) -> Result<Option<PausedWorkflow>>

Load a paused run by id without claiming it, or None if absent. Read-only peek — does not protect against double-resume; use claim for that.

pub fn claim(&self, run_id: &str) -> Result<Option<PausedWorkflow>>

Atomically take ownership of a paused run for resumption.

Renames <run_id>.json to <run_id>.inflight (atomic) and returns the checkpoint. A second concurrent or duplicate claim finds no .json and gets None — this is the exactly-once guard against double-resume. After resuming, call save (if it paused again) then complete.

pub fn recover_orphaned(&self) -> Result<usize>

Recover runs orphaned by a crash between claim and complete. Call once at startup, before any resume can be in flight — running it concurrently with a live resume could re-arm a run another caller is mid-way through.

For each <run_id>.inflight: if a sibling <run_id>.json exists (a crash after a re-pause save), the .json is authoritative and the stale marker is removed; otherwise the marker is renamed back to <run_id>.json, re-arming the run for a fresh claim. Returns the number re-armed.

pub fn complete(&self, run_id: &str) -> Result<()>

Drop the in-flight marker after a claimed run finishes resuming. Idempotent. Leaves any fresh <run_id>.json written by a re-pause.

pub fn remove(&self, run_id: &str) -> Result<()>

Remove a checkpoint and any in-flight marker entirely (hard cleanup). Idempotent: removing a missing checkpoint is not an error.

pub fn list(&self) -> Result<Vec<String>>

List the run IDs of all currently-paused runs.

Trait Implementations

impl Clone for CheckpointStore

fn clone(&self) -> CheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointStore

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

Formats the value using the given formatter.