Struct OutboundQueue 

pub struct OutboundQueue { /* private fields */ }

FIFO of wire envelopes ready to ship.

Implementations

impl OutboundQueue

pub fn new() -> Self

Construct a fresh outbound queue with no cap.

pub fn with_cap(cap: Option<usize>) -> Self

Construct a fresh outbound queue with the given FIFO-drop cap. None disables the cap.

pub fn set_cap(&mut self, cap: Option<usize>)

Set the FIFO-drop cap. None removes the cap.

pub fn push(&mut self, env: WireEnvelope)

Push an envelope for shipment. If a cap is set and the queue is at the cap, FIFO-evict the oldest entry and bump the drop counter.

Stamps schema_version here so the encode boundary can read &WireEnvelope and call encode_to_vec without cloning the payload to set the field defensively.

pub fn drain_all(&mut self) -> Vec<WireEnvelope>

Drain all queued envelopes. Called by Phase 8 of the poll cycle.

pub fn take_dropped_count(&mut self) -> usize

Read + reset the count of FIFO-dropped envelopes since the last call. Returns 0 when no drops occurred.

pub fn len(&self) -> usize

Number of queued envelopes.

pub fn is_empty(&self) -> bool

Whether the queue is empty.

pub fn iter_for_snapshot(&self) -> impl Iterator<Item = &WireEnvelope>

Iterate queued envelopes for snapshot capture. The queue is not consumed - Phase 8 still drains on the next poll. .

Trait Implementations

impl Default for OutboundQueue

fn default() -> OutboundQueue

Returns the “default value” for a type.