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)
• 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) 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)

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) 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