Module: Kcl::Checkpoints::Sentinel
- Defined in:
- lib/kcl/checkpoints/sentinel.rb
Constant Summary collapse
- TRIM_HORIZON =
Start from the first available record in the shard.
'TRIM_HORIZON'.freeze
- LATEST =
Start from the latest record in the shard.
'LATEST'.freeze
- SHARD_END =
We’ve completely processed all records in this shard.
'SHARD_END'.freeze
- AT_TIMESTAMP =
Start from the record at or after the specified server-side timestamp.
'AT_TIMESTAMP'.freeze
- AFTER_SEQUENCE_NUMBER =
Continue from the sequence number in the shard.
'AFTER_SEQUENCE_NUMBER'.freeze