query

type AggOp string

type Aggregation struct {
	Op    AggOp  `json:"op"`
	Field string `json:"field,omitempty"`
	Alias string `json:"alias,omitempty"`
}

type Column struct {
	Name string `json:"name"`
	Type string `json:"type"` // "string" | "int" | "float" | "bool" | "time"
}

type Compiled struct {
	SQL     string
	Args    []any
	Columns []Column
	// HasBucket reports whether the query included a time bucket; when true,
	// the first column is the bucket time and callers should group rows into
	// time-series lines keyed by the GROUP BY tuple.
	HasBucket bool
	// GroupKeys holds the aliases of GROUP BY expressions (used to split
	// rows into series).
	GroupKeys []string
	// Rates describes post-processing transforms that turn underlying SUM/
	// AVG/MAX columns into per-second deltas. Executor applies them after
	// scanning the rows from SQLite.
	Rates []RateSpec
}

type Dataset string

type Filter struct {
	Field string   `json:"field"`
	Op    FilterOp `json:"op"`
	Value any      `json:"value,omitempty"`
}

type FilterOp string

type JSONTime struct {
	time.Time
}

type Order struct {
	Field string `json:"field"`
	Dir   string `json:"dir,omitempty"` // "asc" | "desc" (default desc)
}

type Query struct {
	Dataset   Dataset       `json:"dataset"`
	TimeRange TimeRange     `json:"time_range"`
	Select    []Aggregation `json:"select"`
	Where     []Filter      `json:"where,omitempty"`
	GroupBy   []string      `json:"group_by,omitempty"`
	OrderBy   []Order       `json:"order_by,omitempty"`
	Having    []Filter      `json:"having,omitempty"`
	Limit     int           `json:"limit,omitempty"`
	// BucketMS, when > 0, groups rows into time buckets of that size and
	// emits a `bucket_ns` column as the first SELECT entry. Use this for
	// time-series charts.
	BucketMS int64 `json:"bucket_ms,omitempty"`
}

type RateSpec struct {
	ColumnIndex int
	BucketSecs  float64
}

type TimeRange struct {
	From JSONTime `json:"from"`
	To   JSONTime `json:"to"`
}