Struct cernan::filter::delay_filter::DelayFilter

pub struct DelayFilter { /* fields omitted */ }

Filter streams to within a bounded interval of current time.

This filter is intended to remove items from the stream which are too old, as defined by the current time and the configured tolerance. That is, if for some time T, (T - time::now()).abs() > tolerance the item associated with T will be rejected.

Methods

impl DelayFilter

pub fn new(config: &DelayFilterConfig) -> DelayFilter

Create a new DelayFilter

Trait Implementations

impl Filter for DelayFilter

fn process(     &mut self,     event: Event,     res: &mut Vec<Event> ) -> Result<(), FilterError>

Process a single metric::Event

fn run(&mut self, recv: Receiver<Event>, sources: Vec<String>, chans: Channel)

Run the Filter