Struct AnnounceVerifyQueue 

pub struct AnnounceVerifyQueue { /* private fields */ }

Implementations

impl AnnounceVerifyQueue

pub fn new(max_entries: usize) -> Self

pub fn with_limits( max_entries: usize, max_bytes: usize, max_stale_secs: f64, overflow_policy: OverflowPolicy, ) -> Self

pub fn enqueue( &mut self, key: AnnounceVerifyKey, entry: PendingAnnounce, ) -> bool

pub fn take_pending( &mut self, now: f64, ) -> Vec<(AnnounceVerifyKey, PendingAnnounce)>

pub fn complete_success( &mut self, key: &AnnounceVerifyKey, ) -> Option<PendingAnnounce>

pub fn complete_failure(&mut self, key: &AnnounceVerifyKey) -> bool

pub fn len(&self) -> usize

pub fn queued_bytes(&self) -> usize

Trait Implementations

impl Clone for AnnounceVerifyQueue

fn clone(&self) -> AnnounceVerifyQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AnnounceVerifyQueue

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

Formats the value using the given formatter.