Struct InMemorySink 

pub struct InMemorySink {
    alerts: RwLock<RawRwLock, Vec<Alert>>,
    max_alerts: usize,
    min_severity: AlertSeverity,
}

Alert sink that stores alerts in memory (for testing).

Fields

alerts: RwLock<RawRwLock, Vec<Alert>>

max_alerts: usize

min_severity: AlertSeverity

Implementations

impl InMemorySink

pub fn new(max_alerts: usize) -> InMemorySink

Create a new in-memory sink.

pub fn with_severity_filter(self, min: AlertSeverity) -> InMemorySink

Set minimum severity filter.

pub fn alerts(&self) -> Vec<Alert>

Get all stored alerts.

pub fn count(&self) -> usize

Get the count of stored alerts.

pub fn clear(&self)

Clear all stored alerts.

Trait Implementations

impl AlertSink for InMemorySink

fn send<'life0, 'life1, 'async_trait>( &'life0 self, alert: &'life1 Alert, ) -> Pin<Box<dyn Future<Output = Result<(), AlertSinkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InMemorySink: 'async_trait,

Send an alert to the sink.

fn sink_name(&self) -> &str

Get the sink name.

fn accepts_severity(&self, severity: AlertSeverity) -> bool

Check if this sink accepts alerts of the given severity.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), AlertSinkError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InMemorySink: 'async_trait,

Health check the sink.