Struct CheckpointService 

pub struct CheckpointService { /* private fields */ }

Main checkpoint service for integration

Implementations

impl CheckpointService

pub fn new(storage: ThreadSafeStorage) -> Self

Create a new checkpoint service

Initializes the global sequence counter from storage to ensure monotonic sequences across service restarts.

pub fn global_sequence(&self) -> u64

Get the current global sequence number

Returns the sequence number of the most recently created checkpoint. Returns 0 if no checkpoints have been created yet.

pub fn is_running(&self) -> bool

Check if service is running

pub fn stop(&self)

Stop the service

pub fn create_session(&self, _name: &str) -> Result<SessionId>

Create a new session

pub fn checkpoint( &self, session_id: &SessionId, message: impl Into<String>, ) -> Result<CheckpointId>

Create a checkpoint with global sequence number

pub fn list_checkpoints( &self, session_id: &SessionId, ) -> Result<Vec<CheckpointSummary>>

List checkpoints for a session

pub fn restore( &self, session_id: &SessionId, checkpoint_id: &CheckpointId, ) -> Result<DebugStateSnapshot>

Restore a checkpoint

pub fn enable_auto_checkpoint( &self, session_id: &SessionId, config: AutoCheckpointConfig, ) -> Result<()>

Enable auto-checkpointing for a session

pub fn trigger_auto_checkpoint( &self, session_id: &SessionId, trigger: AutoTrigger, ) -> Result<Option<CheckpointId>>

Trigger an auto-checkpoint with global sequence

pub fn subscribe( &self, session_id: &SessionId, ) -> Result<Receiver<CheckpointEvent>>

Subscribe to checkpoint events for a session

pub fn execute(&self, command: CheckpointCommand) -> Result<CommandResult>

Execute a command

pub fn sync_to_disk(&self) -> Result<()>

Sync checkpoints to disk (background persistence)

pub fn annotate( &self, checkpoint_id: &CheckpointId, annotation: CheckpointAnnotation, ) -> Result<()>

Annotate a checkpoint

pub fn get_with_annotations( &self, checkpoint_id: &CheckpointId, ) -> Result<AnnotatedCheckpoint>

Get checkpoint with annotations

pub fn metrics(&self) -> Result<ServiceMetrics>

Get service metrics

pub fn health_check(&self) -> Result<HealthStatus>

Health check

pub fn list_by_sequence_range( &self, start_seq: u64, end_seq: u64, ) -> Result<Vec<CheckpointSummary>>

List checkpoints by global sequence number range

Returns all checkpoints (across all sessions) with sequence numbers in the inclusive range [start_seq, end_seq].

pub fn export_all_checkpoints(&self) -> Result<String>

Export all checkpoints from all sessions

Returns a JSON-serializable export containing all checkpoints and the current global sequence number.

pub fn import_checkpoints(&self, export_data: &str) -> Result<ImportResult>

Import checkpoints from export data

Imports all checkpoints and restores the global sequence counter. Skips checkpoints that already exist (by ID).

pub fn validate_checkpoint(&self, checkpoint_id: &CheckpointId) -> Result<bool>

Validate a single checkpoint by ID

Returns true if the checkpoint’s checksum is valid, false otherwise.

pub fn health_check_with_validation(&self) -> Result<HealthStatus>

Health check with validation of recent checkpoints

Performs a health check and additionally validates the most recent checkpoints to detect data corruption.

pub fn validate_all_checkpoints(&self) -> Result<ValidationReport>

Validate all checkpoints

Performs a full validation of all checkpoints in the system. Returns a report with validation statistics.

pub async fn get_hypothesis_state( &self, checkpoint_id: CheckpointId, ) -> Result<Option<HypothesisState>>

Get hypothesis state at a specific checkpoint