Struct EventStream 

pub struct EventStream {
    pub events: Vec<DashboardEvent>,
    pub max_buffer_size: usize,
    pub is_active: bool,
}

Event stream for real-time dashboard updates

Fields

events: Vec<DashboardEvent>

Buffer of recent events

max_buffer_size: usize

Maximum number of events to buffer

is_active: bool

Whether the stream is actively monitoring

Implementations

impl EventStream

pub fn new() -> Self

Create a new event stream with default buffer size

pub fn with_buffer_size(buffer_size: usize) -> Self

Create a new event stream with custom buffer size

pub fn add_event(&mut self, event: DashboardEvent)

Add an event to the stream

pub fn recent_events(&self, window_secs: i64) -> Vec<&DashboardEvent>

Get recent events within a time window (in seconds)

pub fn events_of_type( &self, event_type: &DashboardEventType, ) -> Vec<&DashboardEvent>

Get events of a specific type

pub fn clear(&mut self)

Clear all events from the buffer

pub const fn start(&mut self)

Start monitoring events

pub const fn stop(&mut self)

Stop monitoring events

Trait Implementations

impl Clone for EventStream

fn clone(&self) -> EventStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventStream

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

Formats the value using the given formatter.

impl Default for EventStream

fn default() -> Self

Returns the “default value” for a type.