Struct SignalRouter 

pub struct SignalRouter { /* private fields */ }

High-performance signal router with deduplication and priority queuing.

Implementations

impl SignalRouter

pub fn new(max_queue_size: usize) -> Self

pub fn with_policy( max_queue_size: usize, policy: Box<dyn AttentionPolicy>, ) -> Self

pub fn ingest( &mut self, signal: RuntimeSignal, is_running: bool, ) -> SignalDisposition

Ingest a signal. Returns the disposition after dedup + attention evaluation. Queue dispositions are buffered; if the queue is full, returns Dropped so the SDK can apply backpressure or surface the loss to telemetry. All other dispositions are returned directly to the caller.

pub fn next(&mut self) -> Option<RuntimeSignal>

Pull next queued signal.

pub fn next_for(&mut self, recipient: Option<&str>) -> Option<RuntimeSignal>

Pull the next queued signal visible to recipient (broadcasts plus signals addressed to it); other recipients’ signals stay queued. None ⇒ no filter.

pub fn depth(&self) -> usize

Number of queued signals.

pub fn clear_dedup(&mut self)

Clear the dedup set (call at session boundaries to prevent unbounded growth).