Module backpressure_controller 

Backpressure Controller

Adaptive backpressure control for streaming pipelines. Supports multiple strategies: Drop, Block, Throttle (token-bucket), and SpillToDisk.

Strategies

• Drop: Discard incoming items when the queue is above the high watermark.
• Block: Signal the caller to block (returns ThrottleDelay(u64::MAX)).
• Throttle: Token-bucket rate limiter — items accepted only when a token is available; delay returned otherwise.
• SpillToDisk: Like Drop but caller is expected to write to path; this module records the event for stats purposes only (I/O is caller’s concern).

Structs

BackpressureConfig

Configuration for a BackpressureController.

BackpressureController

Adaptive backpressure controller implementing multiple mitigation strategies.

BackpressureStats

Cumulative statistics tracked by a BackpressureController.

Enums

BackpressureDecision

Decision returned by BackpressureController::try_accept.

BackpressureStrategy

How the controller responds when the queue exceeds the high-watermark.