Struct PostgresStoreAggregateContext

pub struct PostgresStoreAggregateContext<A: Aggregate> {
    pub aggregate_id: String,
    pub aggregate: A,
    pub current_sequence: usize,
}

Holds context for a pure event store implementation for MemStore

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

impl<A: Aggregate> AggregateContext<A> for PostgresStoreAggregateContext<A>

fn aggregate(&self) -> &A

The aggregate instance with all state loaded.

impl<A: Aggregate> EventStore<A, PostgresStoreAggregateContext<A>> for PostgresStore<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, ) -> PostgresStoreAggregateContext<A>

Load aggregate at current state

fn commit( &mut self, events: Vec<A::Event>, context: PostgresStoreAggregateContext<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