Struct FileCheckpointStore 

pub struct FileCheckpointStore { /* private fields */ }

Filesystem-backed checkpoint accelerator store.

Implementations

impl FileCheckpointStore

pub fn new(root: impl Into<PathBuf>) -> Self

Creates a checkpoint store rooted under the provided directory.

Trait Implementations

impl CheckpointStore for FileCheckpointStore

fn save( &self, checkpoint: RunCheckpoint, latest_journal_seq: u64, ) -> Result<CheckpointSaveOutcome, AgentError>

Saves checkpoint accelerator data for a run at a journal sequence. Implementations write or replace checkpoint accelerator data for the run without changing journal truth.

fn load_latest( &self, run_id: &RunId, ) -> Result<Option<RunCheckpoint>, AgentError>

Loads the latest checkpoint accelerator data for a run. Implementations read checkpoint storage for the requested run and return matching checkpoint data without altering durable journal truth.

fn load_at_or_before( &self, run_id: &RunId, cursor: &JournalCursor, ) -> Result<Option<RunCheckpoint>, AgentError>

Loads checkpoint accelerator data at or before the requested journal cursor. Implementations read checkpoint storage for the requested run and return matching checkpoint data without altering durable journal truth.

fn prune( &self, run_id: &RunId, policy: CheckpointPrunePolicy, ) -> Result<CheckpointPruneReport, AgentError>

Prunes checkpoint accelerator data according to retention policy. Implementations remove checkpoint accelerator entries according to retention policy without deleting journal truth.

impl Clone for FileCheckpointStore

fn clone(&self) -> FileCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileCheckpointStore

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

Formats the value using the given formatter.