Struct SignalRouter 

pub struct SignalRouter { /* private fields */ }

Signal router: dedup set + urgency-based attention + bounded priority queue.

Implementations

impl SignalRouter

pub const DEFAULT_DEDUPE_CAPACITY: usize = 256

pub fn new(max_queue_size: usize) -> Self

pub fn with_policy( max_queue_size: usize, ttl_ms: Option<u64>, deadline_escalation: bool, ) -> Self

pub fn ingest( &mut self, signal: RuntimeSignal, lifecycle: TaskLifecycle, ) -> 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 ingest_at( &mut self, signal: RuntimeSignal, lifecycle: TaskLifecycle, now_ms: u64, ) -> SignalRouteOutcome

pub fn expire(&mut self, now_ms: u64) -> Vec<String>

Expire queued signals against the journaled clock before either admission or delivery.

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

Pull next queued signal.

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).