aggregator

Sep 18, 2019

Changes in this version

type Aggregator

+ Key string

+ type Count struct

+ func (c *Count) Add(val float64, ts uint32)

+ func (c *Count) Flush() ([]processorResult, bool)

type Processor

+ func NewCount(val float64, ts uint32) Processor

+ type TsSlice []uint

+ func (p TsSlice) Len() int

+ func (p TsSlice) Less(i, j int) bool

+ func (p TsSlice) Swap(i, j int)

Nov 9, 2018

Changes in this version

+ func InitMetrics()

type Aggregator

+ DropRaw bool

+ type Percentiles struct

+ func (p *Percentiles) Add(val float64, ts uint32)

+ func (p *Percentiles) Flush() ([]processorResult, bool)

type Processor

+ func NewPercentiles(val float64, ts uint32) Processor

+ type RangeTracker struct

+ func NewRangeTracker() *RangeTracker

+ func (m *RangeTracker) Run()

+ func (m *RangeTracker) Sample(ts uint32)

Dec 15, 2017

Changes in this version

type Aggregator

+ Prefix string

+ Sub string

Oct 19, 2017

Changes in this version

+ func GetProcessorConstructor(fun string) (func(val float64, ts uint32) Processor, error)

type Aggregator

+ Cache bool

+ func NewMocked(fun, regex, outFmt string, cache bool, interval, wait uint, out chan []byte, ...) (*Aggregator, error)

+ func (a *Aggregator) AddMaybe(buf [][]byte, val float64, ts uint32)

type Avg

+ func (a *Avg) Add(val float64, ts uint32)

+ func (a *Avg) Flush() (float64, bool)

+ type CacheEntry struct

type Delta

+ func (d *Delta) Add(val float64, ts uint32)

+ func (d *Delta) Flush() (float64, bool)

+ type Derive struct

+ func (d *Derive) Add(val float64, ts uint32)

+ func (d *Derive) Flush() (float64, bool)

type Last

+ func (l *Last) Add(val float64, ts uint32)

+ func (l *Last) Flush() (float64, bool)

type Max

+ func (m *Max) Add(val float64, ts uint32)

+ func (m *Max) Flush() (float64, bool)

type Min

+ func (m *Min) Add(val float64, ts uint32)

+ func (m *Min) Flush() (float64, bool)

+ type Processor interface

+ Add func(val float64, ts uint32)

+ Flush func() (float64, bool)

+ func NewAvg(val float64, ts uint32) Processor

+ func NewDelta(val float64, ts uint32) Processor

+ func NewDerive(val float64, ts uint32) Processor

+ func NewLast(val float64, ts uint32) Processor

+ func NewMax(val float64, ts uint32) Processor

+ func NewMin(val float64, ts uint32) Processor

+ func NewStdev(val float64, ts uint32) Processor

+ func NewSum(val float64, ts uint32) Processor

type Stdev

+ func (s *Stdev) Add(val float64, ts uint32)

+ func (s *Stdev) Flush() (float64, bool)

type Sum

+ func (s *Sum) Add(val float64, ts uint32)

+ func (s *Sum) Flush() (float64, bool)

Jun 26, 2017

Changes in this version

+ func Delta(in []float64) float64

+ func Last(in []float64) float64

+ func Stdev(in []float64) float64

Feb 16, 2017

Changes in this version

+ var Funcs = map[string]Func

+ func Avg(in []float64) float64

+ func Max(in []float64) float64

+ func Min(in []float64) float64

+ func SetLogger(l *logging.Logger)

+ func Sum(in []float64) float64

+ type Aggregator struct

+ Fun string

+ In chan [][]byte

+ Interval uint

+ OutFmt string

+ Regex string

+ Wait uint

+ func New(fun, regex, outFmt string, interval, wait uint, out chan []byte) (*Aggregator, error)

+ func (a *Aggregator) AddOrCreate(key string, ts uint, value float64)

+ func (a *Aggregator) Flush(ts uint)

+ func (agg *Aggregator) PreMatch(buf []byte) bool

+ func (agg *Aggregator) Shutdown()

+ func (agg *Aggregator) Snapshot() *Aggregator

+ type Func func(in []float64) float64