Struct EmitterState 

pub struct EmitterState {
    pub context: Context,
    pub last_seen: u64,
    pub message_count: u64,
    pub recent_values: Vec<f64>,
    pub is_anomalous: bool,
    /* private fields */
}

State for a single emitter

Fields

context: Context

Emitter’s context

last_seen: u64

Last seen timestamp

message_count: u64

Message count from this emitter

recent_values: Vec<f64>

Recent values (for cross-fleet comparison)

is_anomalous: bool

Is this emitter behaving anomalously?

Implementations

impl EmitterState

pub fn new() -> Self

Create a new emitter state

pub fn with_capacity(max_recent: usize) -> Self

Create with custom recent values capacity

pub fn record_value(&mut self, value: f64, timestamp: u64)

Record a new value

pub fn mean(&self) -> Option<f64>

Calculate mean of recent values

pub fn std_dev(&self) -> Option<f64>

Calculate standard deviation of recent values

pub fn last_value(&self) -> Option<f64>

Get the last recorded value

Trait Implementations

impl Debug for EmitterState

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

Formats the value using the given formatter.

impl Default for EmitterState

fn default() -> Self

Returns the “default value” for a type.