Struct cqrs_es2_sql::EventStore

pub struct EventStore<A: IAggregate> { /* fields omitted */ }

Storage engine using an Postgres backing. This is the only persistent store currently provided.

Implementations

impl<A: IAggregate> EventStore<A>

pub fn new(conn: Client) -> Self

Creates a new EventStore from the provided database connection.

Trait Implementations

impl<A: IAggregate> IEventStore<A> for EventStore<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) -> AggregateContext<A>

Load aggregate at current state

fn commit(
    &mut self,
    events: Vec<A::Event>,
    context: AggregateContext<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 IAggregate>::Event, Global>,
    base_metadata: HashMap<String, String, RandomState>
) -> Vec<EventEnvelope<A>, Global>

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