Struct AlertBus 

pub struct AlertBus { /* private fields */ }

Central alert bus.

Components fire alerts via AlertBus::fire; subscribers receive them synchronously in the same call.

Example

use obs_core::bus::AlertBus;
let bus = AlertBus::new();
assert_eq!(bus.subscriber_count(), 0);

Implementations

impl AlertBus

pub fn new() -> Self

Create a new bus with the default history limit (1 000 entries).

pub fn with_history_limit(limit: usize) -> Self

pub fn subscribe( &mut self, handler: Box<dyn AlertHandler>, min_severity: AlertSeverity, source: Option<String>, )

Register a handler that receives all alerts at or above min_severity. If source is Some, only alerts from that source component are delivered.

pub fn fire(&mut self, alert: Alert)

Dispatch alert to all matching subscribers and add it to history.

pub fn history(&self) -> &[Alert]

All alerts in history (oldest first).

pub fn history_at_or_above( &self, min: AlertSeverity, ) -> impl Iterator<Item = &Alert>

History filtered to severity >= min.

pub fn history_for_source<'a>( &'a self, source: &str, ) -> impl Iterator<Item = &'a Alert>

History filtered to a single source.

pub fn subscriber_count(&self) -> usize

Trait Implementations

impl Default for AlertBus

fn default() -> Self

Returns the “default value” for a type.