Struct PostgresReadModelStore 

pub struct PostgresReadModelStore { /* private fields */ }

Postgres implementation of ReadModelStore.

Implementations

impl PostgresReadModelStore

pub async fn new(database_url: &str) -> ReadModelResult<Self>

Build a new store from a database URL, creating a small pool.

pub fn with_pool(pool: PgPool) -> Self

Build a store from an existing pool. Lets tests share one pool with the event store against the same database.

pub fn pool(&self) -> &PgPool

Borrow the underlying pool.

pub async fn initialize_schema(&self) -> ReadModelResult<()>

Create the users_view projection table and its email index if absent. Idempotent.

Trait Implementations

impl Clone for PostgresReadModelStore

fn clone(&self) -> PostgresReadModelStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ReadModelStore for PostgresReadModelStore

fn upsert<'life0, 'async_trait>( &'life0 self, op: Upsert, ) -> Pin<Box<dyn Future<Output = ReadModelResult<()>> + Send + 'async_trait>>

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

Insert or update a row, version-gated.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<()>> + Send + 'async_trait>>

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

Delete a row by primary key. No-op if missing.

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<Option<Row>>> + Send + 'async_trait>>

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

Fetch a single row by primary key.

fn find_by<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, table: &'life1 str, field: &'life2 str, value: &'life3 Value, ) -> Pin<Box<dyn Future<Output = ReadModelResult<Vec<Row>>> + Send + 'async_trait>>

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

Fetch all rows where field equals value. Used for secondary-index lookups such as login-by-email. Backends may or may not have an index on the field — the trait carries no guarantee.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<Vec<Row>>> + Send + 'async_trait>>

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

Fetch every row in a table.

fn truncate<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, ) -> Pin<Box<dyn Future<Output = ReadModelResult<()>> + Send + 'async_trait>>

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

Wipe a table. Used during projection rebuild before replay.