functions

Documentation

Index

• Constants
• type AbsNode
  • func (c *AbsNode) Meta(meta block.Metadata) block.Metadata
  • func (c *AbsNode) Process(ID parser.NodeID, b block.Block) error
  • func (c *AbsNode) ProcessSeries(series block.Series) (block.Series, error)
  • func (c *AbsNode) ProcessStep(step block.Step) (block.Step, error)
  • func (c *AbsNode) SeriesMeta(metas []block.SeriesMeta) []block.SeriesMeta
• type AbsOp
  • func (o AbsOp) Node(controller *transform.Controller) transform.OpNode
  • func (o AbsOp) OpType() string
  • func (o AbsOp) String() string
• type ClampNode
  • func (c *ClampNode) Process(ID parser.NodeID, b block.Block) error
• type ClampOp
  • func NewClampOp(args []interface{}, optype string) (ClampOp, error)
  • func (o ClampOp) Node(controller *transform.Controller) transform.OpNode
  • func (o ClampOp) OpType() string
  • func (o ClampOp) String() string
• type CountNode
  • func (c *CountNode) Process(ID parser.NodeID, b block.Block) error
• type CountOp
  • func (o CountOp) Node(controller *transform.Controller) 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) Node(controller *transform.Controller, storage storage.Storage, ...) parser.Source
  • func (o FetchOp) OpType() string
  • func (o FetchOp) String() string

Constants

const AbsType = "abs"

AbsType takes absolute value of each datapoint in the series

const ClampMaxType = "clamp_max"

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

const ClampMinType = "clamp_min"

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

const CountType = "count"

CountType counts all non nan elements in a list of series

const FetchType = "fetch"

FetchType gets the series from storage

Types

type AbsNode

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

AbsNode is an execution node

func (*AbsNode) Meta

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

Meta returns the metadata for the block

func (*AbsNode) Process

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

Process the block

func (*AbsNode) ProcessSeries

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

ProcessSeries allows series iteration

func (*AbsNode) ProcessStep

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

ProcessStep allows step iteration

func (*AbsNode) SeriesMeta

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

SeriesMeta returns the metadata for each series in the block

type AbsOp

type AbsOp struct {
}

AbsOp stores required properties for abs

func (AbsOp) Node

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

Node creates an execution node

func (AbsOp) OpType

func (o AbsOp) OpType() string

OpType for the operator

func (AbsOp) String

func (o AbsOp) String() string

String representation

type ClampNode

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

ClampNode is an execution node

func (*ClampNode) Process

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

Process the block

type ClampOp

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

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

func NewClampOp

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

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

func (ClampOp) Node

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

Node creates an execution node

func (ClampOp) OpType

func (o ClampOp) OpType() string

OpType for the operator

func (ClampOp) String

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