Struct OutboundBatcher 

pub(super) struct OutboundBatcher {
    pending_batch: EnvelopeBatch,
    flush_scheduled: bool,
}

buffers control-plane envelopes behind one host flush timer

the first batched envelope schedules BATCH_FLUSH_TIMER_ID later batched envelopes join the same frame until the timer fires or the batch reaches MAX_OUTBOUND_BATCH_LEN

Fields

pending_batch: EnvelopeBatch

flush_scheduled: bool

Implementations

impl OutboundBatcher

pub(super) fn new() -> Self

pub(super) fn enqueue( &mut self, envelope: Envelope, mode: FlushMode, ) -> Vec<Command>

pub(super) fn extend(&mut self, envelopes: EnvelopeBatch)

pub(super) fn flush(&mut self, cancel_timer: bool) -> Vec<Command>

pub(super) fn clear(&mut self)

pub(super) fn discard_pending(&mut self) -> Vec<Command>

Trait Implementations

impl Clone for OutboundBatcher

fn clone(&self) -> OutboundBatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboundBatcher

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

Formats the value using the given formatter.

impl Default for OutboundBatcher

fn default() -> OutboundBatcher

Returns the “default value” for a type.

impl PartialEq for OutboundBatcher

fn eq(&self, other: &OutboundBatcher) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for OutboundBatcher

impl StructuralPartialEq for OutboundBatcher