Skip to main content

Module queue_storage

Module queue_storage 

Source

Structs§

BusyCounts
Per-table row counts observed at a rotation gate. 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§

shard_for_ordering_key
Deterministically map an ordering key to a shard in [0, shards).