stats

Documentation

Index

• type Aggregator
  • func (a *Aggregator) Add(ts time.Time, value float64) *Aggregator
  • func (a Aggregator) Average() float64
  • func (a *Aggregator) Clip(window time.Duration) *Aggregator
• type ByWindow
• type Window
  • func (w Window) MarshalText() ([]byte, error)
  • func (w *Window) UnmarshalText(b []byte) error
• type WindowAggregators
  • func (a WindowAggregators) Averages(windows []time.Duration, ts time.Time, measure *float64) ByWindow

Types

type Aggregator

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

func (*Aggregator) Add

func (a *Aggregator) Add(ts time.Time, value float64) *Aggregator

func (Aggregator) Average

func (a Aggregator) Average() float64

func (*Aggregator) Clip

func (a *Aggregator) Clip(window time.Duration) *Aggregator

type ByWindow

type ByWindow = map[Window]float64

type Window

type Window struct{ time.Duration }

func (Window) MarshalText

func (w Window) MarshalText() ([]byte, error)

func (*Window) UnmarshalText

func (w *Window) UnmarshalText(b []byte) error

type WindowAggregators

type WindowAggregators map[Window]*Aggregator

func (WindowAggregators) Averages

func (a WindowAggregators) Averages(windows []time.Duration, ts time.Time, measure *float64) ByWindow