Struct PgOutbox 

pub struct PgOutbox { /* private fields */ }

The outbox, as the relay reads it.

Implementations

impl PgOutbox

pub fn new(pool: PgPool) -> Self

pub fn with_lock_key(self, key: i64) -> Self

Another lock key: two projects relaying from one database each need their own.

Trait Implementations

impl Outbox for PgOutbox

fn try_lead<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, TransportError>> + Send + 'async_trait>>

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

Whether this process may relay now. Only one relay runs at a time, so the outbox order is kept with several worker replicas (a Postgres advisory lock). It is asked before every batch; once held, it keeps answering true.

fn fetch_unpublished<'life0, 'async_trait>( &'life0 self, limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventEnvelope>, TransportError>> + Send + 'async_trait>>

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

Up to limit unpublished events, oldest first (the order they were written).

fn mark_published<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [Uuid], ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Marks these events published. Idempotent: an id already marked is left as it is.