Struct EventQuery 

pub struct EventQuery {
    pub session_id: Option<SessionId>,
    pub branch_id: Option<BranchId>,
    pub after_seq: Option<SeqNo>,
    pub before_seq: Option<SeqNo>,
    pub limit: Option<usize>,
    pub metadata_filters: Option<Vec<(String, String)>>,
    pub kind_filter: Option<Vec<String>>,
}

Query parameters for reading events.

Fields

session_id: Option<SessionId>

branch_id: Option<BranchId>

after_seq: Option<SeqNo>

before_seq: Option<SeqNo>

limit: Option<usize>

metadata_filters: Option<Vec<(String, String)>>

Filter events by metadata key-value pairs (all must match).

kind_filter: Option<Vec<String>>

Filter by event kind discriminant name (e.g. “HiveArtifactShared”).

Implementations

impl EventQuery

pub fn new() -> Self

pub fn session(self, id: SessionId) -> Self

pub fn branch(self, id: BranchId) -> Self

pub fn after(self, seq: SeqNo) -> Self

pub fn before(self, seq: SeqNo) -> Self

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

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add a metadata key-value filter. All metadata filters must match.

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

Add a kind filter. Events must match any of the specified kind names.

impl EventQuery

pub fn matches_filters(&self, envelope: &EventEnvelope) -> bool

Check if an event envelope matches the metadata and kind filters. Used for post-deserialization filtering in journal implementations.

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.