Struct CommandQueues 

pub struct CommandQueues { /* private fields */ }

Bounded, priority-aware command queues for a station or gateway shard.

Implementations

impl CommandQueues

pub fn new(limits: CommandQueueLimits) -> Self

Creates empty command queues.

pub fn push( &mut self, command: CommandEnvelope, ingress: CommandIngress, ) -> Result<CommandPushOutcome, CommandQueueError>

Pushes a command through the barrier-aware ingress policy.

pub fn release_barrier_buffer(&mut self) -> Result<usize, CommandQueueError>

Moves commands buffered by a barrier back into priority queues.

If a target priority queue is full, the first blocked command and all commands after it remain in the barrier buffer for a later retry.

pub fn clear_barrier_buffer(&mut self) -> usize

Drops commands buffered by a barrier.

pub fn pop_next(&mut self) -> Option<CommandEnvelope>

Pops the next command, preferring high priority.

pub fn ready_len(&self) -> usize

Returns queued command count excluding the barrier buffer.

pub fn barrier_buffer_len(&self) -> usize

Returns command count buffered by an active barrier.

pub fn barrier_buffer_capacity(&self) -> usize

Maximum commands retained while a barrier buffers ingress.

The buffer uses the saturating sum of the three ready-queue limits so integrations get a bounded default without a separate hidden capacity.

pub fn total_len(&self) -> usize

Returns total command count including barrier buffer.

pub fn is_empty(&self) -> bool

Returns whether no commands are queued.

Trait Implementations

impl Clone for CommandQueues

fn clone(&self) -> CommandQueues

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommandQueues

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

Formats the value using the given formatter.