Struct FdPressureGuard 

pub struct FdPressureGuard { /* private fields */ }

Shared fd-pressure demotion state machine.

Implementations

impl FdPressureGuard

pub fn new(config: FdPressureConfig) -> Self

Build a guard with explicit tunables.

pub fn on_accept_error(&self, err: &Error) -> FdPressureDecision

Classify one accept error. Fd-exhaustion errors demote the broker; anything else is reported back to the caller as unrelated.

pub fn on_accept_ok(&self) -> bool

Record one successful accept. Returns true when this accept cleared an active demotion.

pub fn is_demoted(&self) -> bool

Whether new Hello connections are currently being refused.

pub fn demotions_total(&self) -> u64

Total demotion episodes since the guard was created.

pub fn refused_while_demoted(&self) -> u64

Hello connections refused with ERROR_FD_PRESSURE so far.

pub fn refusal_reply(&self) -> HelloReply

Structured refusal sent to Hello clients while demoted.

pub fn force_demote(&self)

Force a demotion without an accept error (tests / external probes).

Trait Implementations

impl Debug for FdPressureGuard

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

Formats the value using the given formatter.

impl Default for FdPressureGuard

fn default() -> FdPressureGuard

Returns the “default value” for a type.