Documentation
¶
Index ¶
- Variables
- func AggKey(series *types.MetricData, fields []int) (string, error)
- func AggregateSeries(name string, args []*types.MetricData, absent_if_first_series_absent bool, ...) ([]*types.MetricData, error)
- func AlignStartToInterval(start, stop, bucketSize int32) int32
- func AlignToBucketSize(start, stop, bucketSize int32) (int32, int32)
- func AvgValue(f64s []float64, absent []bool) float64
- func CombineSeries(originalA, originalB *types.MetricData, name string, operator Operator) *types.MetricData
- func Contains(a []int, i int) bool
- func CurrentValue(f64s []float64, absent []bool) float64
- func ExtractMetric(s string) string
- func ForEachSeriesDo(ctx context.Context, e parser.Expr, from, until int32, ...) ([]*types.MetricData, error)
- func GCD(a, b int32) int32
- func GetBuckets(start, stop, bucketSize int32) int32
- func GetSeriesArg(ctx context.Context, arg parser.Expr, from, until int32, ...) ([]*types.MetricData, error)
- func GetSeriesArgs(ctx context.Context, e []parser.Expr, from, until int32, ...) ([]*types.MetricData, error)
- func GetSeriesArgsAndRemoveNonExisting(ctx context.Context, e parser.Expr, from, until int32, ...) ([]*types.MetricData, error)
- func GroupByNodes(nodes []int, seriesList []*types.MetricData) (map[string][]*types.MetricData, map[string]bool, error)
- func LCM(a, b int32) int32
- func MaxValue(f64s []float64, absent []bool) float64
- func MinValue(f64s []float64, absent []bool) float64
- func Normalize(args []*types.MetricData) ([]*types.MetricData, int32, int32, int32, error)
- func Percentile(data []float64, percent float64, interpolate bool) (float64, bool)
- func Poly(x float64, coeffs ...float64) float64
- func RemoveEmptySeriesFromName(args []*types.MetricData) string
- func SetEvaluator(e interfaces.Evaluator)
- func SummarizeValues(f string, values []float64) (float64, bool, error)
- func Vandermonde(absent []bool, deg int) *mat.Dense
- func VarianceValue(f64s []float64, absent []bool) float64
- type AggregateFunc
- type ByName
- type ByNameNatural
- type ByVals
- type Operator
Constants ¶
This section is empty.
Variables ¶
var Backref = regexp.MustCompile(`\\(\d+)`)
Backref is a pre-compiled expression for backref
var ErrUnknownFunction = parser.ParseError("unknown function")
Functions ¶
func AggregateSeries ¶
func AggregateSeries(name string, args []*types.MetricData, absent_if_first_series_absent bool, absent_if_any_absent bool, function AggregateFunc) ([]*types.MetricData, error)
AggregateSeries aggregates series
func AlignStartToInterval ¶
AlignStartToInterval aligns start of serie to interval
func AlignToBucketSize ¶
AlignToBucketSize aligns start and stop of serie to specified bucket (step) size
func CombineSeries ¶ added in v0.2.0
func CombineSeries(originalA, originalB *types.MetricData, name string, operator Operator) *types.MetricData
CombineSeries applied operator() on two series. If they do not have the same length, series are consolidated with a Lower Common Multiple step.
func CurrentValue ¶
CurrentValue returns last non-absent value (if any), otherwise returns NaN
func ExtractMetric ¶
ExtractMetric extracts metric out of function list
func ForEachSeriesDo ¶
func ForEachSeriesDo(ctx context.Context, e parser.Expr, from, until int32, values map[parser.MetricRequest][]*types.MetricData, function seriesFunc, getTargetData interfaces.GetTargetData) ([]*types.MetricData, error)
ForEachSeriesDo do action for each serie in list.
func GetBuckets ¶
GetBuckets returns amount buckets for timeSeries (defined with startTime, stopTime and step (bucket) size.
func GetSeriesArg ¶
func GetSeriesArg(ctx context.Context, arg parser.Expr, from, until int32, values map[parser.MetricRequest][]*types.MetricData, getTargetData interfaces.GetTargetData) ([]*types.MetricData, error)
GetSeriesArg returns argument from series.
func GetSeriesArgs ¶
func GetSeriesArgs(ctx context.Context, e []parser.Expr, from, until int32, values map[parser.MetricRequest][]*types.MetricData, getTargetData interfaces.GetTargetData) ([]*types.MetricData, error)
GetSeriesArgs returns arguments of series
func GetSeriesArgsAndRemoveNonExisting ¶
func GetSeriesArgsAndRemoveNonExisting(ctx context.Context, e parser.Expr, from, until int32, values map[parser.MetricRequest][]*types.MetricData, getTargetData interfaces.GetTargetData) ([]*types.MetricData, error)
GetSeriesArgsAndRemoveNonExisting will fetch all required arguments, but will also filter out non existing Series This is needed to be graphite-web compatible in cases when you pass non-existing Series to, for example, sumSeries
func GroupByNodes ¶ added in v0.3.0
func GroupByNodes(nodes []int, seriesList []*types.MetricData) (map[string][]*types.MetricData, map[string]bool, error)
func Normalize ¶ added in v0.2.0
func Normalize(args []*types.MetricData) ([]*types.MetricData, int32, int32, int32, error)
func Percentile ¶
Percentile returns percent-th percentile. Can interpolate if needed
func RemoveEmptySeriesFromName ¶
func RemoveEmptySeriesFromName(args []*types.MetricData) string
RemoveEmptySeriesFromName removes empty series from list of names.
func SetEvaluator ¶
func SetEvaluator(e interfaces.Evaluator)
SetEvaluator sets evaluator for all helper functions
func SummarizeValues ¶
SummarizeValues summarizes values
func Vandermonde ¶
Vandermonde creates a Vandermonde matrix
func VarianceValue ¶
VarianceValue gets variances of list of values
Types ¶
type AggregateFunc ¶
AggregateFunc type that defined aggregate function
type ByName ¶
type ByName []*types.MetricData
ByName sorts metrics by name
type ByNameNatural ¶
type ByNameNatural []*types.MetricData
ByNameNatural sorts metric naturally by name
func (ByNameNatural) Len ¶
func (s ByNameNatural) Len() int
Len returns length, required to be sortable
func (ByNameNatural) Less ¶
func (s ByNameNatural) Less(i, j int) bool
Less compares two elements with specified IDs, required to be sortable
func (ByNameNatural) Swap ¶
func (s ByNameNatural) Swap(i, j int)
Swap swaps to elements by IDs, required to be sortable
type ByVals ¶
type ByVals struct {
Vals []float64
Series []*types.MetricData
}
ByVals sorts by values Total (sortByTotal), max (sortByMaxima), min (sortByMinima) sorting For 'min', we actually store 1/v so the sorting logic is the same
Source Files