Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

sqlite-backed durability store.

Implementations

impl SqliteStore

pub fn open<P: AsRef<Path>>(path: P, default_contract: Contract) -> Result<Self>

Opens (creating if absent) a sqlite store at path with WAL mode.

Errors

sqlite open/pragma/schema failure.

pub fn open_in_memory(default_contract: Contract) -> Result<Self>

In-memory sqlite store (tests / pure-TRANSIENT-via-sqlite).

Errors

sqlite open/pragma/schema failure.

Trait Implementations

impl DurabilityStore for SqliteStore

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>, StoreError>

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