Struct InMemoryCheckpointStore 

pub struct InMemoryCheckpointStore { /* private fields */ }

Holds in memory checkpoint store application-layer state or configuration. Use it with the documented coordinator methods; run, journal, event, provider, or port effects are called out on those methods rather than on construction.

Implementations

impl InMemoryCheckpointStore

pub fn new() -> Self

Creates a new application::checkpoint value with explicit caller-provided inputs. This constructor is data-only and performs no I/O or external side effects.

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

Save. This stores checkpoint accelerator data in memory without changing journal truth.

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

Load latest. This reads the in-memory checkpoint store for the requested run and does not write checkpoints or journal records.

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

Load at or before. This reads the in-memory checkpoint store for the requested run and does not write checkpoints or journal records.

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

Prune. This prunes only the in-memory checkpoint accelerator and leaves durable journal records untouched.

pub fn list(&self, run_id: &RunId) -> Result<Vec<RunCheckpoint>, AgentError>

List. This reads all in-memory checkpoint accelerator entries for one run.

Trait Implementations

impl CheckpointStore for InMemoryCheckpointStore

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 InMemoryCheckpointStore

fn clone(&self) -> InMemoryCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryCheckpointStore

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

Formats the value using the given formatter.

impl Default for InMemoryCheckpointStore

fn default() -> InMemoryCheckpointStore

Returns the “default value” for a type.