Represents the highest checkpoint for some pipeline that has been processed by the indexer
framework. When read from the Store, this represents the inclusive upper bound checkpoint of
data that has been written to the Store for a pipeline.
A watermark that represents the bounds for the region that the pruner is allowed to prune, and
the time in milliseconds the pruner must wait before it can begin pruning data.
Represents a database connection that can be used by the indexer framework to manage watermark
operations, agnostic of the underlying store implementation.
A storage-agnostic interface that provides database connections for both watermark management
and arbitrary writes. The indexer framework accepts this Store implementation to manage
watermarks operations through its associated Connection type. This store is also passed to the
pipeline handlers to perform arbitrary writes to the store.