Struct AscendingTimestampsGenerator 

pub struct AscendingTimestampsGenerator { /* private fields */ }

Watermark generator for strictly ascending timestamps.

Assumes events arrive in timestamp order with no lateness. The watermark equals the current timestamp. Use this for sources that guarantee ordering.

Example

use laminar_core::time::{AscendingTimestampsGenerator, WatermarkGenerator, Watermark};

let mut gen = AscendingTimestampsGenerator::new();
assert_eq!(gen.on_event(1000), Some(Watermark::new(1000)));
assert_eq!(gen.on_event(2000), Some(Watermark::new(2000)));

Implementations

impl AscendingTimestampsGenerator

pub fn new() -> Self

Creates a new ascending timestamps generator.

Trait Implementations

impl Debug for AscendingTimestampsGenerator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AscendingTimestampsGenerator

fn default() -> AscendingTimestampsGenerator

Returns the “default value” for a type.

impl WatermarkGenerator for AscendingTimestampsGenerator

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.

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

Advances the watermark to at least the given timestamp from an external source.