Module queue_depth 

Available on crate feature serve and crate feature triggers and (crate features triggers-kafka or triggers-redis) only.

queue_depth trigger: poll a queue’s depth and fire edge-triggered (once per rising crossing of threshold, suppressed until it drains). The Edge is pure; DepthProbe is the IO seam (Redis/Kafka impls + a fake in tests).

Structs

Edge

Edge detector. Fires once when depth first reaches threshold; re-arms only after depth drops below threshold.

QueueDepthWatcher

Traits

DepthProbe

The IO seam: returns the current depth of the queue.

Functions

build_probe

Build the depth probe for a queue spec (feature-gated backends).