Versions in this module Expand all Collapse all v0 v0.99.3 Jan 3, 2021 v0.99.2 Jan 3, 2021 Changes in this version + const ASTCompilerType + const FluxCompilerType + func AddCompilerMappings(mappings flux.CompilerMappings) error + func IsNonNullJSON(bs json.RawMessage) bool + type ASTCompiler struct + AST json.RawMessage + Extern json.RawMessage + Now time.Time + func (ASTCompiler) CompilerType() flux.CompilerType + func (c ASTCompiler) Compile(ctx context.Context, runtime flux.Runtime) (flux.Program, error) + type AstProgram struct + Ast flux.ASTHandle + Now time.Time + Profilers []execute.Profiler + func Compile(q string, runtime flux.Runtime, now time.Time, opts ...CompileOption) (*AstProgram, error) + func CompileAST(astPkg flux.ASTHandle, runtime flux.Runtime, now time.Time, ...) *AstProgram + func (p *AstProgram) GetAst() (flux.ASTHandle, error) + func (p *AstProgram) Start(ctx context.Context, alloc *memory.Allocator) (flux.Query, error) + type CompileOption func(*compileOptions) + func Verbose(v bool) CompileOption + func WithExtern(extern flux.ASTHandle) CompileOption + func WithLogPlanOpts(lopts ...plan.LogicalOption) CompileOption + func WithPhysPlanOpts(popts ...plan.PhysicalOption) CompileOption + type ExecOptsConfig struct + func (eoc *ExecOptsConfig) ConfigureNow(ctx context.Context, now time.Time) + func (eoc *ExecOptsConfig) ConfigureProfiler(ctx context.Context, profilerNames []string) + type FluxCompiler struct + Extern json.RawMessage + Now time.Time + Query string + func (c FluxCompiler) Compile(ctx context.Context, runtime flux.Runtime) (flux.Program, error) + func (c FluxCompiler) CompilerType() flux.CompilerType + type LoggingProgram interface + SetLogger func(logger *zap.Logger) + type Program struct + Logger *zap.Logger + PlanSpec *plan.Spec + Runtime flux.Runtime + func CompileTableObject(ctx context.Context, to *flux.TableObject, now time.Time, ...) (*Program, error) + func (p *Program) SetLogger(logger *zap.Logger) + func (p *Program) Start(ctx context.Context, alloc *memory.Allocator) (flux.Query, error) + type TableObjectCompiler struct + Now time.Time + Tables *flux.TableObject + func (*TableObjectCompiler) CompilerType() flux.CompilerType + func (c *TableObjectCompiler) Compile(ctx context.Context) (flux.Program, error)