dag

type Agg struct {
	Kind  string `json:"kind" unpack:""`
	Name  string `json:"name"`
	Expr  Expr   `json:"expr"`
	Where Expr   `json:"where"`
}

type ArrayExpr struct {
	Kind  string `json:"kind" unpack:""`
	Exprs []Expr `json:"exprs"`
}

type Assignment struct {
	Kind string `json:"kind" unpack:""`
	LHS  Expr   `json:"lhs"`
	RHS  Expr   `json:"rhs"`
}

type BinaryExpr struct {
	Kind string `json:"kind" unpack:""`
	Op   string `json:"op"`
	LHS  Expr   `json:"lhs"`
	RHS  Expr   `json:"rhs"`
}

type Call struct {
	Kind string `json:"kind" unpack:""`
	Name string `json:"name"`
	Args []Expr `json:"args"`
}

type Case struct {
	Expr Expr `json:"expr"`
	Op   Op   `json:"op"`
}

type Cast struct {
	Kind string      `json:"kind" unpack:""`
	Expr Expr        `json:"expr"`
	Type astzed.Type `json:"type"`
}

type CommitMeta struct {
	Kind      string      `json:"kind" unpack:""`
	Pool      ksuid.KSUID `json:"pool"`
	Commit    ksuid.KSUID `json:"branch"`
	Meta      string      `json:"meta"`
	ScanLower Expr        `json:"scan_lower"`
	ScanUpper Expr        `json:"scan_upper"`
	ScanOrder string      `json:"scan_order"`
}

type Conditional struct {
	Kind string `json:"kind" unpack:""`
	Cond Expr   `json:"cond"`
	Then Expr   `json:"then"`
	Else Expr   `json:"else"`
}

type Const struct {
	Kind string `json:"kind" unpack:""`
	Name string `json:"name"`
	Expr Expr   `json:"expr"`
}

type Cut struct {
	Kind  string       `json:"kind" unpack:""`
	Args  []Assignment `json:"args"`
	Quiet bool         `json:"quiet"`
}

type Dot struct {
	Kind string `json:"kind" unpack:""`
	LHS  Expr   `json:"lhs"`
	RHS  string `json:"rhs"`
}

type Drop struct {
	Kind string `json:"kind" unpack:""`
	Args []Expr `json:"args"`
}

type Entry struct {
	Key   Expr `json:"key"`
	Value Expr `json:"value"`
}

type Explode struct {
	Kind string      `json:"kind" unpack:""`
	Args []Expr      `json:"args"`
	Type astzed.Type `json:"type"`
	As   Expr        `json:"as"`
}

type Expr interface {
	ExprDAG()
}

type Field struct {
	Name  string `json:"name"`
	Value Expr   `json:"value"`
}

type File struct {
	Kind   string       `json:"kind" unpack:""`
	Path   string       `json:"path"`
	Format string       `json:"format"`
	Layout order.Layout `json:"layout"`
}

type Filter struct {
	Kind string `json:"kind" unpack:""`
	Expr Expr   `json:"expr"`
}

type From struct {
	Kind   string  `json:"kind" unpack:""`
	Trunks []Trunk `json:"trunks"`
}

type Fuse struct {
	Kind string `json:"kind" unpack:""`
}

type HTTP struct {
	Kind   string       `json:"kind" unpack:""`
	URL    string       `json:"url"`
	Format string       `json:"format"`
	Layout order.Layout `json:"layout"`
}

type Head struct {
	Kind  string `json:"kind" unpack:""`
	Count int    `json:"count"`
}

type Join struct {
	Kind     string       `json:"kind" unpack:""`
	Style    string       `json:"style"`
	LeftKey  Expr         `json:"left_key"`
	RightKey Expr         `json:"right_key"`
	Args     []Assignment `json:"args"`
}

type LakeMeta struct {
	Kind string `json:"kind" unpack:""`
	Meta string `json:"meta"`
}

type MapExpr struct {
	Kind    string  `json:"kind" unpack:""`
	Entries []Entry `json:"entries"`
}

type Merge struct {
	Kind  string      `json:"kind" unpack:""`
	Key   field.Path  `json:"key"`
	Order order.Which `json:"order"`
}

type Method struct {
	Name string `json:"name"`
	Args []Expr `json:"args"`
}

type Op interface {
	OpNode()
}

type Parallel struct {
	Kind string `json:"kind" unpack:""`
	Ops  []Op   `json:"ops"`
}

