Struct WorkflowCheckpointService 

pub struct WorkflowCheckpointService { /* private fields */ }

Workflow checkpoint storage service.

Provides save/load functionality for workflow checkpoints using bincode serialization for fast snapshots. Uses separate namespace (“workflow:”) to distinguish from debugging checkpoints.

Note

This is a basic in-memory implementation for Phase 9 Task 2. Future tasks will integrate with forge-reasoning CheckpointStorage for persistent storage using SQLiteGraph backend.

Implementations

impl WorkflowCheckpointService

pub fn new(namespace: impl Into<String>) -> Self

Creates a new workflow checkpoint service.

Arguments

• namespace - Namespace prefix for checkpoints (default: “workflow”)

pub fn default() -> Self

Creates a service with default “workflow” namespace.

pub fn save(&self, checkpoint: &WorkflowCheckpoint) -> Result<(), WorkflowError>

Saves a workflow checkpoint.

Serializes the checkpoint using bincode and stores it with the workflow namespace prefix.

Arguments

• checkpoint - The checkpoint to save

Returns

• Ok(()) if checkpoint was saved successfully
• Err(WorkflowError) if serialization or storage fails

pub fn load( &self, id: &CheckpointId, ) -> Result<Option<WorkflowCheckpoint>, WorkflowError>

Loads a workflow checkpoint by ID.

Arguments

• id - The checkpoint ID to load

Returns

• Ok(Some(checkpoint)) if found
• Ok(None) if not found
• Err(WorkflowError) if deserialization fails or data is corrupted

pub fn get_latest( &self, workflow_id: &str, ) -> Result<Option<WorkflowCheckpoint>, WorkflowError>

Gets the latest checkpoint for a workflow.

Arguments

• workflow_id - The workflow identifier

Returns

• Ok(Some(checkpoint)) if latest checkpoint exists
• Ok(None) if no checkpoints found for workflow
• Err(WorkflowError) if retrieval fails

pub fn list_by_workflow( &self, workflow_id: &str, ) -> Result<Vec<CheckpointSummary>, WorkflowError>

Lists all checkpoints for a workflow.

Arguments

• workflow_id - The workflow identifier

Returns

• Ok(summaries) - Vector of checkpoint summaries in sequence order
• Err(WorkflowError) if listing fails

pub fn delete(&self, id: &CheckpointId) -> Result<(), WorkflowError>

Deletes a checkpoint by ID.

Arguments

• id - The checkpoint ID to delete

Returns

• Ok(()) if deleted or not found
• Err(WorkflowError) if deletion fails

Trait Implementations

impl Clone for WorkflowCheckpointService

fn clone(&self) -> WorkflowCheckpointService

Returns a duplicate of the value.

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

Performs copy-assignment from source.