+++ /dev/null
-// Copyright 2019 The Go Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style
-// license that can be found in the LICENSE file.
-
-package metric
-
-import (
- "fmt"
- "sort"
- "time"
-
- "golang.org/x/tools/internal/event/keys"
- "golang.org/x/tools/internal/event/label"
-)
-
-// Data represents a single point in the time series of a metric.
-// This provides the common interface to all metrics no matter their data
-// format.
-// To get the actual values for the metric you must type assert to a concrete
-// metric type.
-type Data interface {
- // Handle returns the metric handle this data is for.
- //TODO: rethink the concept of metric handles
- Handle() string
- // Groups reports the rows that currently exist for this metric.
- Groups() [][]label.Label
-}
-
-// Int64Data is a concrete implementation of Data for int64 scalar metrics.
-type Int64Data struct {
- // Info holds the original construction information.
- Info *Scalar
- // IsGauge is true for metrics that track values, rather than increasing over time.
- IsGauge bool
- // Rows holds the per group values for the metric.
- Rows []int64
- // End is the last time this metric was updated.
- EndTime time.Time
-
- groups [][]label.Label
- key *keys.Int64
-}
-
-// Float64Data is a concrete implementation of Data for float64 scalar metrics.
-type Float64Data struct {
- // Info holds the original construction information.
- Info *Scalar
- // IsGauge is true for metrics that track values, rather than increasing over time.
- IsGauge bool
- // Rows holds the per group values for the metric.
- Rows []float64
- // End is the last time this metric was updated.
- EndTime time.Time
-
- groups [][]label.Label
- key *keys.Float64
-}
-
-// HistogramInt64Data is a concrete implementation of Data for int64 histogram metrics.
-type HistogramInt64Data struct {
- // Info holds the original construction information.
- Info *HistogramInt64
- // Rows holds the per group values for the metric.
- Rows []*HistogramInt64Row
- // End is the last time this metric was updated.
- EndTime time.Time
-
- groups [][]label.Label
- key *keys.Int64
-}
-
-// HistogramInt64Row holds the values for a single row of a HistogramInt64Data.
-type HistogramInt64Row struct {
- // Values is the counts per bucket.
- Values []int64
- // Count is the total count.
- Count int64
- // Sum is the sum of all the values recorded.
- Sum int64
- // Min is the smallest recorded value.
- Min int64
- // Max is the largest recorded value.
- Max int64
-}
-
-// HistogramFloat64Data is a concrete implementation of Data for float64 histogram metrics.
-type HistogramFloat64Data struct {
- // Info holds the original construction information.
- Info *HistogramFloat64
- // Rows holds the per group values for the metric.
- Rows []*HistogramFloat64Row
- // End is the last time this metric was updated.
- EndTime time.Time
-
- groups [][]label.Label
- key *keys.Float64
-}
-
-// HistogramFloat64Row holds the values for a single row of a HistogramFloat64Data.
-type HistogramFloat64Row struct {
- // Values is the counts per bucket.
- Values []int64
- // Count is the total count.
- Count int64
- // Sum is the sum of all the values recorded.
- Sum float64
- // Min is the smallest recorded value.
- Min float64
- // Max is the largest recorded value.
- Max float64
-}
-
-func labelListEqual(a, b []label.Label) bool {
- //TODO: make this more efficient
- return fmt.Sprint(a) == fmt.Sprint(b)
-}
-
-func labelListLess(a, b []label.Label) bool {
- //TODO: make this more efficient
- return fmt.Sprint(a) < fmt.Sprint(b)
-}
-
-func getGroup(lm label.Map, g *[][]label.Label, keys []label.Key) (int, bool) {
- group := make([]label.Label, len(keys))
- for i, key := range keys {
- l := lm.Find(key)
- if l.Valid() {
- group[i] = l
- }
- }
- old := *g
- index := sort.Search(len(old), func(i int) bool {
- return !labelListLess(old[i], group)
- })
- if index < len(old) && labelListEqual(group, old[index]) {
- // not a new group
- return index, false
- }
- *g = make([][]label.Label, len(old)+1)
- copy(*g, old[:index])
- copy((*g)[index+1:], old[index:])
- (*g)[index] = group
- return index, true
-}
-
-func (data *Int64Data) Handle() string { return data.Info.Name }
-func (data *Int64Data) Groups() [][]label.Label { return data.groups }
-
-func (data *Int64Data) modify(at time.Time, lm label.Map, f func(v int64) int64) Data {
- index, insert := getGroup(lm, &data.groups, data.Info.Keys)
- old := data.Rows
- if insert {
- data.Rows = make([]int64, len(old)+1)
- copy(data.Rows, old[:index])
- copy(data.Rows[index+1:], old[index:])
- } else {
- data.Rows = make([]int64, len(old))
- copy(data.Rows, old)
- }
- data.Rows[index] = f(data.Rows[index])
- data.EndTime = at
- frozen := *data
- return &frozen
-}
-
-func (data *Int64Data) count(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v int64) int64 {
- return v + 1
- })
-}
-
-func (data *Int64Data) sum(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v int64) int64 {
- return v + data.key.From(l)
- })
-}
-
-func (data *Int64Data) latest(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v int64) int64 {
- return data.key.From(l)
- })
-}
-
-func (data *Float64Data) Handle() string { return data.Info.Name }
-func (data *Float64Data) Groups() [][]label.Label { return data.groups }
-
-func (data *Float64Data) modify(at time.Time, lm label.Map, f func(v float64) float64) Data {
- index, insert := getGroup(lm, &data.groups, data.Info.Keys)
- old := data.Rows
- if insert {
- data.Rows = make([]float64, len(old)+1)
- copy(data.Rows, old[:index])
- copy(data.Rows[index+1:], old[index:])
- } else {
- data.Rows = make([]float64, len(old))
- copy(data.Rows, old)
- }
- data.Rows[index] = f(data.Rows[index])
- data.EndTime = at
- frozen := *data
- return &frozen
-}
-
-func (data *Float64Data) sum(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v float64) float64 {
- return v + data.key.From(l)
- })
-}
-
-func (data *Float64Data) latest(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v float64) float64 {
- return data.key.From(l)
- })
-}
-
-func (data *HistogramInt64Data) Handle() string { return data.Info.Name }
-func (data *HistogramInt64Data) Groups() [][]label.Label { return data.groups }
-
-func (data *HistogramInt64Data) modify(at time.Time, lm label.Map, f func(v *HistogramInt64Row)) Data {
- index, insert := getGroup(lm, &data.groups, data.Info.Keys)
- old := data.Rows
- var v HistogramInt64Row
- if insert {
- data.Rows = make([]*HistogramInt64Row, len(old)+1)
- copy(data.Rows, old[:index])
- copy(data.Rows[index+1:], old[index:])
- } else {
- data.Rows = make([]*HistogramInt64Row, len(old))
- copy(data.Rows, old)
- v = *data.Rows[index]
- }
- oldValues := v.Values
- v.Values = make([]int64, len(data.Info.Buckets))
- copy(v.Values, oldValues)
- f(&v)
- data.Rows[index] = &v
- data.EndTime = at
- frozen := *data
- return &frozen
-}
-
-func (data *HistogramInt64Data) record(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v *HistogramInt64Row) {
- value := data.key.From(l)
- v.Sum += value
- if v.Min > value || v.Count == 0 {
- v.Min = value
- }
- if v.Max < value || v.Count == 0 {
- v.Max = value
- }
- v.Count++
- for i, b := range data.Info.Buckets {
- if value <= b {
- v.Values[i]++
- }
- }
- })
-}
-
-func (data *HistogramFloat64Data) Handle() string { return data.Info.Name }
-func (data *HistogramFloat64Data) Groups() [][]label.Label { return data.groups }
-
-func (data *HistogramFloat64Data) modify(at time.Time, lm label.Map, f func(v *HistogramFloat64Row)) Data {
- index, insert := getGroup(lm, &data.groups, data.Info.Keys)
- old := data.Rows
- var v HistogramFloat64Row
- if insert {
- data.Rows = make([]*HistogramFloat64Row, len(old)+1)
- copy(data.Rows, old[:index])
- copy(data.Rows[index+1:], old[index:])
- } else {
- data.Rows = make([]*HistogramFloat64Row, len(old))
- copy(data.Rows, old)
- v = *data.Rows[index]
- }
- oldValues := v.Values
- v.Values = make([]int64, len(data.Info.Buckets))
- copy(v.Values, oldValues)
- f(&v)
- data.Rows[index] = &v
- data.EndTime = at
- frozen := *data
- return &frozen
-}
-
-func (data *HistogramFloat64Data) record(at time.Time, lm label.Map, l label.Label) Data {
- return data.modify(at, lm, func(v *HistogramFloat64Row) {
- value := data.key.From(l)
- v.Sum += value
- if v.Min > value || v.Count == 0 {
- v.Min = value
- }
- if v.Max < value || v.Count == 0 {
- v.Max = value
- }
- v.Count++
- for i, b := range data.Info.Buckets {
- if value <= b {
- v.Values[i]++
- }
- }
- })
-}
projects / dotfiles / .git / blobdiff