executor

package
v0.14.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SinkNode

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

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(_ *models.QueryContext, ID parser.NodeID, block block.Block) error

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL