[−][src]Trait eventmill::store::EventSink

pub trait EventSink<E, A> where
    E: EventType,
    A: WithAggregateId, {
    type Error: Error;
    fn append(&self, event: DomainEvent<E, A>) -> Result<(), Self::Error>;

    fn append_batch(
        &self, 
        events: impl IntoIterator<Item = DomainEvent<E, A>>
    ) -> Result<(), Self::Error>;
}

Associated Types

type Error: Error

Loading content...

Required methods

fn append(&self, event: DomainEvent<E, A>) -> Result<(), Self::Error>

fn append_batch(
    &self,
    events: impl IntoIterator<Item = DomainEvent<E, A>>
) -> Result<(), Self::Error>

Loading content...

Implementors

impl<E, A> EventSink<E, A> for InMemoryStore<E, A> where
    E: EventType,
    A: WithAggregateId,
    AggregateIdOf<A>: Display, [src]

type Error = Error

Loading content...