rollup

Documentation

Index

• func AggrAny(points []point.Point) (r float64)
• func AggrAnyLast(points []point.Point) (r float64)
• func AggrAvg(points []point.Point) (r float64)
• func AggrMax(points []point.Point) (r float64)
• func AggrMin(points []point.Point) (r float64)
• func AggrSum(points []point.Point) (r float64)
• type Pattern
• type Retention
• type Rollup
  • func ParseXML(body []byte) (*Rollup, error)
  • func (r *Rollup) Match(metric string) *Pattern
  • func (r *Rollup) RollupMetric(points []point.Point) ([]point.Point, int32)
  • func (r *Rollup) Step(metric string, from int32) int32

Functions

func AggrAny

func AggrAny(points []point.Point) (r float64)

func AggrAnyLast

func AggrAnyLast(points []point.Point) (r float64)

func AggrAvg

func AggrAvg(points []point.Point) (r float64)

func AggrMax

func AggrMax(points []point.Point) (r float64)

func AggrMin

func AggrMin(points []point.Point) (r float64)

func AggrSum

func AggrSum(points []point.Point) (r float64)

Types

type Pattern

type Pattern struct {
	Regexp    string       `xml:"regexp"`
	Function  string       `xml:"function"`
	Retention []*Retention `xml:"retention"`
	// contains filtered or unexported fields
}

type Retention

type Retention struct {
	Age       int32 `xml:"age"`
	Precision int32 `xml:"precision"`
}

type Rollup

type Rollup struct {
	Pattern []*Pattern `xml:"pattern"`
	Default *Pattern   `xml:"default"`
}

func ParseXML

func ParseXML(body []byte) (*Rollup, error)

func (*Rollup) Match

func (r *Rollup) Match(metric string) *Pattern

Match returns rollup rules for metric

func (*Rollup) RollupMetric

func (r *Rollup) RollupMetric(points []point.Point) ([]point.Point, int32)

RollupMetric rolling up list of points of ONE metric sorted by key "time" returns (new points slice, precision)

func (*Rollup) Step

func (r *Rollup) Step(metric string, from int32) int32