Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Backpressure controller for managing load

Implementations

impl BackpressureController

pub fn new(strategy: BackpressureStrategy) -> Self

Create a new backpressure controller with the given strategy

pub fn should_apply_backpressure(&self) -> bool

Check if we should apply backpressure

pub fn get_backoff(&self) -> Option<Duration>

Get the backoff duration if throttling is needed

pub fn update_load(&mut self, load: usize)

Update the current load

pub fn can_accept(&self) -> bool

Check if we can accept more items based on the strategy