Skip to main content

Module queue_storage

Module queue_storage 

Source

Structs§

BusyCounts
Per-table presence observed at a rotation gate. Each non-zero value means “this table was non-empty”; it is not an exact row count. Each ring populates only the fields meaningful for it; unused fields stay zero. The maintenance loop emits one OTel metric label per non-zero field so dashboards can attribute “rotation pinned” to the responsible side.
ClaimedEntry
ClaimedRuntimeJob
QueueClaimerLease
QueueClaimerState
QueueCounts
QueueStorage
Segmented queue storage backend.
QueueStorageConfig
TerminalDeltaRollupOutcome

Enums§

PruneOutcome
RotateOutcome
SkipReason
Discriminator for PruneOutcome::SkippedActive.

Functions§

ordering_key_hash64
Portable 64-bit hash over raw ordering-key bytes.
shard_for_ordering_key
Deterministically map an ordering key to a shard in [0, shards).