Struct InMemoryCompactionCheckpointStore 

pub struct InMemoryCompactionCheckpointStore { /* private fields */ }

Application-grade in-memory compaction checkpoint store for embedded hosts.

Trait Implementations

impl CompactionCheckpointStore for InMemoryCompactionCheckpointStore

fn get_latest<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: SessionId, provider_type: &'life1 str, model: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CompactionCheckpoint>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn install<'life0, 'async_trait>( &'life0 self, checkpoint: CompactionCheckpoint, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Install a checkpoint only if no newer source boundary is canonical.

fn get_proactive_attempt<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: SessionId, provider_type: &'life1 str, model: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ProactiveCompactionAttempt>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Latest pressure snapshot where proactive native compaction was attempted.

fn record_proactive_attempt<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: SessionId, provider_type: &'life1 str, model: &'life2 str, attempt: ProactiveCompactionAttempt, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

impl Debug for InMemoryCompactionCheckpointStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryCompactionCheckpointStore

fn default() -> InMemoryCompactionCheckpointStore

Returns the “default value” for a type.