Struct EventStream 

pub struct EventStream { /* private fields */ }

Cloneable, in-memory journal keyed by scan ID.

Implementations

impl EventStream

pub fn new() -> Self

pub fn record( &self, event: RealtimeEvent, ) -> Result<(), RealtimeEventValidationError>

Records a valid event in memory. It does not deliver the event to a client.

Invalid float ranges and empty scan IDs are rejected without mutating the journal.

pub fn events(&self, scan_id: &str) -> Vec<RealtimeEvent>

pub fn events_since( &self, scan_id: &str, since_exclusive: u64, ) -> Vec<RealtimeEvent>

pub fn recent_events(&self, scan_id: &str, limit: usize) -> Vec<RealtimeEvent>

pub fn clear_events(&self, scan_id: &str) -> usize

Removes an in-memory journal and returns the number of removed events.

pub fn event_count(&self, scan_id: &str) -> usize

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() -> EventStream

Returns the “default value” for a type.