aggregation

Documentation

Index

• type Accumulator
  • func YoungerThan(oldest time.Time, acc Accumulator) Accumulator
• type Average
  • func (a *Average) Accumulate(_ time.Time, bucket float64Bucket)
  • func (a *Average) Value() float64
• type TimedFloat64Buckets
  • func NewTimedFloat64Buckets(granularity time.Duration) *TimedFloat64Buckets
  • func (t *TimedFloat64Buckets) ForEachBucket(accs ...Accumulator)
  • func (t *TimedFloat64Buckets) IsEmpty() bool
  • func (t *TimedFloat64Buckets) Record(time time.Time, name string, value float64)
  • func (t *TimedFloat64Buckets) RemoveOlderThan(time time.Time)

Types

type Accumulator

type Accumulator func(time time.Time, bucket float64Bucket)

Accumulator is a function accumulating buckets and their time..

func YoungerThan

func YoungerThan(oldest time.Time, acc Accumulator) Accumulator

YoungerThan only applies the accumulator to buckets that are younger than the given time.

type Average

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

Average is used to keep the values necessary to compute an average.

func (*Average) Accumulate

func (a *Average) Accumulate(_ time.Time, bucket float64Bucket)

Accumulate accumulates the values needed to compute an average.

func (*Average) Value

func (a *Average) Value() float64

Value returns the average or 0 if no buckets have been accumulated.

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(granularity time.Duration) *TimedFloat64Buckets

NewTimedFloat64Buckets generates a new TimedFloat64Buckets with the given granularity.

func (*TimedFloat64Buckets) ForEachBucket

func (t *TimedFloat64Buckets) ForEachBucket(accs ...Accumulator)

ForEachBucket calls the given Accumulator function for each bucket.

func (*TimedFloat64Buckets) IsEmpty

func (t *TimedFloat64Buckets) IsEmpty() bool

IsEmpty returns whether or not there are no values currently stored.

func (*TimedFloat64Buckets) Record

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

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

func (*TimedFloat64Buckets) RemoveOlderThan

func (t *TimedFloat64Buckets) RemoveOlderThan(time time.Time)

RemoveOlderThan removes buckets older than the given time from the state.