runtime

type Compiler interface {
	NewQuery(*Context, ast.Seq, []zio.Reader) (Query, error)
	NewLakeQuery(*Context, ast.Seq, int, *lakeparse.Commitish) (Query, error)
	NewLakeDeleteQuery(*Context, ast.Seq, *lakeparse.Commitish) (DeleteQuery, error)
	Parse(string, ...string) (ast.Seq, error)
}

type Context struct {
	context.Context
	// WaitGroup is used to ensure that goroutines complete cleanup work
	// (e.g., removing temporary files) before Cancel returns.
	WaitGroup sync.WaitGroup
	Zctx      *zed.Context
	// contains filtered or unexported fields
}

type DeleteQuery interface {
	Query
	DeletionSet() []ksuid.KSUID
}

type Query interface {
	zbuf.Puller
	io.Closer
	Progress() zbuf.Progress
	Meter() zbuf.Meter
}