Struct Query 

pub struct Query<A> {
    pub attrs: Attrs,
    pub sources: Vec<Source<A>>,
    pub predicate: Option<ExprRef>,
    pub group_by: Option<GroupBy>,
    pub order_by: Option<OrderBy>,
    pub limit: Option<Limit>,
    pub projection: ExprRef,
    pub distinct: bool,
    pub meta: A,
}

A complete EventQL query.

This is the root node of the AST, representing a full query with all its clauses. A query must have at least one source and a projection; other clauses are optional.

Structure

FROM <alias> <source>
[FROM <alias> <source>] ...
[WHERE <condition>]
[GROUP BY <field> [HAVING <condition>]]
[ORDER BY <field> ASC|DESC]
[TOP|SKIP <n>]
PROJECT INTO [DISTINCT] <projection>

Examples

use eventql_parser::Session;

let mut session = Session::builder().use_stdlib().build();
let query = session.parse(
    "FROM e IN events \
     WHERE e.price > 100 \
     ORDER BY e.timestamp DESC \
     TOP 10 \
     PROJECT INTO {id: e.id, price: e.price}"
).unwrap();

assert_eq!(query.sources.len(), 1);
assert!(query.predicate.is_some());
assert!(query.order_by.is_some());
assert!(query.limit.is_some());

Fields

attrs: Attrs

Metadata about this query

sources: Vec<Source<A>>

FROM clause sources (must have at least one)

predicate: Option<ExprRef>

Optional WHERE clause filter predicate

group_by: Option<GroupBy>

Optional GROUP BY clause expression

order_by: Option<OrderBy>

Optional ORDER BY clause

limit: Option<Limit>

Optional LIMIT clause (TOP or SKIP)

projection: ExprRef

PROJECT INTO clause expression (required)

distinct: bool

Remove duplicate rows from the query’s results

meta: A

Type-level metadata about the query’s analysis state.

This field uses a generic type parameter to track whether the query is in a raw (unparsed/untyped) state or has been statically analyzed:

• Query<Raw>: Query parsed but not yet type-checked
• Query<Typed>: Query that has passed static analysis with validated types and variable scopes

This provides compile-time guarantees about the query’s type safety.

Trait Implementations

impl<A: Clone> Clone for Query<A>

fn clone(&self) -> Query<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug> Debug for Query<A>

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

Formats the value using the given formatter.

impl<A> Serialize for Query<A>

where A: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.