Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

PostgreSQL-backed durability store.

Implementations

impl PostgresStore

pub fn connect(conn_str: &str, default_contract: Contract) -> Result<Self>

Connects to PostgreSQL (libpq keyword/URI connection string, e.g. postgres://user@host/db or host=… user=… dbname=…) and ensures the schema. The samples survive a full process/system restart in the database; contracts live in memory and are re-registered on startup.

Errors

Connection, schema, or (with timescaledb) hypertable-setup failure.

Trait Implementations

impl DurabilityStore for PostgresStore

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.