Struct InMemoryCheckpointStorage 

pub struct InMemoryCheckpointStorage { /* private fields */ }

In-memory checkpoint storage implementation (for testing/development)

Implementations

impl InMemoryCheckpointStorage

pub fn new() -> Self

Trait Implementations

impl CheckpointStorage for InMemoryCheckpointStorage

fn save_checkpoint( &self, execution_id: ExecutionId, checkpoint: &ExecutionCheckpoint, ) -> Result<CheckpointId, CheckpointError>

Save a checkpoint

fn load_latest_checkpoint( &self, execution_id: ExecutionId, ) -> Result<Option<ExecutionCheckpoint>, CheckpointError>

Load the latest checkpoint for an execution

fn load_checkpoint( &self, checkpoint_id: CheckpointId, ) -> Result<Option<ExecutionCheckpoint>, CheckpointError>

Load a specific checkpoint by ID

fn list_checkpoints( &self, execution_id: ExecutionId, ) -> Result<Vec<CheckpointMetadata>, CheckpointError>

List all checkpoints for an execution

fn prune_checkpoints( &self, execution_id: ExecutionId, keep_count: usize, ) -> Result<usize, CheckpointError>

Delete old checkpoints beyond retention limit

fn delete_checkpoints( &self, execution_id: ExecutionId, ) -> Result<usize, CheckpointError>

Delete all checkpoints for an execution

impl Debug for InMemoryCheckpointStorage

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

Formats the value using the given formatter.

impl Default for InMemoryCheckpointStorage

fn default() -> InMemoryCheckpointStorage

Returns the “default value” for a type.