Struct cqrs::trivial::NullSnapshotStore

pub struct NullSnapshotStore<A>(_)
 where
    A: Aggregate;

A trivial store that never has any snapshots, and which always succeeds in persisting data (which is immediately dropped).

Methods

impl<A> NullSnapshotStore<A> where
    A: Aggregate, 

pub const DEFAULT: Self

A constant value representing a trivial event store.

Trait Implementations

impl<A: Clone> Clone for NullSnapshotStore<A> where
    A: Aggregate, 

fn clone(&self) -> NullSnapshotStore<A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A> Default for NullSnapshotStore<A> where
    A: Aggregate, 

fn default() -> Self

Returns the "default value" for a type.

impl<A: Copy> Copy for NullSnapshotStore<A> where
    A: Aggregate, 

impl<A> Debug for NullSnapshotStore<A> where
    A: Aggregate, 

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

Formats the value using the given formatter.

impl<A> SnapshotSource<A> for NullSnapshotStore<A> where
    A: Aggregate, 

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.

impl<A> SnapshotSink<A> for NullSnapshotStore<A> where
    A: Aggregate, 

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.