Struct BackpressureController 

pub struct BackpressureController { /* private fields */ }

Tracks backpressure state and transition counts.

Called by the bridge on every push/pop to update state. The Data Plane reads the current state to decide its I/O behavior.

Implementations

impl BackpressureController

pub fn new(config: BackpressureConfig) -> Self

Create a new controller with the given config.

pub fn update(&self, utilization_percent: u8) -> Option<PressureState>

Update the backpressure state based on current queue utilization.

Returns the new state if a transition occurred, or None if unchanged. The caller SHOULD emit a tracing event on transitions.

pub fn state(&self) -> PressureState

Current backpressure state.

pub fn throttle_transitions(&self) -> u64

Number of times the controller transitioned into Throttled.

pub fn suspend_transitions(&self) -> u64

Number of times the controller transitioned into Suspended.

Trait Implementations

impl Default for BackpressureController

fn default() -> Self

Returns the “default value” for a type.