package debug

import "github.com/influxdata/flux/stdlib/internal/debug"

Index ¶

• Constants
• func Feature(ctx context.Context, args interpreter.Arguments) (values.Value, error)
• func NewPassTransformation(id execute.DatasetID, spec *PassProcedureSpec) (execute.Transformation, execute.Dataset)
• func NewSinkTransformation(id execute.DatasetID, spec *SinkProcedureSpec) (execute.Transformation, execute.Dataset)
• func NewSlurpTransformation(id execute.DatasetID, spec *SlurpProcedureSpec, a execute.Administration) (execute.Transformation, execute.Dataset)
• func Null(ctx context.Context, args interpreter.Arguments) (values.Value, error)
• type OpaqueOpSpec
• func (s *OpaqueOpSpec) Kind() flux.OperationKind
• type PassOpSpec
• func (s *PassOpSpec) Kind() flux.OperationKind
• type PassProcedureSpec
• func (s *PassProcedureSpec) Copy() plan.ProcedureSpec
• func (s *PassProcedureSpec) Kind() plan.ProcedureKind
• func (s *PassProcedureSpec) PassThroughAttribute(attrKey string) bool
• func (s *PassProcedureSpec) TriggerSpec() plan.TriggerSpec
• type SinkOpSpec
• func (s *SinkOpSpec) Kind() flux.OperationKind
• type SinkProcedureSpec
• func (s *SinkProcedureSpec) Copy() plan.ProcedureSpec
• func (s *SinkProcedureSpec) Kind() plan.ProcedureKind
• func (s *SinkProcedureSpec) TriggerSpec() plan.TriggerSpec
• type SlurpOpSpec
• func (s *SlurpOpSpec) Kind() flux.OperationKind
• type SlurpProcedureSpec
• func (s *SlurpProcedureSpec) Copy() plan.ProcedureSpec
• func (s *SlurpProcedureSpec) Kind() plan.ProcedureKind
• func (s *SlurpProcedureSpec) TriggerSpec() plan.TriggerSpec

Constants ¶

const OpaqueKind = "internal/debug.opaque"

const PassKind = "internal/debug.pass"

const SinkKind = "internal/debug.sink"

const SlurpKind = "internal/debug.slurp"

Functions ¶

func Feature ¶

func Feature(ctx context.Context, args interpreter.Arguments) (values.Value, error)

func NewPassTransformation ¶

func NewPassTransformation(id execute.DatasetID, spec *PassProcedureSpec) (execute.Transformation, execute.Dataset)

func NewSinkTransformation ¶

func NewSinkTransformation(id execute.DatasetID, spec *SinkProcedureSpec) (execute.Transformation, execute.Dataset)

func NewSlurpTransformation ¶

func NewSlurpTransformation(id execute.DatasetID, spec *SlurpProcedureSpec, a execute.Administration) (execute.Transformation, execute.Dataset)

func Null ¶

func Null(ctx context.Context, args interpreter.Arguments) (values.Value, error)

Types ¶

type OpaqueOpSpec ¶

type OpaqueOpSpec struct{}

func (*OpaqueOpSpec) Kind ¶

func (s *OpaqueOpSpec) Kind() flux.OperationKind

type PassOpSpec ¶

type PassOpSpec struct{}

func (*PassOpSpec) Kind ¶

func (s *PassOpSpec) Kind() flux.OperationKind

type PassProcedureSpec ¶

type PassProcedureSpec struct {
	plan.DefaultCost
}

func (*PassProcedureSpec) Copy ¶

func (s *PassProcedureSpec) Copy() plan.ProcedureSpec

func (*PassProcedureSpec) Kind ¶

func (s *PassProcedureSpec) Kind() plan.ProcedureKind

func (*PassProcedureSpec) PassThroughAttribute ¶

func (s *PassProcedureSpec) PassThroughAttribute(attrKey string) bool

PassThroughAttribute implements the PassThroughAttributer interface used by the planner. This implementation says that any attributes provided by input to this transformation are also propagated to its output.

func (*PassProcedureSpec) TriggerSpec ¶

func (s *PassProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type SinkOpSpec ¶

type SinkOpSpec struct{}

func (*SinkOpSpec) Kind ¶

func (s *SinkOpSpec) Kind() flux.OperationKind

type SinkProcedureSpec ¶

type SinkProcedureSpec struct {
	plan.DefaultCost
}

func (*SinkProcedureSpec) Copy ¶

func (s *SinkProcedureSpec) Copy() plan.ProcedureSpec

func (*SinkProcedureSpec) Kind ¶

func (s *SinkProcedureSpec) Kind() plan.ProcedureKind

func (*SinkProcedureSpec) TriggerSpec ¶

func (s *SinkProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

type SlurpOpSpec ¶

type SlurpOpSpec struct{}

func (*SlurpOpSpec) Kind ¶

func (s *SlurpOpSpec) Kind() flux.OperationKind

type SlurpProcedureSpec ¶

type SlurpProcedureSpec struct {
	plan.DefaultCost
}

func (*SlurpProcedureSpec) Copy ¶

func (s *SlurpProcedureSpec) Copy() plan.ProcedureSpec

func (*SlurpProcedureSpec) Kind ¶

func (s *SlurpProcedureSpec) Kind() plan.ProcedureKind

func (*SlurpProcedureSpec) TriggerSpec ¶

func (s *SlurpProcedureSpec) TriggerSpec() plan.TriggerSpec

TriggerSpec implements plan.TriggerAwareProcedureSpec

Source Files ¶

feature.go get_option.go null.go opaque.go pass.go sink.go slurp.go