Struct TemporalCheckpointManager 

pub struct TemporalCheckpointManager { /* private fields */ }

The main checkpoint manager

Implementations

impl TemporalCheckpointManager

pub fn new(storage: Rc<dyn CheckpointStorage>, session_id: SessionId) -> Self

Create a new checkpoint manager

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

Create a manual checkpoint

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

Create an automatic checkpoint (if appropriate)

pub fn list(&self) -> Result<Vec<CheckpointSummary>>

List all checkpoints for this session

pub fn get(&self, id: &CheckpointId) -> Result<Option<TemporalCheckpoint>>

Get a checkpoint by ID

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

List checkpoints for a specific session

pub fn list_by_tag(&self, tag: &str) -> Result<Vec<CheckpointSummary>>

List checkpoints with a specific tag

pub fn checkpoint_with_tags( &self, message: impl Into<String>, tags: Vec<String>, ) -> Result<CheckpointId>

Create a checkpoint with tags

pub fn restore( &self, checkpoint: &TemporalCheckpoint, ) -> Result<DebugStateSnapshot>

Restore state from a checkpoint

pub fn get_summary( &self, id: &CheckpointId, ) -> Result<Option<CheckpointSummary>>

Get a summary of a checkpoint by ID

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

Delete a checkpoint by ID

pub fn compact(&self, keep_recent: usize) -> Result<usize>

Compact checkpoints, keeping only the most recent N

pub fn compact_with_policy(&self, policy: CompactionPolicy) -> Result<usize>

Compact checkpoints using a specific policy