Struct OutputQueue 

pub struct OutputQueue { /* private fields */ }

Manages a queue of outbound replication messages.

The queue has a configurable maximum size. When the queue is full or shut down, enqueue returns false. Messages can be dequeued in batches for efficient network I/O.

Implementations

impl OutputQueue

pub fn new(max_queue_size: usize) -> Self

Create a new output queue with the given maximum capacity.

pub fn enqueue(&self, message: Vec<u8>) -> bool

Enqueue a message.

Returns true if the message was accepted, false if the queue is full or has been shut down.

pub fn dequeue_batch(&self, max: usize) -> Vec<Vec<u8>>

Dequeue up to max messages in a batch.

Returns the messages in FIFO order. If fewer than max messages are available, returns all of them.

pub fn len(&self) -> usize

Return the number of messages currently in the queue.

pub fn is_empty(&self) -> bool

Return true if the queue is empty.

pub fn shutdown(&self)

Shut down the queue. No more messages will be accepted.

pub fn is_shutdown(&self) -> bool

Return true if the queue has been shut down.

pub fn clear(&self)

Clear all messages from the queue.

Trait Implementations

impl Debug for OutputQueue

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

Formats the value using the given formatter.