Struct EventSourcedStateStore 

pub struct EventSourcedStateStore<ID, E, ES, SN>
where
    ID: EventId,
    E: Event + Clone + Send + Sync,
    ES: EventStore<ID, E> + Clone + Sync + Send,
    SN: SnapshotConfig + Clone,
{ /* private fields */ }

Represents an event sourced decision state store. It loads and stores decision states from events in a event store.

Implementations

impl<ID, E, ES, SN> EventSourcedStateStore<ID, E, ES, SN>

where ID: EventId, E: Event + Clone + Send + Sync, ES: EventStore<ID, E> + Clone + Sync + Send, SN: SnapshotConfig + Clone,

pub fn new(event_store: ES, snapshot: SN) -> Self

Trait Implementations

impl<ID, E, ES, SN> Clone for EventSourcedStateStore<ID, E, ES, SN>

where ID: EventId + Clone, E: Event + Clone + Send + Sync + Clone, ES: EventStore<ID, E> + Clone + Sync + Send + Clone, SN: SnapshotConfig + Clone + Clone,

fn clone(&self) -> EventSourcedStateStore<ID, E, ES, SN>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ID, ES, E, S> LoadState<ID, S, E> for EventSourcedStateStore<ID, E, ES, NoSnapshot>

where ES: EventStore<ID, E> + Clone + Sync + Send, <ES as EventStore<ID, E>>::Error: StdError + Send + Sync + 'static, ID: EventId, E: Event + Clone + Send + Sync + 'static, S: Send + Sync + Serialize + DeserializeOwned + IntoStatePart<ID, S> + 'static, <S as IntoStatePart<ID, S>>::Target: Send + Sync + Serialize + DeserializeOwned + IntoState<S> + MultiState<ID, E>,

fn load<'life0, 'async_trait>( &'life0 self, state_query: S, ) -> Pin<Box<dyn Future<Output = Result<LoadedState<ID, S>, BoxDynError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads the state based on the provided state query.

impl<ID, ES, E, S, B> LoadState<ID, S, E> for EventSourcedStateStore<ID, E, ES, WithSnapshot<ID, B>>

where ID: EventId, B: StateSnapshotter<ID> + Send + Sync + Clone, ES: EventStore<ID, E> + Clone + Sync + Send, <ES as EventStore<ID, E>>::Error: StdError + Send + Sync + 'static, E: Event + Clone + Send + Sync + 'static, S: Send + Sync + Serialize + DeserializeOwned + IntoStatePart<ID, S> + 'static, <S as IntoStatePart<ID, S>>::Target: Send + Sync + Serialize + DeserializeOwned + IntoState<S> + MultiState<ID, E> + MultiStateSnapshot<ID, B>,

fn load<'life0, 'async_trait>( &'life0 self, state_query: S, ) -> Pin<Box<dyn Future<Output = Result<LoadedState<ID, S>, BoxDynError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Loads the state based on the provided state query.

impl<ID, ES, E, S, SC> PersistDecision<ID, S, E> for EventSourcedStateStore<ID, E, ES, SC>

where ID: EventId, E: Event + Clone + Send + Sync + 'static, ES: EventStore<ID, E> + Clone + Sync + Send, <ES as EventStore<ID, E>>::Error: StdError + Send + Sync + 'static, S: Send + Sync + Serialize + DeserializeOwned + IntoStatePart<ID, S> + 'static, <S as IntoStatePart<ID, S>>::Target: Send + Sync + Serialize + DeserializeOwned + IntoState<S> + MultiState<ID, E>, SC: SnapshotConfig + Clone + Send + Sync + 'static,

fn persist<'life0, 'async_trait>( &'life0 self, loaded_state: LoadedState<ID, S>, events: Vec<E>, validation_query: Option<StreamQuery<ID, E>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<PersistedEvent<ID, E>>, BoxDynError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Persists the decision changes to the event store.