aggregator

Feb 1, 2018

Changes in this version

+ func RegisterFactory(id string, factory Factory)

+ type Aggregator interface

+ Add func(value float64) (report bool, result float64)

+ func NewBlockAverage(windowSize int) Aggregator

+ func NewMovingAverage(windowSize int) Aggregator

+ func NewTimeBlockAverage(windowSize int) Aggregator

+ type BlockAverage struct

+ func (ba *BlockAverage) Add(value float64) (bool, float64)

+ type Factory func(windowSize int) Aggregator

+ func GetFactory(id string) Factory

+ type MovingAverage struct

+ func (ma *MovingAverage) Add(value float64) (bool, float64)

+ type TimeBlockAverage struct

+ func (ta *TimeBlockAverage) Add(value float64) (bool, float64)