Struct TestHarness 

pub struct TestHarness { /* private fields */ }

Test harness for stream testing

Implementations

impl TestHarness

pub fn builder() -> TestHarnessBuilder

Create a new test harness builder

pub async fn now(&self) -> DateTime<Utc>

Get current mock time

pub async fn advance_time(&self, duration: Duration)

Advance mock time

pub async fn set_time(&self, time: DateTime<Utc>)

Set mock time

pub async fn push_event(&self, event: StreamEvent) -> Result<()>

Push a single event

pub async fn push_events(&self, events: Vec<StreamEvent>) -> Result<()>

Push multiple events

pub async fn generate_events(&self, count: usize) -> Result<()>

Generate and push events

pub async fn add_output(&self, event: StreamEvent)

Add output event (called by stream processor)

pub async fn get_output(&self) -> Vec<StreamEvent>

Get output events

pub async fn clear_output(&self)

Clear output events

pub async fn get_captured_events(&self) -> Vec<CapturedEvent>

Get captured events

pub async fn assert_event_count(&self, expected: usize) -> Result<()>

Assert event count

pub async fn assert_contains( &self, predicate: impl Fn(&StreamEvent) -> bool, ) -> Result<()>

Assert output contains event

pub async fn assert_no_events(&self) -> Result<()>

Assert no output events

pub async fn assert_within( &self, duration: Duration, condition: impl Fn(&[StreamEvent]) -> bool, ) -> Result<()>

Assert events within duration

pub async fn assert_performance( &self, metric: PerformanceMetric, threshold: f64, ) -> Result<()>

Assert performance metric

pub async fn get_metrics(&self) -> TestMetrics

Get test metrics

pub async fn get_assertions(&self) -> Vec<Assertion>

Get all assertions

pub async fn generate_report(&self) -> TestReport

Generate test report

pub async fn reset(&self)

Reset harness state