executor

Documentation

Index

• type SinkNode
  • func NewControllerWithSink(ID parser.NodeID) (*transform.Controller, *SinkNode)
  • func (s *SinkNode) Process(ID parser.NodeID, block block.Block) error

Types

type SinkNode

type SinkNode struct {
	Values [][]float64
	Meta   block.Metadata
	Metas  []block.SeriesMeta
}

SinkNode is a test node useful for comparisons

func NewControllerWithSink

func NewControllerWithSink(ID parser.NodeID) (*transform.Controller, *SinkNode)

NewControllerWithSink creates a new controller which has a sink useful for comparison in tests

func (*SinkNode) Process

func (s *SinkNode) Process(ID parser.NodeID, block block.Block) error

Process processes and stores the last block output in the sink node