Skip to main content

EventStore

Trait EventStore 

Source
pub trait EventStore: Send + Sync {
    // Required methods
    fn query(
        &self,
        event_class: Option<EventClass>,
        event_type: Option<&str>,
        after_seconds: Option<u64>,
        before_seconds: Option<u64>,
        source_instance_id: Option<&str>,
        limit: u32,
    ) -> Vec<PeatEvent>;
    fn store(&self, event: PeatEvent);
    fn count(&self) -> usize;
    fn remove_expired(&self);
}
Expand description

Trait for event storage backends

Required Methods§

Source

fn query( &self, event_class: Option<EventClass>, event_type: Option<&str>, after_seconds: Option<u64>, before_seconds: Option<u64>, source_instance_id: Option<&str>, limit: u32, ) -> Vec<PeatEvent>

Query events matching the given filters

Source

fn store(&self, event: PeatEvent)

Store an event

Source

fn count(&self) -> usize

Get count of stored events

Source

fn remove_expired(&self)

Remove expired events (TTL enforcement)

Implementors§