Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

sqlx/Postgres-backed durable event store (clustered tier).

Implementations

impl PostgresStore

pub async fn connect(url: &str) -> Result<Self>

Connect to Postgres at url and ensure the schema exists.

Trait Implementations

impl Store for PostgresStore

fn usage<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, since: &'life1 str, until: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<UsageRow>>> + Send + 'async_trait>>

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

The sqlite query’s Postgres twin: same grouping, same filter, same shape. kind is a TEXT column (not jsonb), so each read casts before extracting. The explicit ::bigint casts on the counts are load-bearing — Postgres widens SUM over an integer to numeric, which sqlx will not decode as i64.

fn append<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 FleetEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Append one event to durable storage.

fn replay<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, from_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<FleetEvent>>> + Send + 'async_trait>>

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

Replay events for one stream with seq >= from_seq, in seq order.

fn high_water<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

The highest seq ever persisted for stream_key (0 if none). Used to resume that stream’s sequence counter across daemon restarts.

fn writable<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Whether the backend can currently accept writes. A cheap, non-destructive probe used by the readiness endpoint.

fn prune<'life0, 'life1, 'async_trait>( &'life0 self, before_ts: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Delete events with ts < before_ts (RFC-3339, lexically ordered). Returns the number removed. Backs age-based retention (#4).