forked from atlassian/gostatsd
-
Notifications
You must be signed in to change notification settings - Fork 0
/
gauges.go
46 lines (38 loc) · 1.27 KB
/
gauges.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
package gostatsd
// Gauge is used for storing aggregated values for gauges.
type Gauge struct {
Value float64 // The numeric value of the metric
Timestamp Nanotime // Last time value was updated
Hostname string // Hostname of the source of the metric
Tags Tags // The tags for the gauge
}
// NewGauge initialises a new gauge.
func NewGauge(timestamp Nanotime, value float64, hostname string, tags Tags) Gauge {
return Gauge{Value: value, Timestamp: timestamp, Hostname: hostname, Tags: tags}
}
// Gauges stores a map of gauges by tags.
type Gauges map[string]map[string]Gauge
// MetricsName returns the name of the aggregated metrics collection.
func (g Gauges) MetricsName() string {
return "Gauges"
}
// Delete deletes the metrics from the collection.
func (g Gauges) Delete(k string) {
delete(g, k)
}
// DeleteChild deletes the metrics from the collection for the given tags.
func (g Gauges) DeleteChild(k, t string) {
delete(g[k], t)
}
// HasChildren returns whether there are more children nested under the key.
func (g Gauges) HasChildren(k string) bool {
return len(g[k]) != 0
}
// Each iterates over each gauge.
func (g Gauges) Each(f func(string, string, Gauge)) {
for key, value := range g {
for tags, gauge := range value {
f(key, tags, gauge)
}
}
}