Struct EventRepository 

pub struct EventRepository<'a> { /* private fields */ }

Implementations

impl<'a> EventRepository<'a>

pub const fn new(conn: &'a Connection) -> Self

pub fn get(&self, event_id: Uuid) -> Result<Option<ChangeEvent>>

pub fn enqueue_delivery( &self, event_id: Uuid, subscription_id: Uuid, ) -> Result<()>

pub fn claim_due( &self, now: i64, duration_us: i64, ) -> Result<Option<EventDelivery>>

At most one active delivery per subscription, including claims made by other processes. Expired tokens are superseded by a strictly newer epoch.

pub fn complete(&self, delivery: &EventDelivery, now: i64) -> Result<bool>

pub fn retry( &self, delivery: &EventDelivery, now: i64, next_attempt_us: i64, error: &str, dead: bool, ) -> Result<bool>