Struct AlertRouter 

pub struct AlertRouter { /* private fields */ }

Alert router that directs alerts to appropriate sinks

Routing Rules

1. If an alert has tags, it’s sent to sinks that handle those tags
2. If no tag matches, it’s sent to default sinks (those with empty tag lists)
3. Sinks with no tags configured receive all alerts

Dead Letter Queue

Failed deliveries are stored in a dead-letter queue for later retry.

Implementations

impl AlertRouter

pub fn new() -> Self

Create a new alert router

pub fn with_max_dlq_size(self, size: usize) -> Self

Set maximum dead-letter queue size

pub fn register_sink(&self, name: &str, sink: Arc<dyn AlertSink>)

Register a sink

Arguments

• name - Unique name for the sink
• sink - The sink implementation

pub fn unregister_sink(&self, name: &str) -> bool

Unregister a sink

Arguments

• name - Name of sink to remove

Returns

true if sink was removed

pub fn emit(&self, alert: Alert)

Emit an alert to appropriate sinks

Arguments

• alert - The alert to send

pub fn dlq_size(&self) -> usize

Get current dead-letter queue size

pub fn drain_dlq(&self) -> Vec<DeadLetterEntry>

Drain the dead-letter queue

pub fn flush(&self)

Flush all sinks

pub fn list_sinks(&self) -> Vec<String>

List registered sink names

pub fn get_sink(&self, name: &str) -> Option<Arc<dyn AlertSink>>

Get sink by name

Trait Implementations

impl Default for AlertRouter

fn default() -> Self

Returns the “default value” for a type.

impl Send for AlertRouter

impl Sync for AlertRouter