Struct StateStore 

pub struct StateStore<A, Hasher = RandomState>
where
    A: Aggregate + Clone,
    Hasher: BuildHasher,
{ /* private fields */ }

An in-memory store for aggregate snapshots.

Implementations

impl<A, Hasher> StateStore<A, Hasher>

where A: Aggregate + Clone, Hasher: BuildHasher,

pub fn with_hasher(hasher: Hasher) -> Self

Constructs a new snapshot store with a specific hasher.

Trait Implementations

impl<A, Hasher> Debug for StateStore<A, Hasher>

where A: Aggregate + Clone + Debug, Hasher: BuildHasher + Debug,

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

Formats the value using the given formatter.

impl<A, Hasher> Default for StateStore<A, Hasher>

where A: Aggregate + Clone, Hasher: BuildHasher + Default,

fn default() -> Self

Returns the “default value” for a type.

impl<A, Hasher> SnapshotSink<A> for StateStore<A, Hasher>

where A: Aggregate + Clone, Hasher: BuildHasher,

type Error = Void

The error type.

fn persist_snapshot<I>( &self, id: &I, aggregate: &A, version: Version, _last_snapshot_version: Option<Version>, ) -> Result<Version, Self::Error>

where I: AggregateId<A>, Self: Sized,

Writes an aggregate with its version to the sink. Returns the version number of the latest snapshot.

impl<A, Hasher> SnapshotSource<A> for StateStore<A, Hasher>

where A: Aggregate + Clone, Hasher: BuildHasher,

type Error = Void

The error type.

fn get_snapshot<I>( &self, id: &I, ) -> Result<Option<VersionedAggregate<A>>, Self::Error>

where I: AggregateId<A>, Self: Sized,

Loads a versioned aggregate from the snapshot source.