Struct FileResumeStore 

pub struct FileResumeStore { /* private fields */ }

Disk checkpoint storage: JSON persistence + atomic write.

Atomic write: write pending.json.tmp first, then rename, so a crash never leaves a partial checkpoint. The directory is chosen by the caller; concurrent executors must use separate directories to avoid overwriting each other’s checkpoints.

Implementations

impl FileResumeStore

pub fn new(dir: impl Into<PathBuf>) -> Result<Self, ResumeError>

Creates a checkpoint store; auto-creates the directory (and parents) if missing.

Trait Implementations

impl ResumeStore for FileResumeStore

fn save_pending<'life0, 'life1, 'async_trait>( &'life0 self, pending: &'life1 PendingApproval, ) -> Pin<Box<dyn Future<Output = Result<(), ResumeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Persists a pending-approval checkpoint.

fn load_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<PendingApproval>, ResumeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reads the current checkpoint; returns None if absent.

fn clear_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), ResumeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Clears the checkpoint (decision finalized / checkpoint claimed). Treats absence as success.