Struct SqliteCheckpointStore 

pub struct SqliteCheckpointStore { /* private fields */ }

SQLite-backed checkpoint store.

Implementations

impl SqliteCheckpointStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, AgentError>

Opens or creates a SQLite checkpoint store.

Trait Implementations

impl CheckpointStore for SqliteCheckpointStore

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 SqliteCheckpointStore

fn clone(&self) -> SqliteCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteCheckpointStore

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

Formats the value using the given formatter.