functions

Documentation

Index

• Constants
• func NewScalarOp(val float64) parser.Params
• type CountNode
  • func (c *CountNode) Process(ID parser.NodeID, b block.Block) error
• type CountOp
  • func (o CountOp) Node(controller *transform.Controller, _ transform.Options) transform.OpNode
  • func (o CountOp) OpType() string
  • func (o CountOp) String() string
• type FetchNode
  • func (n *FetchNode) Execute(ctx context.Context) error
• type FetchOp
  • func (o FetchOp) Bounds() transform.BoundSpec
  • func (o FetchOp) Node(controller *transform.Controller, storage storage.Storage, ...) parser.Source
  • func (o FetchOp) OpType() string
  • func (o FetchOp) String() string

Constants

const CountType = "count"

CountType counts all non nan elements in a list of series

const FetchType = "fetch"

FetchType gets the series from storage

const ScalarType = "scalar"

ScalarType is a scalar series

Functions

func NewScalarOp

func NewScalarOp(val float64) parser.Params

NewScalarOp creates a new scalar op

Types

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.Options) 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 TODO: Make FetchNode private

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 TODO: Make FetchOp private

func (FetchOp) Bounds

func (o FetchOp) Bounds() transform.BoundSpec

Bounds returns the bounds for the spec

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