Skip to main content

Module backpressure

Module backpressure 

Source
Expand description

Backpressure controller to bound in-flight work and prevent memory blowouts.

Uses tokio semaphores and bounded channels to limit concurrent tasks, ensuring the crawler stays within resource budgets.

Structs§

BackpressureController
Backpressure controller for bounded pipeline channels.
BackpressurePermit
RAII permit for backpressure.
BoundedPipeline
Bounded channel wrapper with backpressure.

Enums§

BackpressureError
Errors from backpressure operations.