lang

Documentation

Index

• Constants
• func AddCompilerMappings(mappings flux.CompilerMappings) error
• func HaveExecutionDependencies(ctx context.Context) bool
• func IsNonNullJSON(bs json.RawMessage) bool
• type ASTCompiler
  • func (c ASTCompiler) Compile(ctx context.Context, runtime flux.Runtime) (flux.Program, error)
  • func (ASTCompiler) CompilerType() flux.CompilerType
• type AstProgram
  • 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) Start(ctx context.Context, alloc *memory.Allocator) (flux.Query, error)
• type CompileOption
  • func Verbose(v bool) CompileOption
  • func WithExtern(extern flux.ASTHandle) CompileOption
  • func WithLogPlanOpts(lopts ...plan.LogicalOption) CompileOption
  • func WithPhysPlanOpts(popts ...plan.PhysicalOption) CompileOption
• type ExecutionDependencies
  • func GetExecutionDependencies(ctx context.Context) ExecutionDependencies
  • func (d ExecutionDependencies) Inject(ctx context.Context) context.Context
• type FluxCompiler
  • func (c FluxCompiler) Compile(ctx context.Context, runtime flux.Runtime) (flux.Program, error)
  • func (c FluxCompiler) CompilerType() flux.CompilerType
• type LoggingProgram
• type Program
  • 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
  • func (c *TableObjectCompiler) Compile(ctx context.Context) (flux.Program, error)
  • func (*TableObjectCompiler) CompilerType() flux.CompilerType

Constants

const (
	FluxCompilerType = "flux"
	ASTCompilerType  = "ast"
)

Functions

func AddCompilerMappings

func AddCompilerMappings(mappings flux.CompilerMappings) error

AddCompilerMappings adds the Flux specific compiler mappings.

func HaveExecutionDependencies

func HaveExecutionDependencies(ctx context.Context) bool

func IsNonNullJSON

func IsNonNullJSON(bs json.RawMessage) bool

Types

type ASTCompiler

type ASTCompiler struct {
	Extern json.RawMessage `json:"extern,omitempty"`
	AST    json.RawMessage `json:"ast"`
	Now    time.Time
}

ASTCompiler implements Compiler by producing a Program from an AST.

func (ASTCompiler) Compile

func (c ASTCompiler) Compile(ctx context.Context, runtime flux.Runtime) (flux.Program, error)

func (ASTCompiler) CompilerType

func (ASTCompiler) CompilerType() flux.CompilerType

type AstProgram

type AstProgram struct {
	*Program

	Ast flux.ASTHandle
	Now time.Time
}

AstProgram wraps a Program with an AST that will be evaluated upon Start. As such, the PlanSpec is populated after Start and evaluation errors are returned by Start.

func Compile

func Compile(q string, runtime flux.Runtime, now time.Time, opts ...CompileOption) (*AstProgram, error)

Compile evaluates a Flux script producing a flux.Program. now parameter must be non-zero, that is the default now time should be set before compiling.

func CompileAST

func CompileAST(astPkg flux.ASTHandle, runtime flux.Runtime, now time.Time, opts ...CompileOption) *AstProgram

CompileAST evaluates a Flux handle to an AST and produces a flux.Program. now parameter must be non-zero, that is the default now time should be set before compiling.

func (*AstProgram) Start

func (p *AstProgram) Start(ctx context.Context, alloc *memory.Allocator) (flux.Query, error)

type CompileOption

type CompileOption func(*compileOptions)

CompileOption represents an option for compilation.

func Verbose

func Verbose(v bool) CompileOption

func WithExtern

func WithExtern(extern flux.ASTHandle) CompileOption

func WithLogPlanOpts

func WithLogPlanOpts(lopts ...plan.LogicalOption) CompileOption

func WithPhysPlanOpts

func WithPhysPlanOpts(popts ...plan.PhysicalOption) CompileOption

type ExecutionDependencies

type ExecutionDependencies struct {
	Allocator *memory.Allocator
	Logger    *zap.Logger
}

ExecutionDependencies represents the dependencies that a function call executed by the Interpreter needs in order to trigger the execution of a flux.Program

func GetExecutionDependencies

func GetExecutionDependencies(ctx context.Context) ExecutionDependencies

func (ExecutionDependencies) Inject

func (d ExecutionDependencies) Inject(ctx context.Context) context.Context

type FluxCompiler

type FluxCompiler struct {
	Now    time.Time
	Extern json.RawMessage `json:"extern,omitempty"`
	Query  string          `json:"query"`
}

FluxCompiler compiles a Flux script into a spec.

func (FluxCompiler) Compile

func (c FluxCompiler) Compile(ctx context.Context, runtime flux.Runtime) (flux.Program, error)

func (FluxCompiler) CompilerType

func (c FluxCompiler) CompilerType() flux.CompilerType

type LoggingProgram

type LoggingProgram interface {
	SetLogger(logger *zap.Logger)
}

type Program

type Program struct {
	Logger   *zap.Logger
	PlanSpec *plan.Spec
	Runtime  flux.Runtime
	// contains filtered or unexported fields
}

Program implements the flux.Program interface. It will execute a compiled plan using an executor.

func CompileTableObject

func CompileTableObject(ctx context.Context, to *flux.TableObject, now time.Time, opts ...CompileOption) (*Program, error)

CompileTableObject evaluates a TableObject and produces a flux.Program. now parameter must be non-zero, that is the default now time should be set before compiling.

func (*Program) SetLogger

func (p *Program) SetLogger(logger *zap.Logger)

func (*Program) Start

func (p *Program) Start(ctx context.Context, alloc *memory.Allocator) (flux.Query, error)

type TableObjectCompiler

type TableObjectCompiler struct {
	Tables *flux.TableObject
	Now    time.Time
}

TableObjectCompiler compiles a TableObject into an executable flux.Program. It is not added to CompilerMappings and it is not serializable, because it is impossible to use it outside of the context of an ongoing execution.

func (*TableObjectCompiler) Compile

func (c *TableObjectCompiler) Compile(ctx context.Context) (flux.Program, error)

func (*TableObjectCompiler) CompilerType

func (*TableObjectCompiler) CompilerType() flux.CompilerType