type Pass struct {
	Kind string `json:"kind" unpack:""`
}

type Path struct {
	Kind string   `json:"kind" unpack:""`
	Name []string `json:"name"`
}

type Pick struct {
	Kind string       `json:"kind" unpack:""`
	Args []Assignment `json:"args"`
}

type Pool struct {
	Kind      string      `json:"kind" unpack:""`
	ID        ksuid.KSUID `json:"id"`
	Commit    ksuid.KSUID `json:"commit"`
	ScanLower Expr        `json:"scan_lower"`
	ScanUpper Expr        `json:"scan_upper"`
	ScanOrder string      `json:"scan_order"`
}

type PoolMeta struct {
	Kind string      `json:"kind" unpack:""`
	ID   ksuid.KSUID `json:"id"`
	Meta string      `json:"meta"`
}

type Pushdown struct {
	Scan  Op      `json:"scan"`
	Index *Filter `json:"index"`
}

type Put struct {
	Kind string       `json:"kind" unpack:""`
	Args []Assignment `json:"args"`
}

type RecordExpr struct {
	Kind   string  `json:"kind" unpack:""`
	Fields []Field `json:"fields"`
}

type Ref struct {
	Kind string `json:"kind" unpack:""`
	Name string `json:"name"`
}

type RegexpMatch struct {
	Kind    string `json:"kind" unpack:""`
	Pattern string `json:"pattern"`
	Expr    Expr   `json:"expr"`
}

type RegexpSearch struct {
	Kind    string `json:"kind" unpack:""`
	Pattern string `json:"pattern"`
}

type Rename struct {
	Kind string       `json:"kind" unpack:""`
	Args []Assignment `json:"args"`
}

type Search struct {
	Kind  string           `json:"kind" unpack:""`
	Text  string           `json:"text"`
	Value astzed.Primitive `json:"value"` //XXX search should be extended to complex types
}

type SelectExpr struct {
	Kind      string `json:"kind" unpack:""`
	Selectors []Expr `json:"selectors"`
	Methods   []Call `json:"methods"`
}

type SeqExpr struct {
	Kind      string   `json:"kind" unpack:""`
	Name      string   `json:"name"`
	Selectors []Expr   `json:"selectors"`
	Methods   []Method `json:"methods"`
}

type Sequential struct {
	Kind string `json:"kind" unpack:""`
	Ops  []Op   `json:"ops"`
}

type SetExpr struct {
	Kind  string `json:"kind" unpack:""`
	Exprs []Expr `json:"exprs"`
}

type Shape struct {
	Kind string `json:"kind" unpack:""`
}

type Sort struct {
	Kind       string      `json:"kind" unpack:""`
	Args       []Expr      `json:"args"`
	Order      order.Which `json:"order"`
	NullsFirst bool        `json:"nullsfirst"`
}

type Source interface {
	Source()
}

type Summarize struct {
	Kind         string            `json:"kind" unpack:""`
	Duration     *astzed.Primitive `json:"duration"`
	Limit        int               `json:"limit"`
	Keys         []Assignment      `json:"keys"`
	Aggs         []Assignment      `json:"aggs"`
	InputSortDir int               `json:"input_sort_dir,omitempty"`
	PartialsIn   bool              `json:"partials_in,omitempty"`
	PartialsOut  bool              `json:"partials_out,omitempty"`
}

type Switch struct {
	Kind  string `json:"kind" unpack:""`
	Expr  Expr   `json:"expr"`
	Cases []Case `json:"cases"`
}

type Tail struct {
	Kind  string `json:"kind" unpack:""`
	Count int    `json:"count"`
}

type Top struct {
	Kind  string `json:"kind" unpack:""`
	Limit int    `json:"limit"`
	Args  []Expr `json:"args"`
	Flush bool   `json:"flush"`
}

type Trunk struct {
	Kind     string      `json:"kind" unpack:""`
	Source   Source      `json:"source"`
	Seq      *Sequential `json:"seq"`
	Pushdown Pushdown    `json:"pushdown"`
}

type TypeProc struct {
	Kind string      `json:"kind" unpack:""`
	Name string      `json:"name"`
	Type astzed.Type `json:"type"`
}

type UnaryExpr struct {
	Kind    string `json:"kind" unpack:""`
	Op      string `json:"op"`
	Operand Expr   `json:"operand"`
}

type Uniq struct {
	Kind  string `json:"kind" unpack:""`
	Cflag bool   `json:"cflag"`
}