Struct EventTransmitter 

pub struct EventTransmitter { /* private fields */ }

Event transmitter with bandwidth control

Manages event queues with:

• Weighted fair queuing for priority levels
• Token bucket rate limiting
• Queue overflow handling

Implementations

impl EventTransmitter

pub fn new(allocation: BandwidthAllocation) -> Self

Create a new event transmitter

pub fn with_defaults() -> Self

Create with default allocation

pub fn set_max_queue_size(&mut self, priority: EventPriority, size: usize)

Set maximum queue size for a priority

pub fn set_overflow_policy(&mut self, policy: OverflowPolicy)

Set overflow policy

pub fn enqueue(&mut self, event: PeatEvent) -> bool

Enqueue an event for transmission

Returns true if event was accepted, false if dropped due to overflow.

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

Transmit events within bandwidth limits

Returns events ready for transmission, respecting bandwidth allocation.

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

Transmit all critical events immediately (preempt)

pub fn has_critical(&self) -> bool

Check if there are critical events pending

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

Get queue lengths

pub fn total_queued(&self) -> usize

Get total queued events

pub fn stats(&self) -> &TransmitterStats

Get transmission statistics

pub fn reset_stats(&mut self)

Reset statistics

pub fn available_bandwidth(&mut self) -> [f64; 4]

Get available bandwidth tokens per priority