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§
Sourcefn 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 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
Sourcefn remove_expired(&self)
fn remove_expired(&self)
Remove expired events (TTL enforcement)