Struct EventStore 

pub struct EventStore<Id, Event>
where
    Id: Hash + Eq,
{ /* private fields */ }

An in-memory EventStore implementation, backed by an HashMap.

Implementations

impl<Id, Event> EventStore<Id, Event>

where Id: Hash + Eq,

pub fn new(subscribe_capacity: usize) -> Self

Creates a new EventStore with a specified in-memory broadcast channel size, which will used by the subscribe_all method to notify of newly append events.

Trait Implementations

impl<Id, Event: Clone> Clone for EventStore<Id, Event>

where Id: Hash + Eq + Clone,

fn clone(&self) -> EventStore<Id, Event>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Id, Event: Debug> Debug for EventStore<Id, Event>

where Id: Hash + Eq + Debug,

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

Formats the value using the given formatter.

impl<Id, Event> Default for EventStore<Id, Event>

where Id: Hash + Eq,

fn default() -> Self

Returns the “default value” for a type.

impl<Id, Event> EventStore for EventStore<Id, Event>

where Id: Hash + Eq + Sync + Send + Debug + Clone, Event: Sync + Send + Debug + Clone,

type SourceId = Id

Type of the Source id, typically an AggregateId.

type Event = Event

Event to be stored in the EventStore, typically an Aggregate::Event.

type Error = ConflictError

Possible errors returned by the EventStore when requesting operations.

fn append( &mut self, id: Self::SourceId, version: Expected, events: Vec<Self::Event>, ) -> BoxFuture<'_, Result<u32, Self::Error>>

Appends a new list of Events to the Event Store, for the Source entity specified by SourceId.

fn stream( &self, id: Self::SourceId, select: Select, ) -> BoxFuture<'_, Result<EventStream<'_, Self>, Self::Error>>

Streams a list of Events from the EventStore back to the application, by specifying the desired SourceId and Select operation.

fn stream_all( &self, select: Select, ) -> BoxFuture<'_, Result<EventStream<'_, Self>, Self::Error>>

Streams a list of Events from the EventStore back to the application, disregarding the SourceId values but using a Select operation.

fn remove( &mut self, id: Self::SourceId, ) -> BoxFuture<'_, Result<(), Self::Error>>

Drops all the Events related to one Source, specified by the provided SourceId.

impl<Id, Event> EventSubscriber for EventStore<Id, Event>

where Id: Hash + Eq + Sync + Send + Clone, Event: Sync + Send + Clone,

type SourceId = Id

Type of the Source id, typically an AggregateId.

type Event = Event

Event type stored in the EventStore, typically an Aggregate::Event.

type Error = SubscriberError

Possible errors returned when receiving events from the notification channel.

fn subscribe_all( &self, ) -> BoxFuture<'_, Result<EventStream<'_, Self>, Self::Error>>

Subscribes to all new events persisted in the EventStore, from the moment of calling this function, in the future.