aggregator

Documentation

Index

• func RegisterFactory(id string, factory Factory)
• type Aggregator
  • func NewBlockAverage(windowSize int) Aggregator
  • func NewMovingAverage(windowSize int) Aggregator
  • func NewTimeBlockAverage(windowSize int) Aggregator
• type BlockAverage
  • func (ba *BlockAverage) Add(value float64) (bool, float64)
• type Factory
  • func GetFactory(id string) Factory
• type MovingAverage
  • func (ma *MovingAverage) Add(value float64) (bool, float64)
• type TimeBlockAverage
  • func (ta *TimeBlockAverage) Add(value float64) (bool, float64)

Functions

func RegisterFactory

func RegisterFactory(id string, factory Factory)

Register registers the specified aggregator

Types

type Aggregator

type Aggregator interface {
	Add(value float64) (report bool, result float64)
}

func NewBlockAverage

func NewBlockAverage(windowSize int) Aggregator

func NewMovingAverage

func NewMovingAverage(windowSize int) Aggregator

func NewTimeBlockAverage

func NewTimeBlockAverage(windowSize int) Aggregator

type BlockAverage

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

func (*BlockAverage) Add

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

type Factory

type Factory func(windowSize int) Aggregator

func GetFactory

func GetFactory(id string) Factory

Get gets specified aggregator factory

type MovingAverage

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

func (*MovingAverage) Add

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

type TimeBlockAverage

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

func (*TimeBlockAverage) Add

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