spec

Documentation

Index

• func FromEvaluation(ctx context.Context, ses []interpreter.SideEffect, now time.Time, ...) (*operation.Spec, error)
• func FromScript(ctx context.Context, runtime flux.Runtime, now time.Time, script string) (*operation.Spec, error)
• func FromTableObject(ctx context.Context, to *flux.TableObject, now time.Time) (*operation.Spec, error)

Functions

func FromEvaluation

func FromEvaluation(ctx context.Context, ses []interpreter.SideEffect, now time.Time, skipYields bool) (*operation.Spec, error)

FromEvaluation produces a flux.Spec from an array of side-effects.

The `skipYields` param can be used to adjust the spec (ie to omit the yields). This is useful for situations like table functions (tableFind, etc) where the consumer of the spec can only accept one (1) result, presumably coming from the terminal node in the plan. In keeping with the "one result" requirement, when `skipYields` is true FromEvaluation will produce an error for inputs producing > 1 result.

func FromScript

func FromScript(ctx context.Context, runtime flux.Runtime, now time.Time, script string) (*operation.Spec, error)

FromScript returns a spec from a script expressed as a raw string. This is duplicate logic for what happens when a flux.Program runs. This function is used in tests that compare flux.Specs (e.g. in planner tests).

func FromTableObject

func FromTableObject(ctx context.Context, to *flux.TableObject, now time.Time) (*operation.Spec, error)

FromTableObject returns a spec from a TableObject.