Trait FlowLagsProvider 

pub trait FlowLagsProvider: Send + Sync {
    // Required method
    fn all_lags(&self) -> Vec<FlowLagRow>;
}

Trait for providing flow lag data to virtual tables.

This trait is defined in the core crate to allow the engine crate to use it without depending on the sub-flow crate.

Implemented by FlowLagsProvider in the sub-flow crate. Used by the FlowLags virtual table in the engine crate.

Required Methods

fn all_lags(&self) -> Vec<FlowLagRow>

Get all flow lag rows.

Returns one row per (flow, source) pair, showing how far behind each flow is for each of its subscribed sources.

Implementors