Struct MemoryEventOutbox 

pub struct MemoryEventOutbox<E, M> { /* private fields */ }

In-memory event store and outbox sharing one atomic commit boundary.

Implementations

impl<E, M> MemoryEventOutbox<E, M>

pub fn new() -> Self

Creates an empty combined store.

pub const fn event_store(&self) -> &MemoryEventStore<E>

Returns the event-store view used to read committed events.

pub const fn outbox(&self) -> &MemoryOutboxStore<M>

Returns the outbox view used by a publisher worker.

Trait Implementations

impl<E: Debug, M: Debug> Debug for MemoryEventOutbox<E, M>

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

Formats the value using the given formatter.

impl<E, M> Default for MemoryEventOutbox<E, M>

fn default() -> Self

Returns the “default value” for a type.

impl<E, M> TransactionalEventOutbox<E, M> for MemoryEventOutbox<E, M>

where E: DomainEvent + Clone, M: IntegrationEvent,

fn append_with_outbox<'a>( &'a self, stream_id: &'a StreamId, expected: ExpectedVersion, events: Vec<EventEnvelope<E>>, messages: Vec<OutboxRecord<M>>, ) -> BoxFuture<'a, SoapResult<AppendResult>>

Appends domain events and integration messages atomically.