functions

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2018 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const AbsType = "abs"

AbsType takes absolute value of each datapoint in the series

View Source
const ClampMaxType = "clamp_max"

ClampMaxType ensures all values except NaNs are lesser than or equal to provided argument

View Source
const ClampMinType = "clamp_min"

ClampMinType ensures all values except NaNs are greater than or equal to the provided argument

View Source
const CountType = "count"

CountType counts all non nan elements in a list of series

View Source
const FetchType = "fetch"

FetchType gets the series from storage

Variables

This section is empty.

Functions

This section is empty.

Types

type AbsNode added in v0.3.0

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

AbsNode is an execution node

func (*AbsNode) Meta added in v0.3.0

func (c *AbsNode) Meta(meta block.Metadata) block.Metadata

Meta returns the metadata for the block

func (*AbsNode) Process added in v0.3.0

func (c *AbsNode) Process(ID parser.NodeID, b block.Block) error

Process the block

func (*AbsNode) ProcessSeries added in v0.3.0

func (c *AbsNode) ProcessSeries(series block.Series) (block.Series, error)

ProcessSeries allows series iteration

func (*AbsNode) ProcessStep added in v0.3.0

func (c *AbsNode) ProcessStep(step block.Step) (block.Step, error)

ProcessStep allows step iteration

func (*AbsNode) SeriesMeta added in v0.3.0

func (c *AbsNode) SeriesMeta(metas []block.SeriesMeta) []block.SeriesMeta

SeriesMeta returns the metadata for each series in the block

type AbsOp added in v0.3.0

type AbsOp struct {
}

AbsOp stores required properties for abs

func (AbsOp) Node added in v0.3.0

func (o AbsOp) Node(controller *transform.Controller) transform.OpNode

Node creates an execution node

func (AbsOp) OpType added in v0.3.0

func (o AbsOp) OpType() string

OpType for the operator

func (AbsOp) String added in v0.3.0

func (o AbsOp) String() string

String representation

type ClampNode added in v0.3.0

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

ClampNode is an execution node

func (*ClampNode) Process added in v0.3.0

func (c *ClampNode) Process(ID parser.NodeID, b block.Block) error

Process the block

type ClampOp added in v0.3.0

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

ClampOp stores required properties for clamp TODO(nikunj): Make clamp a lazy function

func NewClampOp added in v0.3.0

func NewClampOp(args []interface{}, optype string) (ClampOp, error)

NewClampOp creates a new clamp op based on the type and arguments

func (ClampOp) Node added in v0.3.0

func (o ClampOp) Node(controller *transform.Controller) transform.OpNode

Node creates an execution node

func (ClampOp) OpType added in v0.3.0

func (o ClampOp) OpType() string

OpType for the operator

func (ClampOp) String added in v0.3.0

func (o ClampOp) String() string

String representation

type CountNode

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

CountNode is an execution node

func (*CountNode) Process

func (c *CountNode) Process(ID parser.NodeID, b block.Block) error

Process the block

type CountOp

type CountOp struct {
}

CountOp stores required properties for count

func (CountOp) Node

func (o CountOp) Node(controller *transform.Controller) transform.OpNode

Node creates an execution node

func (CountOp) OpType

func (o CountOp) OpType() string

OpType for the operator

func (CountOp) String

func (o CountOp) String() string

String representation

type FetchNode

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

FetchNode is the execution node

func (*FetchNode) Execute

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

Execute runs the fetch node operation

type FetchOp

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

FetchOp stores required properties for fetch

func (FetchOp) Node

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

Node creates an execution node

func (FetchOp) OpType

func (o FetchOp) OpType() string

OpType for the operator

func (FetchOp) String

func (o FetchOp) String() string

String representation

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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