Struct PostgresSnapshotStore

pub struct PostgresSnapshotStore<A: Aggregate> { /* private fields */ }

Storage engine using an Postgres backing and relying on a serialization of the aggregate rather than individual events. This is similar to the “snapshot strategy” seen in many CQRS frameworks.

Implementations

impl<A: Aggregate> PostgresSnapshotStore<A>

pub fn new(conn: Client) -> Self

Creates a new PostgresSnapshotStore from the provided database connection.

Trait Implementations

impl<A: Aggregate> EventStore<A, PostgresSnapshotStoreAggregateContext<A>> for PostgresSnapshotStore<A>

fn load(&mut self, aggregate_id: &str) -> Vec<EventEnvelope<A>>

Load all events for a particular aggregate_id

fn load_aggregate( &mut self, aggregate_id: &str, ) -> PostgresSnapshotStoreAggregateContext<A>

Load aggregate at current state

fn commit( &mut self, events: Vec<A::Event>, context: PostgresSnapshotStoreAggregateContext<A>, metadata: HashMap<String, String>, ) -> Result<Vec<EventEnvelope<A>>, AggregateError>

Commit new events

fn wrap_events( &self, aggregate_id: &str, current_sequence: usize, resultant_events: Vec<<A as Aggregate>::Event>, base_metadata: HashMap<String, String>, ) -> Vec<EventEnvelope<A>>

Method to wrap a set of events with the additional metadata needed for persistence and publishing