Struct DelayQueue 

pub struct DelayQueue {
    conf: Arc<Config>,
    inner: Arc<Mutex<Inner>>,
}

Fields

conf: Arc<Config>

inner: Arc<Mutex<Inner>>

Implementations

impl DelayQueue

pub fn new(conf: Arc<Config>) -> Self

pub fn add(&self, s: Slot, i: MsgId, msg: Bytes, pol: RetryPolicy, now: Instant)

pub fn due(&self, now: Instant) -> Option<(Bytes, RetryPolicy)>

pub fn remove(&self, s: Slot, i: MsgId)

pub fn reset(&self, now: Instant)

pub fn gc(&self, s: Slot)

pub fn len(&self) -> usize

pub fn is_due(&self, now: Instant) -> bool

Trait Implementations

impl Clone for DelayQueue

fn clone(&self) -> DelayQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DelayQueue

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

Formats the value using the given formatter.