Struct eventually_redis::EventStore

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

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,
    Event: Serialize + Send + Sync,
    Event: 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.