stats

Documentation

Index

• type Stat
  • func Decimate(maxSamples int, stats []Stat) []Stat
• type Stats
  • func (s *Stats) Scan(value interface{}) error
  • func (s Stats) Value() (driver.Value, error)

Types

type Stat

type Stat struct {
	Timestamp common.DateTime   `json:"timestamp"`
	Metrics   map[string]uint64 `json:"metrics"`
}

Stat is a bucket of stats from a driver at a point in time for a certain task.

func Decimate

func Decimate(maxSamples int, stats []Stat) []Stat

Decimate will down sample to a max number of points in a given sample by averaging samples together. i.e. max=240, if we have 240 samples, return them all, if we have 480 samples, every 2 samples average them (and time distance), and return 240 samples. This is relatively naive and if len(in) > max, <= max points will be returned, not necessarily max: length(out) = ceil(length(in)/max) -- feel free to fix this, setting a relatively high max will allow good enough granularity at higher lengths, i.e. for max of 1 hour tasks, sampling every 1s, decimate will return 15s samples if max=240. Large gaps in time between samples (a factor > (last-start)/max) will result in a shorter list being returned to account for lost samples. Decimate will modify the input list for efficiency, it is not copy safe. Input must be sorted by timestamp or this will fail gloriously.

type Stats

type Stats []Stat

Stats is a list of Stat, notably implements sql.Valuer

func (*Stats) Scan

func (s *Stats) Scan(value interface{}) error

implements sql.Scanner

func (Stats) Value

func (s Stats) Value() (driver.Value, error)

implements sql.Valuer, returning a string