Struct DeadLetterQueue 

pub struct DeadLetterQueue { /* private fields */ }

Implementations

impl DeadLetterQueue

pub fn new() -> Self

pub fn persistent_default() -> Result<Self>

pub fn persistent(path: impl AsRef<Path>) -> Result<Self>

pub fn unavailable(error: impl Into<String>) -> Self

pub fn enqueue(&self, letter: DeadLetter) -> OclaResult<()>

pub fn dequeue( &self, scope: &DlqScope, id: &str, ) -> OclaResult<Option<DeadLetter>>

pub fn peek(&self, scope: &DlqScope) -> OclaResult<Vec<DeadLetter>>

pub fn get(&self, scope: &DlqScope, id: &str) -> OclaResult<Option<DeadLetter>>

pub fn lock_retry( &self, scope: &DlqScope, id: &str, ) -> OclaResult<DlqRetryGuard>

pub fn retry(&self, scope: &DlqScope, id: &str) -> OclaResult<()>

pub fn stats(&self, scope: Option<&DlqScope>) -> OclaResult<DlqStats>

pub fn ensure_writable(&self, scope: &DlqScope) -> OclaResult<()>

Trait Implementations

impl Clone for DeadLetterQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DeadLetterQueue

fn default() -> Self

Returns the “default value” for a type.