functions

package

v0.4.6 Latest Latest Go to latest Published: Oct 5, 2018 License: Apache-2.0 Imports: 10 Imported by: 2

Details

View Source

const FetchType = "fetch"

FetchType gets the series from storage

View Source

const ScalarType = "scalar"

ScalarType is a scalar series

This section is empty.

func NewScalarOp(val float64) parser.Params

NewScalarOp creates a new scalar op

type FetchNode struct {
	// contains filtered or unexported fields
}

FetchNode is the execution node TODO: Make FetchNode private

func (n *FetchNode) Execute(ctx context.Context) error

Execute runs the fetch node operation

type FetchOp struct {
	Name     string
	Range    time.Duration
	Offset   time.Duration
	Matchers models.Matchers
}

FetchOp stores required properties for fetch TODO: Make FetchOp private

func (o FetchOp) Bounds() transform.BoundSpec

Bounds returns the bounds for the spec

func (o FetchOp) Node(controller *transform.Controller, storage storage.Storage, options transform.Options) parser.Source

Node creates an execution node

func (o FetchOp) OpType() string

OpType for the operator

func (o FetchOp) String() string

String representation