Struct cqrs::CompositeEntitySource

pub struct CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's,  { /* fields omitted */ }

Combines an EventSource and a SnapshotSource of different types by reference so that they can be used jointly as an EntitySource.

Methods

impl<'e, 's, A, E, ES, SS> CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

pub fn with_event_source<'new_e, NewES>(
    self,
    event_source: &'new_e NewES
) -> CompositeEntitySource<'new_e, 's, A, E, NewES, SS> where
    NewES: EventSource<A, E> + 'new_e, 

Attaches a specific event source.

pub fn with_snapshot_source<'new_s, NewSS>(
    self,
    snapshot_source: &'new_s NewSS
) -> CompositeEntitySource<'e, 'new_s, A, E, ES, NewSS> where
    NewSS: SnapshotSource<A> + 'new_s, 

Attaches a specific snapshot source.

Trait Implementations

impl<'e, 's, A: Clone, E: Clone, ES: Clone, SS: Clone> Clone for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A, E> Default for CompositeEntitySource<'static, 'static, A, E, 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, ES: PartialEq, SS: PartialEq> PartialEq<CompositeEntitySource<'e, 's, A, E, ES, SS>> for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

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

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

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

This method tests for !=.

impl<'e, 's, A: Copy, E: Copy, ES: Copy, SS: Copy> Copy for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

impl<'e, 's, A: Eq, E: Eq, ES: Eq, SS: Eq> Eq for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

impl<'e, 's, A: Debug, E: Debug, ES: Debug, SS: Debug> Debug for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

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

Formats the value using the given formatter.

impl<'e, 's, A, E, ES, SS> EventSource<A, E> for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

type Error = ES::Error

The error type.

type Events = ES::Events

Represents the sequence of events read from the event source.

fn read_events<I>(
    &self,
    id: &I,
    since: Since,
    max_count: Option<u64>
) -> Result<Option<Self::Events>, Self::Error> where
    I: AggregateId<A>, 

Reads events from the event source for a given identifier.

impl<'e, 's, A, E, ES, SS> SnapshotSource<A> for CompositeEntitySource<'e, 's, A, E, ES, SS> where
    A: Aggregate,
    E: AggregateEvent<A>,
    ES: EventSource<A, E> + 'e,
    SS: SnapshotSource<A> + 's, 

type Error = SS::Error

The error type.

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

Loads a versioned aggregate from the snapshot source.