Struct BackpressureState 

pub struct BackpressureState { /* private fields */ }

Global backpressure state shared across the runtime.

This is written to the SHM control region for clients to read.

Implementations

impl BackpressureState

pub fn new() -> Self

Creates a new backpressure state.

pub fn get(&self) -> f32

Returns the current backpressure value (0.0-1.0).

pub fn set(&self, value: f32)

Sets the backpressure value (0.0-1.0).

pub fn record_rejection(&self)

Increments the rejected request count.

pub fn rejected_count(&self) -> u64

Returns the number of rejected requests.

pub fn active_clients(&self) -> usize

Returns the number of active clients.

pub fn queue_depth(&self) -> usize

Returns the current queue depth.

pub fn level(&self) -> &'static str

Returns the backpressure level as a string.

Trait Implementations

impl Debug for BackpressureState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BackpressureState

fn default() -> Self

Returns the “default value” for a type.