temporal

Documentation

Index

• Constants
• func NewAggOp(args []interface{}, optype string) (transform.Params, error)
• func NewFunctionOp(args []interface{}, optype string) (transform.Params, error)
• func NewRateOp(args []interface{}, optype string) (transform.Params, error)
• type MakeProcessor
• type Processor

Constants

const (
	// AvgType calculates the average of all values in the specified interval
	AvgType = "avg_over_time"

	// CountType calculates count of all values in the specified interval
	CountType = "count_over_time"

	// MinType calculates the minimum of all values in the specified interval
	MinType = "min_over_time"

	// MaxType calculates the maximum of all values in the specified interval
	MaxType = "max_over_time"

	// SumType calculates the sum of all values in the specified interval
	SumType = "sum_over_time"

	// StdDevType calculates the standard deviation of all values in the specified interval
	StdDevType = "stddev_over_time"

	// StdVarType calculates the standard variance of all values in the specified interval
	StdVarType = "stdvar_over_time"
)

const (
	// ResetsType returns the number of counter resets within the provided time range as a time series.
	// Any decrease in the value between two consecutive datapoints is interpreted as a counter reset.
	// ResetsTemporalType should only be used with counters.
	ResetsType = "resets"

	// ChangesType returns the number of times a value changes within the provided time range for
	// a given time series.
	ChangesType = "changes"
)

const (
	// IRateType calculates the per-second rate of increase of the time series
	// across the specified time range. This is based on the last two data points.
	IRateType = "irate"

	// IDeltaType calculates the difference between the last two values in the time series.
	// IDeltaTemporalType should only be used with gauges.
	IDeltaType = "idelta"
)

Functions

func NewAggOp

func NewAggOp(args []interface{}, optype string) (transform.Params, error)

NewAggOp creates a new base temporal transform with a specified node

func NewFunctionOp

func NewFunctionOp(args []interface{}, optype string) (transform.Params, error)

NewFunctionOp creates a new base temporal transform for functions

func NewRateOp

func NewRateOp(args []interface{}, optype string) (transform.Params, error)

NewRateOp creates a new base temporal transform for rate functions

Types

type MakeProcessor

type MakeProcessor func(op baseOp, controller *transform.Controller, opts transform.Options) Processor

MakeProcessor is a way to create a transform

type Processor

type Processor interface {
	Process(values []float64) float64
}

Processor is implemented by the underlying transforms