aggregation

package
v0.14.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 16, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL