rollup

Documentation

Index

• Variables
• 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 Aggr
  • func (ag *Aggr) Do(points []point.Point) (r float64)
  • func (ag *Aggr) Name() string
  • func (ag *Aggr) String() string
• type ClickhouseRollupXML
• type Pattern
• type PatternXML
• type Retention
• type RetentionXML
• type Rollup
  • func NewAuto(addr string, table string, interval time.Duration, defaultPrecision uint32, ...) (*Rollup, error)
  • func NewDefault(defaultPrecision uint32, defaultFunction string) (*Rollup, error)
  • func NewXMLFile(filename string, defaultPrecision uint32, defaultFunction string) (*Rollup, error)
  • func (r *Rollup) MarshalJSON() ([]byte, error)
  • func (r *Rollup) Rules() *Rules
• type Rules
  • func NewMockRules(pattern []Pattern, defaultPrecision uint32, defaultFunction string) (*Rules, error)
  • func (r *Rules) Lookup(metric string, age uint32) (precision uint32, ag *Aggr)
  • func (r *Rules) LookupBytes(metric []byte, age uint32) (precision uint32, ag *Aggr)
  • func (r *Rules) RollupMetric(metricName string, from uint32, points []point.Point) ([]point.Point, uint32, error)
  • func (r *Rules) RollupMetricAge(metricName string, age uint32, points []point.Point) ([]point.Point, uint32, error)
  • func (r *Rules) RollupPoints(pp *point.Points, from int64, step int64) error
• type RulesXML

Variables

var AggrMap = map[string]*Aggr{
	"avg":     &Aggr{"avg", AggrAvg},
	"max":     &Aggr{"max", AggrMax},
	"min":     &Aggr{"min", AggrMin},
	"sum":     &Aggr{"sum", AggrSum},
	"any":     &Aggr{"any", AggrAny},
	"anyLast": &Aggr{"anyLast", AggrAnyLast},
}

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 Aggr

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

func (*Aggr) Do

func (ag *Aggr) Do(points []point.Point) (r float64)

func (*Aggr) Name

func (ag *Aggr) Name() string

func (*Aggr) String

func (ag *Aggr) String() string

type ClickhouseRollupXML

type ClickhouseRollupXML struct {
	Rules RulesXML `xml:"graphite_rollup"`
}

type Pattern

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

type PatternXML

type PatternXML struct {
	Regexp    string          `xml:"regexp"`
	Function  string          `xml:"function"`
	Retention []*RetentionXML `xml:"retention"`
}

type Retention

type Retention struct {
	Age       uint32 `json:"age"`
	Precision uint32 `json:"precision"`
}

type RetentionXML

type RetentionXML struct {
	Age       uint32 `xml:"age"`
	Precision uint32 `xml:"precision"`
}

type Rollup

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

func NewAuto

func NewAuto(addr string, table string, interval time.Duration, defaultPrecision uint32, defaultFunction string) (*Rollup, error)

func NewDefault

func NewDefault(defaultPrecision uint32, defaultFunction string) (*Rollup, error)

func NewXMLFile

func NewXMLFile(filename string, defaultPrecision uint32, defaultFunction string) (*Rollup, error)

func (*Rollup) MarshalJSON

func (r *Rollup) MarshalJSON() ([]byte, error)

func (*Rollup) Rules

func (r *Rollup) Rules() *Rules

type Rules

type Rules struct {
	Pattern []Pattern `json:"pattern"`
	Updated int64     `json:"updated"`
}

func NewMockRules

func NewMockRules(pattern []Pattern, defaultPrecision uint32, defaultFunction string) (*Rules, error)

NewMockRulles creates mock rollup for tests

func (*Rules) Lookup

func (r *Rules) Lookup(metric string, age uint32) (precision uint32, ag *Aggr)

Lookup returns precision and aggregate function for metric name and age

func (*Rules) LookupBytes

func (r *Rules) LookupBytes(metric []byte, age uint32) (precision uint32, ag *Aggr)

LookupBytes returns precision and aggregate function for metric name and age

func (*Rules) RollupMetric

func (r *Rules) RollupMetric(metricName string, from uint32, points []point.Point) ([]point.Point, uint32, error)

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

func (*Rules) RollupMetricAge

func (r *Rules) RollupMetricAge(metricName string, age uint32, points []point.Point) ([]point.Point, uint32, error)

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

func (*Rules) RollupPoints

func (r *Rules) RollupPoints(pp *point.Points, from int64, step int64) error

RollupPoints groups sorted Points by metric name and apply rollup one by one. If the `step` parameter is 0, it will be got from the current *Rules, otherwise it will be used directly.

type RulesXML

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