Module pruning_watermark

Module pruning_watermark 

Source
Expand description

()PruningWatermarks.

Singleton row that holds the lowest still-available tx_seq and checkpoint_seq. Drives the bitmap CFs’ compaction filters and feeds available_range requests.

The bitmap CFs need to know the current tx_seq floor at compaction time, which runs in a RocksDB background thread without access to the schema. The pattern used here:

  1. A process-wide Arc<AtomicU64> (tx_seq_floor) holds the current floor.
  2. Bitmap CF options install compaction filters that clone the Arc and read the atomic on every key they consider.
  3. Indexer pipelines that advance pruning call super::RpcStoreSchema::set_pruning_floor after their batch commits, so the on-disk row and the atomic agree.
  4. On startup callers run super::RpcStoreSchema::refresh_pruning_atomics once to load the persisted floor into the atomic.

Structs§

Watermarks
Caller-facing view of the pruning watermarks.

Constants§

NAME

Functions§

options
store
Build the singleton (Key, Value) pair recording the current pruning floor.
tx_seq_floor
Process-wide tx_seq pruning floor used by the bitmap CFs’ compaction filters. Lazily allocated on first access.

Type Aliases§

Key
Value