module Kcl::Checkpoints::Sentinel

Constants

AFTER_SEQUENCE_NUMBER

Continue from the sequence number in the shard.

AT_TIMESTAMP

Start from the record at or after the specified server-side timestamp.

LATEST

Start from the latest record in the shard.

SHARD_END

We've completely processed all records in this shard.

TRIM_HORIZON

Start from the first available record in the shard.