Struct DocumentQueue 

pub struct DocumentQueue { /* private fields */ }

A bounded in-memory queue of documents awaiting delivery.

When it fills, the oldest documents are dropped. Dropping the newest would be easier but wrong: during an outage the recent events are the ones describing what is going wrong, and they are what a beta debugger needs.

Implementations

impl DocumentQueue

pub fn new(capacity: usize) -> Self

pub fn push(&mut self, document: ForwardDocument)

Add a document, evicting the oldest if the queue is full.

pub fn take_batch( &mut self, max_documents: usize, max_bytes: usize, ) -> Vec<ForwardDocument>

Take the next batch, bounded by both document count and approximate size.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn dropped(&self) -> u64

Documents discarded because the queue was full.

Trait Implementations

impl Debug for DocumentQueue

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

Formats the value using the given formatter.