pub trait PostProcessor: Send {
// Required methods
fn name(&self) -> &str;
fn interval_secs(&self) -> u64;
fn process(&self, input: Box<dyn EventStream>) -> Box<dyn EventStream>;
}Expand description
Post-processor trait for data reduction (mean, max, min, etc.).