Struct MultiSourceWatermarkManager 

pub struct MultiSourceWatermarkManager { /* private fields */ }

Multi-source watermark manager.

Implementations

impl MultiSourceWatermarkManager

pub fn new() -> Self

Create a new multi-source watermark manager.

pub async fn update_source_watermark( &self, source_id: String, watermark: Watermark, ) -> Result<()>

Update watermark for a source.

pub async fn global_watermark(&self) -> Watermark

Get the global watermark (minimum of all source watermarks).

pub async fn source_watermark(&self, source_id: &str) -> Option<Watermark>

Get watermark for a specific source.

pub async fn remove_source(&self, source_id: &str) -> Result<()>

Remove a source.

Trait Implementations

impl Default for MultiSourceWatermarkManager

fn default() -> Self

Returns the “default value” for a type.