timeaverage

Call a function which returns a float every X duration and keep history of N values and return average value of that window.

Install

go get -u github.com/raspi/timeaverage

Example

Take measurement every 500 ms and keep history of 10 seconds.

package main

import (
	"github.com/raspi/timeaverage"
    "log"
	"time"
)

func exampleSampler() (float64, error) {
	return 1, nil
}

func main() {
	avg := timeaverage.New(time.Second*10, time.Millisecond*500, 0.0, exampleSampler)
	avg.Start()

	for {
		v := avg.Average()
		log.Printf(`%f`, v)
		time.Sleep(time.Second * 1)
	}

}

See _examples directory for more examples.