Struct PrioritySyncQueue 

pub struct PrioritySyncQueue { /* private fields */ }

Priority-ordered sync queue

Maintains separate queues per QoS class with automatic aging promotion to prevent starvation of low-priority data.

Implementations

impl PrioritySyncQueue

pub fn new(max_bytes: usize) -> Self

Create a new priority sync queue

Arguments

• max_bytes - Maximum total size in bytes the queue can hold

pub fn default_capacity() -> Self

Default queue with 10 MB capacity

pub fn enqueue(&mut self, sync: PendingSync) -> Result<()>

Enqueue a sync item

Returns an error if the queue is full.

pub fn dequeue_highest(&mut self) -> Option<PendingSync>

Dequeue the highest priority item

Returns None if all queues are empty.

pub fn peek_highest(&self) -> Option<&PendingSync>

Peek at the highest priority item without removing

pub fn apply_aging(&mut self) -> usize

Apply aging promotion to queued items

Moves items that have waited long enough to higher priority queues. Returns the number of items promoted.

pub fn queue_depth(&self, class: QoSClass) -> usize

Get queue depth for a specific class

pub fn total_bytes_queued(&self) -> usize

Get total bytes currently queued

pub fn total_items(&self) -> usize

Get total items currently queued

pub fn is_empty(&self) -> bool

Check if the queue is empty

pub fn is_full(&self) -> bool

Check if the queue is full

pub fn available_bytes(&self) -> usize

Get available capacity in bytes

pub fn max_bytes(&self) -> usize

Get max capacity in bytes

pub fn stats(&self) -> QueueStats

Get queue statistics

pub fn clear(&mut self)

Clear all queued items

pub fn drain_class(&mut self, class: QoSClass) -> Vec<PendingSync>

Drain all items from a specific class

pub fn remove_stale(&mut self, max_age: Duration) -> usize

Remove items older than a threshold

Returns the number of items removed.

pub fn oldest_item_age(&self) -> Option<Duration>

Get oldest item across all queues (for monitoring)

pub fn dequeue_batch(&mut self, max_items: usize) -> Vec<PendingSync>

Dequeue up to N items, respecting priority order

pub fn dequeue_bytes(&mut self, max_bytes: usize) -> Vec<PendingSync>

Dequeue items up to a byte limit, respecting priority order

Trait Implementations

impl Debug for PrioritySyncQueue

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

Formats the value using the given formatter.