Struct cqrs::memory::EventStore

pub struct EventStore<A, E, M, Hasher = RandomState> where
    A: Aggregate,
    E: AggregateEvent<A> + Clone,
    Hasher: BuildHasher,  { /* fields omitted */ }

An in-memory event store

Methods

impl<A, E, M, Hasher> EventStore<A, E, M, Hasher> where
    A: Aggregate,
    E: AggregateEvent<A> + Clone,
    Hasher: BuildHasher, 

pub fn with_hasher(hasher: Hasher) -> Self

Constructs a new event store with the specified hasher.

Trait Implementations

impl<A, E, M, Hasher> Default for EventStore<A, E, M, Hasher> where
    A: Aggregate,
    E: AggregateEvent<A> + Clone,
    Hasher: BuildHasher + Default, 

fn default() -> Self

Returns the "default value" for a type.

impl<A: Debug, E: Debug, M: Debug, Hasher: Debug> Debug for EventStore<A, E, M, Hasher> where
    A: Aggregate,
    E: AggregateEvent<A> + Clone,
    Hasher: BuildHasher, 

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<A, E, M, Hasher> EventSource<A, E> for EventStore<A, E, M, Hasher> where
    A: Aggregate,
    E: AggregateEvent<A> + Clone,
    Hasher: BuildHasher, 

type Error = Void

The error type.

type Events = Vec<VersionedEvent<E>>

Represents the sequence of events read from the event source.

fn read_events<I>(
    &self,
    id: &I,
    since: Since,
    max_count: Option<u64>
) -> Result<Option<Self::Events>, Self::Error> where
    I: AggregateId<A>, 

Reads events from the event source for a given identifier.

impl<A, E, M, Hasher> EventSink<A, E, M> for EventStore<A, E, M, Hasher> where
    A: Aggregate,
    E: AggregateEvent<A> + Clone,
    Hasher: BuildHasher, 

type Error = PreconditionFailed

The error type.

fn append_events<I>(
    &self,
    id: &I,
    events: &[E],
    precondition: Option<Precondition>,
    metadata: M
) -> Result<EventNumber, Self::Error> where
    I: AggregateId<A>, 

Appends events to a given source, with an optional precondition, and associated metadata.