Struct PriorityEventProcessor 

pub struct PriorityEventProcessor<M: Message> { /* private fields */ }

Priority-aware event processor

Implementations

impl<M: Message> PriorityEventProcessor<M>

pub fn new() -> Self

Create a new priority event processor with default configuration

pub fn with_config(config: PriorityConfig) -> Self

Create a new priority event processor with custom configuration

pub fn stats(&self) -> EventStats

Get current statistics

pub fn reset_stats(&self)

Reset statistics

pub fn advanced_metrics(&self) -> AdvancedEventStats

Get advanced metrics snapshot

pub fn metrics_collector(&self) -> Arc<MetricsCollector>

Get metrics collector for external monitoring

pub fn enable_auto_scaling(&mut self, config: AutoScaleConfig)

Enable auto-scaling with the given configuration

pub fn disable_auto_scaling(&mut self)

Disable auto-scaling

pub fn resize_queue(&self, new_size: usize) -> Result<(), ResizeError>

Manually resize the queue

pub fn queue_capacity(&self) -> usize

Get current queue capacity

pub fn push(&self, event: Event<M>) -> Result<(), Event<M>>

Push an event to the queue

pub fn pop(&self) -> Option<Event<M>>

Pop the highest priority event from the queue

pub fn is_empty(&self) -> bool

Check if the queue is empty

pub fn queue_size(&self) -> usize

Get the current queue size

pub fn process_events( &self, message_rx: &Receiver<Event<M>>, crossterm_rx: &Receiver<CrosstermEvent>, tick_rate: Duration, ) -> Option<Event<M>>

Process events from multiple sources with priority handling

pub fn process_events_headless( &self, message_rx: &Receiver<Event<M>>, tick_rate: Duration, ) -> Option<Event<M>>

Process events in headless mode (no terminal events)

Trait Implementations

impl<M: Message> Default for PriorityEventProcessor<M>

fn default() -> Self

Returns the “default value” for a type.