Struct PerSourceWatermarkTracker 

pub struct PerSourceWatermarkTracker { /* private fields */ }

Tracks watermarks for multiple event sources.

The effective watermark is the minimum watermark across all registered sources, ensuring no source’s events are prematurely considered late.

Implementations

impl PerSourceWatermarkTracker

pub fn new() -> Self

Create a new empty tracker.

pub fn register_source(&mut self, name: &str, max_ooo: Duration)

Register a source with its maximum out-of-orderness tolerance.

pub fn observe_event(&mut self, source: &str, event_ts: DateTime<Utc>)

Observe an event from a source, updating its watermark.

pub const fn effective_watermark(&self) -> Option<DateTime<Utc>>

Get the effective (minimum) watermark across all sources.

pub fn advance_source_watermark(&mut self, source: &str, wm: DateTime<Utc>)

Manually advance a source’s watermark (e.g., from upstream context).

pub fn checkpoint(&self) -> WatermarkCheckpoint

Create a checkpoint of the tracker state.

pub fn restore(&mut self, cp: &WatermarkCheckpoint)

Restore tracker state from a checkpoint.

pub fn has_sources(&self) -> bool

Check if any sources are registered.

Trait Implementations

impl Debug for PerSourceWatermarkTracker

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

Formats the value using the given formatter.

impl Default for PerSourceWatermarkTracker

fn default() -> Self

Returns the “default value” for a type.