Struct AlertRouter 

pub struct AlertRouter {
    sinks: Vec<Arc<dyn AlertSink>>,
    dedup_cache: RwLock<RawRwLock, HashMap<String, Instant>>,
    dedup_config: DeduplicationConfig,
    alert_count: AtomicU64,
    dedup_count: AtomicU64,
}

Alert router that sends alerts to multiple sinks.

Fields

sinks: Vec<Arc<dyn AlertSink>>

dedup_cache: RwLock<RawRwLock, HashMap<String, Instant>>

dedup_config: DeduplicationConfig

alert_count: AtomicU64

dedup_count: AtomicU64

Implementations

impl AlertRouter

pub fn new() -> AlertRouter

Create a new alert router.

pub fn with_deduplication(self, config: DeduplicationConfig) -> AlertRouter

Set deduplication config.

pub fn with_sink<S>(self, sink: S) -> AlertRouter

where S: AlertSink + 'static,

Add a sink.

pub fn with_sink_arc(self, sink: Arc<dyn AlertSink>) -> AlertRouter

Add a sink (Arc version).

pub async fn send(&self, alert: Alert)

Send an alert to all appropriate sinks.

pub fn send_sync(&self, alert: Alert)

Send an alert synchronously (spawns async task).

pub fn stats(&self) -> AlertRouterStats

Get statistics.

Trait Implementations

impl Default for AlertRouter

fn default() -> AlertRouter

Returns the “default value” for a type.