metrics

Documentation

Index

• func API_GetMetrics(w http.ResponseWriter, req *http.Request)
• func AggloAndCommitMetrics()
• func CommitAggl(metrics []DataDefDB)
• func GetSystemMetrics()
• func Init()
• func InitAggl()
• func MergeMetric(SetOperation string, currentValue int, newValue int, avgIndex int) int
• func ModuloTime(start time.Time, modulo time.Duration) time.Time
• func PushSetMetric(key string, value int, def DataDef)
• func Run()
• func SaveMetrics()
• type DataDef
• type DataDefDB
  • func AggloMetrics() []DataDefDB
• type DataDefDBEntry
• type DataPush

Functions

func API_GetMetrics

func API_GetMetrics(w http.ResponseWriter, req *http.Request)

func AggloAndCommitMetrics

func AggloAndCommitMetrics()

func CommitAggl

func CommitAggl(metrics []DataDefDB)

func GetSystemMetrics

func GetSystemMetrics()

func Init

func Init()

func InitAggl

func InitAggl()

func MergeMetric

func MergeMetric(SetOperation string, currentValue int, newValue int, avgIndex int) int

func ModuloTime

func ModuloTime(start time.Time, modulo time.Duration) time.Time

func PushSetMetric

func PushSetMetric(key string, value int, def DataDef)

func Run

func Run()

func SaveMetrics

func SaveMetrics()

Types

type DataDef

type DataDef struct {
	Max          uint64
	Period       time.Duration
	Label        string
	AggloType    string
	SetOperation string
}

type DataDefDB

type DataDefDB struct {
	Values     []DataDefDBEntry
	ValuesAggl map[string]DataDefDBEntry
	LastUpdate time.Time
	Max        uint64
	Label      string
	Key        string
	AggloType  string
}

func AggloMetrics

func AggloMetrics() []DataDefDB

type DataDefDBEntry

type DataDefDBEntry struct {
	Date      time.Time
	Value     int
	Processed bool

	// For agglomeration
	AvgIndex    int
	AggloTo     time.Time
	AggloExpire time.Time
}

type DataPush

type DataPush struct {
	Date      time.Time
	Key       string
	Value     int
	Max       uint64
	Expire    time.Time
	Label     string
	AvgIndex  int
	AggloType string
}