aggregation

Documentation

Index

• type TimedFloat64Buckets
  • func NewTimedFloat64Buckets(window, granularity time.Duration) *TimedFloat64Buckets
  • func (t *TimedFloat64Buckets) IsEmpty(now time.Time) bool
  • func (t *TimedFloat64Buckets) Record(now time.Time, value float64)
  • func (t *TimedFloat64Buckets) ResizeWindow(w time.Duration)
  • func (t *TimedFloat64Buckets) String() string
  • func (t *TimedFloat64Buckets) WindowAverage(now time.Time) float64

Types

type TimedFloat64Buckets

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

TimedFloat64Buckets keeps buckets that have been collected at a certain time.

func NewTimedFloat64Buckets

func NewTimedFloat64Buckets(window, granularity time.Duration) *TimedFloat64Buckets

NewTimedFloat64Buckets generates a new TimedFloat64Buckets with the given granularity.

func (*TimedFloat64Buckets) IsEmpty

func (t *TimedFloat64Buckets) IsEmpty(now time.Time) bool

IsEmpty returns if no data has been recorded for the `window` period.

func (*TimedFloat64Buckets) Record

func (t *TimedFloat64Buckets) Record(now time.Time, value float64)

Record adds a value with an associated time to the correct bucket.

func (*TimedFloat64Buckets) ResizeWindow

func (t *TimedFloat64Buckets) ResizeWindow(w time.Duration)

ResizeWindow resizes the window. This is an O(N) operation, and is not supposed to be executed very often.

func (*TimedFloat64Buckets) String

func (t *TimedFloat64Buckets) String() string

Implements stringer interface.

func (*TimedFloat64Buckets) WindowAverage

func (t *TimedFloat64Buckets) WindowAverage(now time.Time) float64

WindowAverage returns the average bucket value over the window.