Struct WindowAggregator 

pub struct WindowAggregator { /* private fields */ }

窗口聚合器

按时间窗口收集 SanitizedEvent, 在窗口关闭时构建 StructuredContext。

Implementations

impl WindowAggregator

pub fn new(window_secs: u64, now_ms: i64) -> Self

创建新的窗口聚合器

window_secs 为窗口长度, 默认 10 秒。 now_ms 为当前 epoch 毫秒时间戳。

pub fn push(&mut self, event: SanitizedEvent)

向当前窗口追加一个脱敏事件

pub fn len(&self) -> usize

返回当前窗口内的已收集事件数

pub fn is_empty(&self) -> bool

返回 true 表示窗口为空

pub fn is_expired(&self, now_ms: i64) -> bool

窗口是否已到期

pub fn close(&mut self, now_ms: i64) -> Option<StructuredContext>

关闭当前窗口, 构建 StructuredContext, 并重置缓冲区。

now_ms 为窗口结束时间 (epoch ms)。 返回 Some(StructuredContext) 如果窗口非空, 否则返回 None。

Trait Implementations

impl Debug for WindowAggregator

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

Formats the value using the given formatter.