Struct InMemoryCheckpointStore 

pub struct InMemoryCheckpointStore { /* private fields */ }

In-memory checkpoint store for testing and lightweight use.

Implementations

impl InMemoryCheckpointStore

pub async fn summarize_run(&self, run_id: &str) -> Option<RunSummary>

Build a RunSummary for the given run.

impl InMemoryCheckpointStore

pub fn new() -> Self

pub async fn list_runs(&self) -> Vec<RunState>

List all runs. Useful for testing and inspection.

Trait Implementations

impl CheckpointStore for InMemoryCheckpointStore

fn create_run( &self, graph_name: &str, ) -> Pin<Box<dyn Future<Output = Result<RunId>> + Send + '_>>

Create a new run and return its ID.

fn record_attempt( &self, run_id: &str, node_id: &str, attempt: u32, input: &Value, ) -> Pin<Box<dyn Future<Output = Result<CheckpointAttemptId>> + Send + '_>>

Record a new node attempt (status: Running).

fn complete_attempt( &self, attempt_id: &str, output: &Value, meta: &HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Mark an attempt as completed with output.

fn fail_attempt( &self, attempt_id: &str, error: &str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Mark an attempt as failed.

fn record_interrupt( &self, attempt_id: &str, interrupt: &Interrupt, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Record an interrupt on an attempt.

fn save_state_snapshot( &self, run_id: &str, state: &HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Save the current state snapshot for a run.

fn load_run( &self, run_id: &str, ) -> Pin<Box<dyn Future<Output = Result<Option<RunState>>> + Send + '_>>

Load the full run state (for resume).

fn complete_run( &self, run_id: &str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Mark a run as completed.

fn fail_run( &self, run_id: &str, _error: &str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Mark a run as failed.

impl Default for InMemoryCheckpointStore

fn default() -> Self

Returns the “default value” for a type.