Struct CommandQueue 

pub struct CommandQueue { /* private fields */ }

Priority command queue

Implementations

impl CommandQueue

pub fn new(max_depth: usize) -> Self

Create a new command queue

pub fn enqueue(&mut self, command: PrioritizedCommand) -> Result<(), QueueError>

Enqueue a command with priority

pub fn enqueue_simple( &mut self, command: BackendCommand, ) -> Result<(), QueueError>

Enqueue a simple command (no priority metadata)

pub fn dequeue(&mut self) -> Option<QueueEntry>

Dequeue the highest priority command

pub fn peek(&self) -> Option<&QueueEntry>

Peek at the highest priority command without removing it

pub fn len(&self) -> usize

Get current queue depth

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn requeue_for_retry(&mut self, entry: QueueEntry) -> Result<(), QueueError>

Re-enqueue a command for retry

pub fn stats(&self) -> QueueStats

Get queue statistics

Trait Implementations

impl Default for CommandQueue

fn default() -> Self

Returns the “default value” for a type.