debug

Documentation

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