Struct EventStore

pub struct EventStore<Id, Event> { /* private fields */ }

Redis backend implementation for eventually::EventStore trait.

Trait Implementations

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

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, Event> EventStore for EventStore<Id, Event>

where Id: TryFrom<String> + Display + Eq + Clone + Send + Sync, <Id as TryFrom<String>>::Error: Error + Send + Sync + 'static, for<'de> Event: Serialize + Send + Sync + Deserialize<'de>,

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 = StoreError

Possible errors returned by the EventStore when requesting operations.

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

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<'_, StoreResult<StoreEventStream<'_, Self>>>

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<'_, StoreResult<StoreEventStream<'_, Self>>>

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<'_, StoreResult<()>>

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