Struct cqrs_es2::MemoryStoreAggregateContext [−][src]
pub struct MemoryStoreAggregateContext<A> where
A: Aggregate, { pub aggregate_id: String, pub aggregate: A, pub current_sequence: usize, }
Expand description
Holds context for a pure event store implementation for MemoryStore
Fields
aggregate_id: String
The aggregate ID of the aggregate instance that has been loaded.
aggregate: A
The current state of the aggregate instance.
current_sequence: usize
The last committed event sequence number for this aggregate instance.
Trait Implementations
Load all events for a particular aggregate_id
Load aggregate at current state
fn commit(
&mut self,
events: Vec<A::Event>,
context: MemoryStoreAggregateContext<A>,
metadata: HashMap<String, String>
) -> Result<Vec<EventEnvelope<A>>, AggregateError>
fn commit(
&mut self,
events: Vec<A::Event>,
context: MemoryStoreAggregateContext<A>,
metadata: HashMap<String, String>
) -> Result<Vec<EventEnvelope<A>>, AggregateError>
Commit new events