debug

Documentation

Index

• Constants
• Variables
• 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 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 PassKind = "internal/debug.pass"

const SinkKind = "internal/debug.sink"

const SlurpKind = "internal/debug.slurp"

Variables

var FluxTestPackages = []*ast.Package{&ast.Package{
	BaseNode: ast.BaseNode{
		Comments: nil,
		Errors:   nil,
		Loc:      nil,
	},
	Files:   []*ast.File{},
	Package: "debug_test",
	Path:    "internal/debug",
}}

Functions

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