Struct PostgresEventStore 

pub struct PostgresEventStore { /* private fields */ }

Postgres-backed event store.

Implementations

impl PostgresEventStore

pub fn new(database_url: &str) -> Result<Self, StoreError>

Create a store backed by a lazily-connected PgPool.

pub fn from_pool(pool: PgPool) -> Self

Construct from an existing pool.

pub fn with_metrics(self, metrics: Arc<YarliMetrics>) -> Self

Attach metrics registry for telemetry.

pub fn pool(&self) -> &PgPool

Access the underlying pool.

Trait Implementations

impl Clone for PostgresEventStore

fn clone(&self) -> PostgresEventStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PostgresEventStore

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

Formats the value using the given formatter.

impl EventStore for PostgresEventStore

fn append(&self, event: Event) -> Result<(), StoreError>

Append an event to the store.

fn get(&self, event_id: EventId) -> Result<Event, StoreError>

Retrieve a single event by ID.

fn query(&self, query: &EventQuery) -> Result<Vec<Event>, StoreError>

Query events matching a filter. Results are ordered by occurred_at ASC.

fn all(&self) -> Result<Vec<Event>, StoreError>

Return all events in insertion order (for replay).

fn len(&self) -> usize

Return the total number of stored events.

fn is_empty(&self) -> bool

Check whether the store is empty.