Struct MeteredGenerator 

pub struct MeteredGenerator<G: WatermarkGenerator> { /* private fields */ }

Watermark generator wrapper that collects metrics.

Implementations

impl<G: WatermarkGenerator> MeteredGenerator<G>

pub fn new(inner: G) -> Self

Creates a new metered generator.

pub fn metrics(&self) -> &WatermarkMetrics

Returns the current metrics.

pub fn inner_mut(&mut self) -> &mut G

Returns a mutable reference to the inner generator.

pub fn record_late_event(&mut self)

Records a late event.

Trait Implementations

impl<G: WatermarkGenerator> WatermarkGenerator for MeteredGenerator<G>

fn on_event(&mut self, timestamp: i64) -> Option<Watermark>

Process an event timestamp and potentially emit a new watermark.

fn on_periodic(&mut self) -> Option<Watermark>

Called periodically to emit watermarks based on wall-clock time.

fn current_watermark(&self) -> i64

Returns the current watermark value without advancing it.