aggregation

Documentation

Index

• Constants
• func NewAggregationOp(opType string, params NodeParams) (parser.Params, error)
• func NewCountValuesOp(opType string, params NodeParams) (parser.Params, error)
• func NewTakeOp(opType string, params NodeParams) (parser.Params, error)
• type NodeParams

Constants

const (
	// SumType adds all non nan elements in a list of series
	SumType = "sum"
	// MinType takes the minimum all non nan elements in a list of series
	MinType = "min"
	// MaxType takes the maximum all non nan elements in a list of series
	MaxType = "max"
	// AverageType averages all non nan elements in a list of series
	AverageType = "avg"
	// StandardDeviationType takes the population standard deviation of all non
	// nan elements in a list of series
	StandardDeviationType = "stddev"
	// StandardVarianceType takes the population standard variance of all non
	// nan elements in a list of series
	StandardVarianceType = "var"
	// CountType counts all non nan elements in a list of series
	CountType = "count"
)

const (
	// BottomKType gathers the smallest k non nan elements in a list of series
	BottomKType = "bottomk"
	// TopKType gathers the largest k non nan elements in a list of series
	TopKType = "topk"
)

const (
	// CountValuesType counts the number of non nan elements with the same value
	CountValuesType = "count_values"
)

const (
	// QuantileType takes the n-th non nan quantile element in a list of series
	// Special cases are:
	// 	 n < 0 = -Inf
	// 	 n > 1 = +Inf
	QuantileType = "quantile"
)

Functions

func NewAggregationOp

func NewAggregationOp(
	opType string,
	params NodeParams,
) (parser.Params, error)

NewAggregationOp creates a new aggregation operation

func NewCountValuesOp

func NewCountValuesOp(
	opType string,
	params NodeParams,
) (parser.Params, error)

NewCountValuesOp creates a new count values operation

func NewTakeOp

func NewTakeOp(
	opType string,
	params NodeParams,
) (parser.Params, error)

NewTakeOp creates a new takeK operation

Types

type NodeParams

type NodeParams struct {
	// MatchingTags is the set of tags by which the aggregation groups output series
	MatchingTags [][]byte
	// Without indicates if series should use only the MatchingTags or if MatchingTags
	// should be excluded from grouping
	Without bool
	// Parameter is the param value for the aggregation op when appropriate
	Parameter float64
	// StringParameter is the string representation of the param value
	StringParameter string
}

NodeParams contains additional parameters required for aggregation ops