Struct PostgresEventStore 

pub struct PostgresEventStore { /* private fields */ }

Postgres implementation of EventStore.

Implementations

impl PostgresEventStore

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

Build a store from a Postgres connection URL, creating a small pool.

pub async fn new_with_integrity_key( database_url: &str, key: impl Into<Vec<u8>>, key_id: impl Into<String>, ) -> EventStoreResult<Self>

Build a store from a Postgres connection URL with an integrity key.

pub fn with_pool(pool: PgPool) -> Self

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

pub fn with_pool_and_integrity_key( pool: PgPool, key: impl Into<Vec<u8>>, key_id: impl Into<String>, ) -> EventStoreResult<Self>

Build a store from an existing pool and an integrity key.

pub fn pool(&self) -> &PgPool

Borrow the underlying pool (e.g. to construct a read-model store that shares the same connections).

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

Create the events and snapshots tables and their indexes if absent. Idempotent; safe to call on every startup.

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 EventStore for PostgresEventStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, version_check: VersionCheck, new_events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = EventStoreResult<()>> + Send + 'async_trait>>

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

Append events to the store for a specific aggregate.

fn append_to<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, aggregate_id: &'life2 str, version_check: VersionCheck, new_events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = EventStoreResult<()>> + Send + 'async_trait>>

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

Append to the stream identified by aggregate type and instance ID.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Vec<Event>>> + Send + 'async_trait>>

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

fn load_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, aggregate_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Vec<Event>>> + Send + 'async_trait>>

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

fn load_from<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, from_sequence: i64, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Vec<Event>>> + Send + 'async_trait>>

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

fn load_stream_from<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, aggregate_id: &'life2 str, from_sequence: i64, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Vec<Event>>> + Send + 'async_trait>>

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

fn stream_all<'life0, 'async_trait>( &'life0 self, from_position: i64, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Vec<Event>>> + Send + 'async_trait>>

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

fn get_version<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = EventStoreResult<i64>> + Send + 'async_trait>>

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

fn get_stream_version<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, aggregate_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = EventStoreResult<i64>> + Send + 'async_trait>>

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

fn save_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, snapshot: &'life1 Snapshot, ) -> Pin<Box<dyn Future<Output = EventStoreResult<()>> + Send + 'async_trait>>

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

Persist an aggregate snapshot (upsert by aggregate_id).

fn load_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Option<Snapshot>>> + Send + 'async_trait>>

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

Load the latest snapshot for an aggregate, if one exists.

fn load_snapshot_for<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, aggregate_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = EventStoreResult<Option<Snapshot>>> + Send + 'async_trait>>

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