Struct ThreadSafeStorage 

pub struct ThreadSafeStorage { /* private fields */ }

Thread-safe wrapper around any CheckpointStorage

Implementations

impl ThreadSafeStorage

pub fn new<S: CheckpointStorage + 'static>(storage: S) -> Self

Create from existing storage

pub fn in_memory() -> Result<Self>

Create in-memory thread-safe storage

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Create file-based thread-safe storage

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

Store a checkpoint

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

Get checkpoint by ID

pub fn get_latest( &self, session_id: SessionId, ) -> Result<Option<TemporalCheckpoint>>

Get latest checkpoint for session

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

List checkpoints by session

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

List checkpoints by tag

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

Delete checkpoint

pub fn get_max_sequence(&self) -> Result<u64>

Get maximum sequence number across all checkpoints

Trait Implementations

impl Clone for ThreadSafeStorage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Send for ThreadSafeStorage

impl Sync for ThreadSafeStorage