logql

type BinOp struct {
	Op  string `json:"op"`
	LHS LogAST `json:"lhs"`
	RHS LogAST `json:"rhs"`
}

type Kind string

type LAggNode struct {
	// Vector aggregation (sum/avg/min/max/count … by/without)
	Op      string
	Param   *int // e.g. 3 for topk(3, ...)
	By      []string
	Without []string
	Child   LExecNode
}

type LBinOpNode struct {
	Op       string
	LHS, RHS LExecNode
}

type LExecNode interface{}

type LLeafNode struct {
	Leaf LogLeaf
}

type LQueryPlan struct {
	Root    LExecNode
	Leaves  []LogLeaf
	TagName string // Set this to a tag name to get distinct values for that tag
}

type LRangeAggNode struct {
	// Range aggregation over logs (rate/bytes_rate/count_over_time/…)
	Op    string
	Param *float64
	Child LExecNode // should be an LLeafNode or a subtree that ends at a leaf
}

type LScalarNode struct {
	Value float64
}

type LabelFilter struct {
	Label string  `json:"label"`
	Op    MatchOp `json:"op"` // =, !=, =~, !~
	Value string  `json:"value"`

	// Where did this appear in the pipeline?
	AfterParser bool `json:"afterParser,omitempty"` // true if it appeared after some parser
	ParserIdx   *int `json:"parserIdx,omitempty"`   // index in LogSelector.Parsers (0-based), if AfterParser
}

type LabelFormatExpr struct {
	Out  string `json:"out"`            // target label/column name
	Tmpl string `json:"tmpl,omitempty"` // original template (normalized, optional for debug)
	SQL  string `json:"sql"`            // compiled DuckDB SQL expression
}

type LabelMatch struct {
	Label string  `json:"label"`
	Op    MatchOp `json:"op"`
	Value string  `json:"value"`
}

type LineFilter struct {
	Op        LineFilterOp `json:"op"`
	Match     string       `json:"match"`
	ParserIdx *int         `json:"parserIdx,omitempty"`
}

type LineFilterOp string

type LogAST struct {
	Kind      Kind         `json:"kind"`
	LogSel    *LogSelector `json:"logSelector,omitempty"`
	LogRange  *LogRange    `json:"logRange,omitempty"`
	RangeAgg  *RangeAgg    `json:"rangeAgg,omitempty"`
	Vector    *Vector      `json:"vector,omitempty"`
	VectorAgg *VectorAgg   `json:"vectorAgg,omitempty"`
	BinOp     *BinOp       `json:"binop,omitempty"`
	Scalar    *float64     `json:"scalar,omitempty"`
	Raw       string       `json:"raw"`
}

type LogLeaf struct {
	ID string `json:"id"`

	// Pipeline (left→right) captured at selector level
	Matchers     []LabelMatch  `json:"matchers,omitempty"`
	LineFilters  []LineFilter  `json:"lineFilters,omitempty"`
	LabelFilters []LabelFilter `json:"labelFilters,omitempty"`
	Parsers      []ParserStage `json:"parsers,omitempty"`

	// Time shape attached to this pipeline (from enclosing LogRange)
	Range  string `json:"range,omitempty"`  // e.g. "5m"
	Offset string `json:"offset,omitempty"` // e.g. "1m"
	Unwrap bool   `json:"unwrap,omitempty"` // rare, but carry it

	// If this leaf is the input to a range aggregation, note the op
	RangeAggOp string   `json:"rangeAggOp,omitempty"` // e.g. "count_over_time", "rate"
	RangeParam *float64 `json:"rangeParam,omitempty"`

	// Optional: the immediate vector-agg goal above this leaf (helps worker decide grouping)
	OutBy      []string `json:"outBy,omitempty"`
	OutWithout []string `json:"outWithout,omitempty"`
}

type LogRange struct {
	Selector LogSelector `json:"selector"`
	Range    string      `json:"range"`  // e.g. "5m"
	Offset   string      `json:"offset"` // e.g. "1m"
	Unwrap   bool        `json:"unwrap"`
}

type LogSelector struct {
	Matchers     []LabelMatch  `json:"matchers"`
	LineFilters  []LineFilter  `json:"lineFilters,omitempty"`
	LabelFilters []LabelFilter `json:"labelFilters,omitempty"`
	Parsers      []ParserStage `json:"parsers,omitempty"` // json, logfmt, regexp, label_format, keep/drop, unwrap, etc.
}

type MatchOp string

type ParserStage struct {
	Type         string            `json:"type"`                   // json|logfmt|regexp|label_format|keep_labels|...
	Params       map[string]string `json:"params"`                 // optional (e.g. regexp pattern)
	Filters      []LabelFilter     `json:"filters,omitempty"`      // label filters that follow this parser
	LabelFormats []LabelFormatExpr `json:"labelFormats,omitempty"` // ONLY for label_format
}

type RangeAgg struct {
	Op      string   `json:"op"`              // rate, count_over_time, bytes_rate, quantile_over_time, ...
	Param   *float64 `json:"param,omitempty"` // e.g. 0.99
	By      []string `json:"by,omitempty"`
	Without []string `json:"without,omitempty"`
	Left    LogRange `json:"left"`
}

type Vector struct {
	Literal *float64 `json:"literal,omitempty"`
}

type VectorAgg struct {
	Op      string   `json:"op"`
	Param   *int     `json:"param,omitempty"` // e.g. 3 for topk(3, ...)
	By      []string `json:"by,omitempty"`
	Without []string `json:"without,omitempty"`
	Left    LogAST   `json:"left"` // vector or sample expression
}