Skip to main content

FlowEventHub

relay_core_runtime::services::flow_event

Trait FlowEventHub 

Source 
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);
}

Required Methods§

Source

fn subscribe_flow_updates(&self) -> Receiver<FlowUpdate>

Source

fn redact_flow_update_for_output(&self, update: FlowUpdate) -> FlowUpdate

Source

fn record_flow_events_lagged(&self, skipped: u64)

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§