pub trait FlowEventHub: Send + Sync {
// Required methods
fn subscribe_flow_updates(&self) -> Receiver<FlowUpdate>;
fn redact_flow_update_for_output(&self, update: FlowUpdate) -> FlowUpdate;
fn record_flow_events_lagged(&self, skipped: u64);
}