Struct CallQueue 

pub struct CallQueue { /* private fields */ }

Implementations

impl CallQueue

pub fn start<F>(host: Host, opts: QueueOptions, work: F) -> CallQueue

where F: Fn(&ConcludedCall) -> Attempt + Send + Sync + 'static,

Start opts.threads workers running work on each call pushed — and on calls saved by the last shutdown, first.

pub fn start_by<L, F>( host: Host, opts: QueueOptions, lane: L, work: F, ) -> CallQueue

where L: Fn(&ConcludedCall) -> String + Send + Sync + 'static, F: Fn(&ConcludedCall) -> Attempt + Send + Sync + 'static,

start, with each call put in the lane lane names (the server it goes to, say): each lane has opts.threads workers of its own, and its own retries and endpoint status. Calls saved by the last shutdown are put in the lane lane names for them now.

pub fn push(&self, call: ConcludedCall)

pub fn len(&self) -> usize

Calls queued or being worked on.

pub fn is_empty(&self) -> bool

pub fn shutdown(&mut self, grace: Duration)

Work what’s ready until grace is nearly up; save the rest (or fail it). Call it from crate::Plugin::shutdown; calls pushed after it are refused.