Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Per-subscription backpressure controller.

Tracks the backpressure strategy and dropped event count for a single subscription. The dispatcher consults this controller before sending each event to determine whether it should be delivered or dropped.

Implementations

impl BackpressureController

pub fn new(strategy: BackpressureStrategy) -> Self

Creates a new controller with the given strategy.

pub fn with_lag_threshold( strategy: BackpressureStrategy, threshold: u64, ) -> Self

Creates a new controller with a custom lag warning threshold.

pub fn should_deliver(&mut self) -> bool

Determines whether the next event should be delivered.

For Sample(n), increments an internal counter and returns true every Nth call. For other strategies, always returns true — the actual backpressure is handled by the broadcast channel or the dispatcher’s send logic.

pub fn record_drop(&mut self)

Records an event drop (e.g., DropNewest when buffer is full).

pub fn dropped(&self) -> u64

Returns the total number of events dropped.

pub fn strategy(&self) -> BackpressureStrategy

Returns the configured backpressure strategy.

pub fn lag_warning_threshold(&self) -> u64

Returns the lag warning threshold.

pub fn is_lagging(&self, lag: u64) -> bool

Returns true if the given lag exceeds the warning threshold.