Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-memory, contract-bounded durability store. Thread-safe via a single mutex. Used directly as the TRANSIENT cold store, and as the hot tier inside crate::TieredStore.

Implementations

impl InMemoryStore

pub fn with_default_contract(default_contract: Contract) -> Self

New empty store with the given default contract (used for topics without an explicit set_contract).

Trait Implementations

impl Default for InMemoryStore

fn default() -> InMemoryStore

Returns the “default value” for a type.

impl DurabilityStore for InMemoryStore

fn set_contract(&self, topic: &str, contract: Contract) -> Result<()>

Registers (or replaces) the retention Contract for topic. The daemon calls this when it starts serving a topic. Topics without an explicit contract use the store’s default (Contract::default).

fn store(&self, sample: DurabilitySample) -> Result<()>

Persists sample durably, enforcing the topic contract. Returns StoreError::OutOfResources when a KEEP_ALL cap is hit.

fn query(&self, topic: &str, selector: &Selector) -> Result<Page>

Returns one ordered Page of samples for topic matching selector. Ordering is (instance_key, sequence). Drive pagination via Page::next + Selector::after_cursor.

fn unregister( &self, topic: &str, instance_key: &[u8; 16], now: SystemTime, ) -> Result<()>

Marks an instance as unregistered at now; its samples become eligible for purge after now + cleanup_delay (applied by cleanup).

fn cleanup(&self, now: SystemTime) -> Result<usize>

Purges instances whose unregister time + cleanup-delay is <= now. Returns the number of purged instances.

fn stats(&self, topic: &str) -> Result<StoreStats>

Aggregate counters for topic.

fn replay_for_topic(&self, topic: &str) -> Result<Vec<DurabilitySample>>

Convenience: drains the full contracted history for topic by paging through query. Prefer paged query for large contracts; this materializes everything into a Vec.