Struct eventually_util::inmemory::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: Clone, Event: Clone> Clone for EventStore<Id, Event> where
    Id: Hash + Eq, 

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Id: Debug, Event: Debug> Debug for EventStore<Id, Event> where
    Id: Hash + Eq, 

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.