Struct ThreadSafeCheckpointManager 

pub struct ThreadSafeCheckpointManager { /* private fields */ }

Thread-safe checkpoint manager

Wraps operations in Mutex for concurrent access

Implementations

impl ThreadSafeCheckpointManager

pub fn new(storage: ThreadSafeStorage, session_id: SessionId) -> Self

Create a new thread-safe manager

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

Create a manual checkpoint with auto-generated sequence

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

Create a checkpoint with a specific sequence number (for global sequencing)

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

Create a checkpoint with tags and auto-generated sequence

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

Create a checkpoint with tags and specific sequence number

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

Create an automatic checkpoint with auto-generated sequence

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

Create an automatic checkpoint with specific sequence number

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 delete(&self, id: &CheckpointId) -> Result<()>

Delete a checkpoint

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

Compact checkpoints

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

Compact with policy

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

Restore state from checkpoint

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

Get summary by ID

Trait Implementations

impl Send for ThreadSafeCheckpointManager

impl Sync for ThreadSafeCheckpointManager