Struct cqrs::CompositeEntitySink

pub struct CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's,  { /* fields omitted */ }

Combines an EventSink and a SnapshotSink of different types by reference so that they can be used jointly as an EntitySink.

Methods

impl<'e, 's, A, E, M, ES, SS> CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

pub fn with_event_sink<'new_e, NewES>(
    self,
    event_sink: &'new_e NewES
) -> CompositeEntitySink<'new_e, 's, A, E, M, NewES, SS> where
    NewES: EventSink<A, E, M> + 'new_e, 

Attaches a specific event sink.

pub fn with_snapshot_sink<'new_s, NewSS>(
    self,
    snapshot_sink: &'new_s NewSS
) -> CompositeEntitySink<'e, 'new_s, A, E, M, ES, NewSS> where
    NewSS: SnapshotSink<A> + 'new_s, 

Attaches a specific snapshot sink.

Trait Implementations

impl<'e, 's, A: Clone, E: Clone, M: Clone, ES: Clone, SS: Clone> Clone for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

fn clone(&self) -> CompositeEntitySink<'e, 's, A, E, M, ES, SS>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A, E, M> Default for CompositeEntitySink<'static, 'static, A, E, M, NullEventStore<A, E>, NullSnapshotStore<A>> where
    A: Aggregate,
    E: AggregateEvent<A>, 

fn default() -> Self

Returns the "default value" for a type.

impl<'e, 's, A: PartialEq, E: PartialEq, M: PartialEq, ES: PartialEq, SS: PartialEq> PartialEq<CompositeEntitySink<'e, 's, A, E, M, ES, SS>> for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

fn eq(&self, other: &CompositeEntitySink<'e, 's, A, E, M, ES, SS>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &CompositeEntitySink<'e, 's, A, E, M, ES, SS>) -> bool

This method tests for !=.

impl<'e, 's, A: Copy, E: Copy, M: Copy, ES: Copy, SS: Copy> Copy for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

impl<'e, 's, A: Eq, E: Eq, M: Eq, ES: Eq, SS: Eq> Eq for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

impl<'e, 's, A: Debug, E: Debug, M: Debug, ES: Debug, SS: Debug> Debug for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

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

Formats the value using the given formatter.

impl<'e, 's, A, E, M, ES, SS> EventSink<A, E, M> for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

type Error = ES::Error

The error type.

fn append_events<I>(
    &self,
    id: &I,
    events: &[E],
    precondition: Option<Precondition>,
    metadata: M
) -> Result<EventNumber, Self::Error> where
    I: AggregateId<A>, 

Appends events to a given source, with an optional precondition, and associated metadata.

impl<'e, 's, A, E, M, ES, SS> SnapshotSink<A> for CompositeEntitySink<'e, 's, A, E, M, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSink<A, E, M> + 'e,
    SS: SnapshotSink<A> + 's, 

type Error = SS::Error

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>, 

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