Versions in this module Expand all Collapse all v1 v1.0.0 Nov 13, 2018 Changes in this version + type Clock interface + Time func() time.Time + type Float float64 + func (f *Float) Add(other Observable) + func (f *Float) Clear() + func (f *Float) CopyFrom(other Observable) + func (f *Float) Multiply(ratio float64) + func (f *Float) String() string + func (f *Float) Value() float64 + type MinuteHourSeries struct + func NewMinuteHourSeries(f func() Observable) *MinuteHourSeries + func NewMinuteHourSeriesWithClock(f func() Observable, clock Clock) *MinuteHourSeries + func (ts *MinuteHourSeries) Add(observation Observable) + func (ts *MinuteHourSeries) AddWithTime(observation Observable, t time.Time) + func (ts *MinuteHourSeries) Clear() + func (ts *MinuteHourSeries) ComputeRange(start, finish time.Time, num int) []Observable + func (ts *MinuteHourSeries) Hour() Observable + func (ts *MinuteHourSeries) Latest(level, num int) Observable + func (ts *MinuteHourSeries) LatestBuckets(level, num int) []Observable + func (ts *MinuteHourSeries) Minute() Observable + func (ts *MinuteHourSeries) Range(start, finish time.Time) Observable + func (ts *MinuteHourSeries) Recent(delta time.Duration) Observable + func (ts *MinuteHourSeries) RecentList(delta time.Duration, num int) []Observable + func (ts *MinuteHourSeries) ScaleBy(factor float64) + func (ts *MinuteHourSeries) Total() Observable + type Observable interface + Add func(other Observable) + Clear func() + CopyFrom func(other Observable) + Multiply func(ratio float64) + func NewFloat() Observable + type TimeSeries struct + func NewTimeSeries(f func() Observable) *TimeSeries + func NewTimeSeriesWithClock(f func() Observable, clock Clock) *TimeSeries + func (ts *TimeSeries) Add(observation Observable) + func (ts *TimeSeries) AddWithTime(observation Observable, t time.Time) + func (ts *TimeSeries) Clear() + func (ts *TimeSeries) ComputeRange(start, finish time.Time, num int) []Observable + func (ts *TimeSeries) Latest(level, num int) Observable + func (ts *TimeSeries) LatestBuckets(level, num int) []Observable + func (ts *TimeSeries) Range(start, finish time.Time) Observable + func (ts *TimeSeries) Recent(delta time.Duration) Observable + func (ts *TimeSeries) RecentList(delta time.Duration, num int) []Observable + func (ts *TimeSeries) ScaleBy(factor float64) + func (ts *TimeSeries) Total() Observable