Struct ShedState 

pub struct ShedState { /* private fields */ }

Node-wide and per-client in-flight serve counts. Held in an Arc so a ShedSlot can outlive the borrow that created it.

Implementations

impl ShedState

pub fn new() -> Arc<Self>

A counter with nothing in flight, already wrapped so ShedSlots can hold it.

pub fn counts(&self, client: B256) -> (u32, u32)

(node_in_flight, client_in_flight). A client with no entry counts 0.

pub fn node_in_flight(&self) -> u32

Node-wide serves in flight across all clients — the same count Self::counts returns as its first element, without needing a client key. Sampled onto the decdn_load_shed_streams_in_flight gauge so an operator can read live concurrency against the shed high-water mark.

pub fn acquire(self: &Arc<Self>, client: B256) -> ShedSlot

Increment both counters and hand back the RAII slot.

Trait Implementations

impl Debug for ShedState

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

Formats the value using the given formatter.

impl Default for ShedState

fn default() -> Self

Returns the “default value” for a type.