Struct EventStore 

pub struct EventStore<A: Aggregate<E>, E> { /* private fields */ }

The event store used to persisting events. Besides from using the store, to well, store events, it can also be used to fetch them, and to stream updates synced between different instances

Implementations

impl<A: Aggregate<E> + Send + Sync + Clone, E: Send> EventStore<A, E>

pub fn builder() -> EventStoreBuilder<A, E, (), ()>

pub async fn aggregate( &self, aggregate_id: Uuid, ) -> Result<Option<A>, AdapterError>

Fetches a single aggregate

pub async fn aggregate_without_snapshot( &self, aggregate_id: Uuid, ) -> Result<Option<A>, AdapterError>

Fetches a single aggregate

pub async fn ids(&self) -> Result<BoxStream<'_, Uuid>, AdapterError>

Returns all ids in the store

pub async fn all( &self, ) -> Result<BoxStream<'_, Result<A, AdapterError>>, AdapterError>

Returns all aggregates in the store

pub async fn create<T: IntoEventList<E>>( &self, events: T, ) -> Result<A, CreateError>

Creates a new aggregate

pub async fn create_with_external_ids( &self, events: Vec<Event<E>>, external_ids: Vec<String>, ) -> Result<A, CreateError>

Creates a new aggregate

pub async fn store<T: IntoEventList<E>, F: Fn(&A) -> T + Send + Sync>( &self, aggregate_id: Uuid, callback: F, ) -> Result<A, StoreError>

Stores events to an existing aggregate

pub async fn try_store<T: IntoEventList<E>, F: Fn(&A) -> Result<T, I> + Send + Sync, I: Send + Sync>( &self, aggregate_id: Uuid, callback: F, ) -> Result<Result<A, I>, StoreError>

Stores events to an existing aggregate with the option to throw a validation error

pub async fn stream_realtime( &self, ) -> Result<BoxStream<'_, Result<RealtimeStreamData<A, E>, AdapterError>>, AdapterError>

pub async fn remove(&self, aggregate_id: Uuid) -> Result<(), AdapterError>

Removes the aggregate permanently

Trait Implementations

impl<A: Clone + Aggregate<E>, E: Clone> Clone for EventStore<A, E>

fn clone(&self) -> EventStore<A, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Aggregate<E>, E: Debug> Debug for EventStore<A, E>

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

Formats the value using the given formatter.