Struct OutboxPublisher 

pub struct OutboxPublisher { /* private fields */ }

Implementations

impl OutboxPublisher

pub async fn init( pool: &Pool<Postgres>, clock: &ClockHandle, ) -> Result<OutboxPublisher, Error>

pub async fn publish_entity_events<Entity, Event>( &self, op: &mut impl AtomicOperation, _: Entity, new_events: Iter<'_, PersistedEvent<Event>>, ) -> Result<(), Error>

where Event: EsEvent, &'a Event: for<'a> Into<OutboxEventPayload>,

pub async fn publish_all( &self, op: &mut impl AtomicOperation, events: impl Iterator<Item = OutboxEventPayload>, ) -> Result<(), Error>

pub fn inner(&self) -> &Outbox<OutboxEventPayload, CalaMailboxTables>

Trait Implementations

impl Clone for OutboxPublisher

fn clone(&self) -> OutboxPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboxPublisher

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

Formats the value using the given formatter.