Struct Outbox 

pub struct Outbox<P, Tables = DefaultMailboxTables>
where
    P: Serialize + DeserializeOwned + Send + Sync + 'static,
{ /* private fields */ }

Implementations

impl<P, Tables> Outbox<P, Tables>

where P: Serialize + DeserializeOwned + Send + Sync + 'static + Unpin, Tables: MailboxTables,

pub async fn init(pool: &PgPool, config: MailboxConfig) -> Result<Self, Error>

pub async fn begin_op(&self) -> Result<DbOp<'static>, Error>

pub async fn publish_persisted_in_op( &self, op: &mut impl AtomicOperation, event: impl Into<P>, ) -> Result<(), Error>

pub async fn publish_all_persisted( &self, op: &mut impl AtomicOperation, events: impl IntoIterator<Item = impl Into<P>>, ) -> Result<(), Error>

pub async fn publish_ephemeral( &self, event_type: EphemeralEventType, event: impl Into<P>, ) -> Result<(), Error>

pub async fn publish_ephemeral_in_op( &self, op: &mut impl AtomicOperation, event_type: EphemeralEventType, event: impl Into<P>, ) -> Result<(), Error>

pub fn listen_persisted( &self, start_after: impl Into<Option<EventSequence>>, ) -> PersistentOutboxListener<P>

pub fn listen_ephemeral(&self) -> EphemeralOutboxListener<P>

pub fn listen_all( &self, start_after: impl Into<Option<EventSequence>>, ) -> AllOutboxListener<P>

pub async fn register_event_handler<H>( &self, jobs: &mut Jobs, config: OutboxEventJobConfig, handler: H, ) -> Result<(), Box<dyn Error + Send + Sync>>

where H: OutboxEventHandler<P>,

Trait Implementations

impl<P, Tables> Clone for Outbox<P, Tables>

where P: Serialize + DeserializeOwned + Send + Sync + 'static, Tables: MailboxTables,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P, Tables: Debug> Debug for Outbox<P, Tables>

where P: Serialize + DeserializeOwned + Send + Sync + 'static + Debug,

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

Formats the value using the given formatter.