Struct EventQuery 

pub struct EventQuery {
    pub kind: Option<String>,
    pub tool_id: Option<String>,
    pub correlation: Option<String>,
    pub principal: Option<String>,
    pub since: Option<DateTime<Utc>>,
}

Filter parameters for GET /v1/events. All fields optional.

Fields

kind: Option<String>

BrainEvent variant discriminant, e.g. signal_received, tool_call_started.

tool_id: Option<String>

Filter to a specific tool_id (only applies to tool-bound BrainEvents).

correlation: Option<String>

Correlation-id filter. Every event in one signal flow shares the originating signal’s id via observe::BrainEvent::id, so ?correlation=<uuid> reconstructs a single turn end-to-end. Matched as a string so a malformed value simply matches nothing rather than 400.

principal: Option<String>

Principal filter — accepted for forward compatibility; current events do not yet carry a principal on the bus, so this filter matches nothing when set.

since: Option<DateTime<Utc>>

RFC3339 timestamp; only events with ts >= since are forwarded.

Implementations

impl EventQuery

pub fn matches(&self, ev: &BrainEvent) -> bool

Returns true if the event should be forwarded to the client.

Trait Implementations

impl Debug for EventQuery

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

Formats the value using the given formatter.

impl Default for EventQuery

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EventQuery

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.