Module progress_monitoring 

Progress monitoring for analytics pipelines.

This module provides traits and implementations for monitoring the progress of data through analytics pipelines, including checking checkpoints in external stores like Snowflake.

Structs

SnowflakeMaxCheckpointReader

Reads the maximum checkpoint from a Snowflake table.

Traits

MaxCheckpointReader

Trait for reading the maximum checkpoint from an external store.

Functions

spawn_snowflake_monitors

Spawns background tasks to monitor Snowflake table checkpoints.