Struct AggregationWindow 

pub struct AggregationWindow { /* private fields */ }

Aggregation window for collecting events before summarization

Implementations

impl AggregationWindow

pub fn new( event_class: EventClass, event_type: &str, window_duration: Duration, ) -> Self

Create a new aggregation window

pub fn add(&mut self, event: PeatEvent)

Add an event to this window

pub fn should_flush(&self) -> bool

Check if the window should be flushed (time expired)

pub fn event_count(&self) -> usize

Get the number of events in this window

pub fn events(&self) -> &[PeatEvent]

Get events in this window

pub fn source_nodes(&self) -> &HashSet<String>

Get source node IDs

pub fn event_class(&self) -> EventClass

Get the event class

pub fn event_type(&self) -> &str

Get the event type

pub fn window_start(&self) -> Instant

Get window start time

pub fn reset(&mut self)

Reset the window for a new aggregation period

Trait Implementations

impl Debug for AggregationWindow

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

Formats the value using the given formatter.