[−][src]Trait cqrs_es::EventStore
The abstract central source for loading past events and committing new events.
Required methods
fn load(&self, aggregate_id: &str) -> Vec<MessageEnvelope<A, E>>
Load all events for a particular aggregate_id
fn commit(
&self,
events: Vec<MessageEnvelope<A, E>>
) -> Result<(), AggregateError>
&self,
events: Vec<MessageEnvelope<A, E>>
) -> Result<(), AggregateError>
Commit new events
Implementors
impl<A, E> EventStore<A, E> for MemStore<A, E> where
A: Aggregate,
E: DomainEvent<A>,
[src]
A: Aggregate,
E: DomainEvent<A>,
fn load(&self, aggregate_id: &str) -> Vec<MessageEnvelope<A, E>>
[src]
fn commit(
&self,
events: Vec<MessageEnvelope<A, E>>
) -> Result<(), AggregateError>
[src]
&self,
events: Vec<MessageEnvelope<A, E>>
) -> Result<(), AggregateError>
impl<A, E> EventStore<A, E> for PostgresStore<A, E> where
A: Aggregate,
E: DomainEvent<A>,
[src]
A: Aggregate,
E: DomainEvent<A>,
fn load(&self, aggregate_id: &str) -> Vec<MessageEnvelope<A, E>>
[src]
fn commit(
&self,
events: Vec<MessageEnvelope<A, E>>
) -> Result<(), AggregateError>
[src]
&self,
events: Vec<MessageEnvelope<A, E>>
) -> Result<(), AggregateError>