Struct MemoryEventBus 

pub struct MemoryEventBus { /* private fields */ }

Implementations

impl MemoryEventBus

pub async fn published(&self) -> Vec<DomainEvent>

pub async fn outbox_records(&self) -> Vec<OutboxRecord>

Trait Implementations

impl Debug for MemoryEventBus

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

Formats the value using the given formatter.

impl Default for MemoryEventBus

fn default() -> MemoryEventBus

Returns the “default value” for a type.

impl EventPublisher for MemoryEventBus

fn publish<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 DomainEvent, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl OutboxStore for MemoryEventBus

fn enqueue<'life0, 'async_trait>( &'life0 self, record: OutboxRecord, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn claim_pending<'life0, 'life1, 'async_trait>( &'life0 self, worker_id: &'life1 str, limit: usize, claim_expires_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutboxRecord>, EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn claim_event<'life0, 'life1, 'async_trait>( &'life0 self, event_id: Uuid, worker_id: &'life1 str, claim_expires_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Option<OutboxRecord>, EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically claims one known event for request-assisted publication.

fn mark_published<'life0, 'life1, 'async_trait>( &'life0 self, event_id: Uuid, worker_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn mark_failed<'life0, 'life1, 'async_trait>( &'life0 self, event_id: Uuid, worker_id: &'life1 str, error: String, retry_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn recover_expired_claims<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<usize, EventError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,