Struct Outbox 

pub struct Outbox { /* private fields */ }

Implementations

impl Outbox

pub fn new(storage: Arc<Storage>) -> Self

pub fn enqueue_event( &self, batch: &mut BatchWriter, operation_id: &str, event: &ChangeEvent, )

pub fn enqueue_events( &self, batch: &mut BatchWriter, operation_id: &str, events: &[ChangeEvent], )

pub fn pending_events(&self) -> Result<Vec<OutboxEntry>>

Errors

Returns an error if reading from storage fails.

pub fn mark_delivered(&self, operation_id: &str) -> Result<()>

Errors

Returns an error if removing from storage fails.

pub fn pending_count(&self) -> Result<usize>

Errors

Returns an error if reading from storage fails.

pub fn increment_retry(&self, operation_id: &str) -> Result<()>

Errors

Returns an error if reading or writing to storage fails.

pub fn update_dispatched_count( &self, operation_id: &str, count: usize, ) -> Result<()>

Errors

Returns an error if reading or writing to storage fails.

pub fn move_to_dead_letter(&self, operation_id: &str) -> Result<()>

Errors

Returns an error if reading or writing to storage fails.

pub fn dead_letter_entries(&self) -> Result<Vec<OutboxEntry>>

Errors

Returns an error if reading from storage fails.

pub fn dead_letter_count(&self) -> Result<usize>

Errors

Returns an error if reading from storage fails.

pub fn remove_dead_letter(&self, operation_id: &str) -> Result<()>

Errors

Returns an error if removing from storage fails.