Struct TestMonitoringHarness

pub struct TestMonitoringHarness {
    pub monitoring_rx: Receiver<ProcessingEvent>,
    events_seen: Arc<Mutex<HashSet<String>>>,
    event_history: Arc<Mutex<Vec<ProcessingEvent>>>,
}

Fields

monitoring_rx: Receiver<ProcessingEvent>

events_seen: Arc<Mutex<HashSet<String>>>

event_history: Arc<Mutex<Vec<ProcessingEvent>>>

Implementations

impl TestMonitoringHarness

pub fn new(monitoring_rx: Receiver<ProcessingEvent>) -> Self

pub async fn wait_for_events(&mut self, expected_events: &[&str]) -> Result<()>

Wait for specific events to occur

async fn process_event(&self, event: &ProcessingEvent) -> Result<()>

Process and categorize an event

pub async fn get_events_seen(&self) -> HashSet<String>

Get all events seen so far

pub async fn get_event_history(&self) -> Vec<ProcessingEvent>

Get full event history

pub async fn has_seen_event(&self, event: &str) -> bool

Check if a specific event has occurred

pub async fn get_event_count(&self, event_prefix: &str) -> usize

Get count of specific event type

pub async fn clear(&self)

Clear all seen events (useful for test isolation)

pub async fn dump_history(&self)

Dump event history for debugging

Trait Implementations

impl Debug for TestMonitoringHarness

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.