Struct EventServices 

pub struct EventServices {
    pub publisher: Arc<dyn EventPublisher>,
    pub outbox: Arc<dyn OutboxStore>,
}

Fields

publisher: Arc<dyn EventPublisher>

outbox: Arc<dyn OutboxStore>

Implementations

impl EventServices

pub async fn dispatch_once( &self, worker_id: &str, limit: usize, lease: TimeDelta, ) -> Result<DispatchReport, EventError>

Executes one bounded, explicit outbox-dispatch pass.

Minco never schedules this automatically. Applications choose request-assisted delivery, an SQS-triggered worker, an operator command, or an explicitly costed recovery schedule.

Trait Implementations

impl Clone for EventServices

fn clone(&self) -> EventServices

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventServices

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

Formats the value using the given formatter.