Struct RiskState 

pub struct RiskState { /* private fields */ }

The in-memory accumulator, owned single-threaded by the sink task (shared behind an RwLock so GET /api/v1/risk can read it).

Implementations

impl RiskState

pub fn len(&self) -> usize

Number of tracked entities.

pub fn is_empty(&self) -> bool

True when no entities are tracked.

pub fn total_entries(&self) -> usize

Total retained contributions across all entities (for the state gauge).

pub fn record( &mut self, cfg: &IncidentConfig, entity_type: &str, entity_value: &str, contribution: Contribution, now: i64, ) -> RecordOutcome

Record a contribution for an entity, returning an incident when a threshold is crossed outside the cooldown.

pub fn tick(&mut self, cfg: &IncidentConfig, now: i64) -> usize

Prune entities whose windows have fully aged out at now, returning the number removed (for eviction accounting).

pub fn snapshot(&self) -> RiskStateSnapshot

Capture the accumulator into a versioned persistence snapshot.

pub fn restore( &mut self, snap: RiskStateSnapshot, window_secs: i64, max_open_entities: usize, now: i64, ) -> bool

Restore a snapshot, dropping contributions already past the window at now, skipping entities left empty, and honoring max_open_entities so a restore cannot load more entities than the live cap allows. Returns false on a version mismatch (the caller starts fresh).

pub fn views(&self, cfg: &IncidentConfig, now: i64) -> Vec<RiskEntityView>

A read-only view of every open entity at now, for the admin API.

Trait Implementations

impl Debug for RiskState

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

Formats the value using the given formatter.

impl Default for RiskState

fn default() -> RiskState

Returns the “default value” for a type.