Struct LeidenCache 

pub struct LeidenCache {
    pub commit_latency_ms: VecDeque<u64>,
    pub last_recompute_at: Option<Instant>,
    pub commit_arrivals: VecDeque<Instant>,
    pub default_mode: LeidenMode,
    pub storm_cap_per_min: u32,
}

Gap 10 Phase-1 debounce + storm-cap state.

Fields

commit_latency_ms: VecDeque<u64>

Rolling ring of commit wall-clock latencies (milliseconds).

last_recompute_at: Option<Instant>

Instant of the most recent successful full recompute.

commit_arrivals: VecDeque<Instant>

Ring of commit arrivals inside the trailing 60s.

default_mode: LeidenMode

Default mode at process start.

storm_cap_per_min: u32

Effective storm cap (operator-overridable).

Implementations

impl LeidenCache

pub fn observe_commit_latency(&mut self, latency: Duration)

Record a completed-commit wall-time sample.

pub fn observe_commit_arrival(&mut self, at: Instant)

Record a commit arrival; evicts entries older than 60s.

pub fn rolling_p75_commit_ms(&self) -> Option<u64>

Nearest-rank p75 of the rolling commit-latency ring.

pub fn effective_debounce_ms(&self) -> u64

Effective debounce window via derive_debounce_ms.

pub fn storm_cap_reached(&self) -> bool

Is the 60s commit-arrival ring at or above the storm cap?

pub fn select_mode(&self, node_count: usize, now: Instant) -> LeidenMode

Pure policy function. Returns the mode to serve this call.

Trait Implementations

impl Debug for LeidenCache

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

Formats the value using the given formatter.

impl Default for LeidenCache

fn default() -> Self

Returns the “default value” for a type.