Struct cernan::filter::FlushBoundaryFilter

pub struct FlushBoundaryFilter { /* fields omitted */ }

Buffer events for a set period of flushes

This filter is intended to hold events for a set number of flushes. This delays the events for the duration of those flushes but reduce the likelyhood of cross-flush splits of timestamps.

Methods

impl FlushBoundaryFilter

pub fn new(config: &FlushBoundaryFilterConfig) -> FlushBoundaryFilter

Create a new FlushBoundaryFilter

Trait Implementations

impl Filter for FlushBoundaryFilter

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