Struct EventQuery 

pub struct EventQuery {
    pub topic: Option<String>,
    pub project_id: Option<String>,
    pub scope_id: Option<String>,
    pub from_commit_seq_exclusive: Option<u64>,
    pub to_commit_seq_exclusive: Option<u64>,
    pub from_ts_micros: Option<u64>,
    pub to_ts_micros: Option<u64>,
    pub field_filters: Vec<EventFieldFilter>,
    pub order: EventOrder,
    pub limit: usize,
}

Ergonomic query over the canonical event log (the event_outbox system table). Supports filtering by event type (topic), project/scope, commit-sequence range (cursor pagination), time range, and arbitrary payload fields (recipient, instance_id, block, …), in either direction.

Construct with EventQuery::new and the builder methods, then pass to AedbInstance::query_events. Pagination is commit-atomic: a page never splits the events emitted by a single commit, and the returned EventStreamPage::next_commit_seq is the cursor for the next page (feed it back as from_commit_seq_exclusive for ascending queries, or to_commit_seq_exclusive for descending queries).

Fields

topic: Option<String>

Event type filter (matches the emit topic). None matches all.

project_id: Option<String>

Restrict to events emitted under this project. None matches all.

scope_id: Option<String>

Restrict to events emitted under this scope. None matches all.

from_commit_seq_exclusive: Option<u64>

Exclusive lower bound on commit sequence (ascending cursor).

to_commit_seq_exclusive: Option<u64>

Exclusive upper bound on commit sequence (descending cursor).

from_ts_micros: Option<u64>

Inclusive lower bound on event timestamp (micros since epoch).

to_ts_micros: Option<u64>

Inclusive upper bound on event timestamp (micros since epoch).

field_filters: Vec<EventFieldFilter>

Payload field equality filters (ANDed together).

order: EventOrder

Scan direction.

limit: usize

Maximum number of events to return in this page.

Implementations

impl EventQuery

pub fn new() -> Self

Start an empty query (ascending, no filters). Set limit before use; a limit of 0 yields an empty page.

pub fn topic(self, topic: impl Into<String>) -> Self

Filter by event type (the emit topic).

pub fn namespace( self, project_id: impl Into<String>, scope_id: impl Into<String>, ) -> Self

Restrict to a single project / scope namespace.

pub fn after_commit_seq(self, seq: u64) -> Self

Resume an ascending scan after this commit sequence (exclusive).

pub fn before_commit_seq(self, seq: u64) -> Self

Resume a descending scan before this commit sequence (exclusive).

pub fn time_range( self, from_micros: Option<u64>, to_micros: Option<u64>, ) -> Self

Inclusive timestamp window (micros since epoch).

pub fn where_field( self, field: impl Into<String>, equals: impl Into<String>, ) -> Self

Add a payload-field equality filter (e.g. recipient, instance_id, block).

pub fn descending(self) -> Self

Newest-first ordering (for “latest N by type”).

pub fn limit(self, limit: usize) -> Self

Page size.

Trait Implementations

impl Clone for EventQuery

fn clone(&self) -> EventQuery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventQuery

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

Formats the value using the given formatter.

impl Default for EventQuery

fn default() -> EventQuery

Returns the “default value” for a type.

impl Eq for EventQuery

impl PartialEq for EventQuery

fn eq(&self, other: &EventQuery) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for EventQuery