Versions in this module Expand all Collapse all v1 v1.5.1 Apr 23, 2018 Changes in this version + type Aggregator struct + func NewAggregator(c RateCounter, opts ...AggregatorOption) *Aggregator + func (a *Aggregator) Rate(timestamp int64) (Rate, error) + func (a *Aggregator) Rates() Rates + func (a *Aggregator) Run() + type AggregatorOption func(a *Aggregator) + func WithMaxRateBuckets(n int) AggregatorOption + func WithPollingInterval(d time.Duration) AggregatorOption + type Counter struct + func NewCounter() *Counter + func (c *Counter) Inc(id string) + func (c *Counter) Reset() map[string]uint64 + type Rate struct + Counts map[string]uint64 + Timestamp int64 + type RateCounter interface + Reset func() map[string]uint64 + type Rates []Rate + func (r Rates) Len() int + func (r Rates) Less(i, j int) bool + func (r Rates) Swap(i, j int)