Struct PriorityEventQueue 

pub struct PriorityEventQueue { /* private fields */ }

Priority-based event queue for transmission scheduling

Events are organized into 4 priority levels:

• Level 0: CRITICAL - immediate, preempts all other traffic
• Level 1: HIGH - after CRITICAL
• Level 2: NORMAL - default priority
• Level 3: LOW - transmitted when bandwidth available

Implementations

impl PriorityEventQueue

pub fn new() -> Self

Create a new empty priority queue

pub fn push(&mut self, event: PeatEvent)

Push an event onto the appropriate priority queue

pub fn pop(&mut self) -> Option<PeatEvent>

Pop the highest-priority event

CRITICAL events are always returned first. If no CRITICAL events, returns from HIGH, then NORMAL, then LOW.

pub fn pop_critical(&mut self) -> Vec<PeatEvent>

Pop all CRITICAL events (for immediate transmission)

Returns events in FIFO order within CRITICAL priority.

pub fn pop_weighted(&mut self, max_events: usize) -> Vec<PeatEvent>

Pop events from non-critical queues for weighted fair transmission

Returns up to max_events events, weighted by priority:

• HIGH: 50% of allocation
• NORMAL: 35% of allocation
• LOW: 15% of allocation

Unused allocation rolls to lower priorities.

pub fn has_critical(&self) -> bool

Check if there are any CRITICAL events pending

pub fn len(&self) -> usize

Get total count of events across all priorities

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn len_at_priority(&self, priority: EventPriority) -> usize

Get count of events at a specific priority level

pub fn counts(&self) -> [usize; 4]

Get total count by priority level (for metrics)

pub fn clear(&mut self)

Clear all events from the queue

Trait Implementations

impl Debug for PriorityEventQueue

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

Formats the value using the given formatter.

impl Default for PriorityEventQueue

fn default() -> PriorityEventQueue

Returns the “default value” for a type.