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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
// SPDX-License-Identifier: GPL-3.0-or-later
package metrics
import (
"time"
"github.com/netdata/netdata/go/go.d.plugin/pkg/stm"
)
type (
// Gauge is a Metric that represents a single numerical value that can
// arbitrarily go up and down.
//
// A Gauge is typically used for measured values like temperatures or current
// memory usage, but also "counts" that can go up and down, like the number of
// running goroutines.
Gauge float64
// GaugeVec is a Collector that bundles a set of Gauges which have different values for their names.
// This is used if you want to count the same thing partitioned by various dimensions
//
// Create instances with NewGaugeVec.
GaugeVec map[string]*Gauge
)
var (
_ stm.Value = Gauge(0)
_ stm.Value = GaugeVec{}
)
// WriteTo writes its value into given map.
func (g Gauge) WriteTo(rv map[string]int64, key string, mul, div int) {
rv[key] = int64(float64(g) * float64(mul) / float64(div))
}
// Value gets current counter.
func (g Gauge) Value() float64 {
return float64(g)
}
// Set sets the atomicGauge to an arbitrary bits.
func (g *Gauge) Set(v float64) {
*g = Gauge(v)
}
// Inc increments the atomicGauge by 1. Use Add to increment it by arbitrary
// values.
func (g *Gauge) Inc() {
*g++
}
// Dec decrements the atomicGauge by 1. Use Sub to decrement it by arbitrary
// values.
func (g *Gauge) Dec() {
*g--
}
// Add adds the given bits to the atomicGauge. (The bits can be negative,
// resulting in a decrease of the atomicGauge.)
func (g *Gauge) Add(delta float64) {
*g += Gauge(delta)
}
// Sub subtracts the given bits from the atomicGauge. (The bits can be
// negative, resulting in an increase of the atomicGauge.)
func (g *Gauge) Sub(delta float64) {
*g -= Gauge(delta)
}
// SetToCurrentTime sets the atomicGauge to the current Unix time in second.
func (g *Gauge) SetToCurrentTime() {
*g = Gauge(time.Now().UnixNano()) / 1e9
}
// NewGaugeVec creates a new GaugeVec
func NewGaugeVec() GaugeVec {
return GaugeVec{}
}
// WriteTo writes its value into given map.
func (g GaugeVec) WriteTo(rv map[string]int64, key string, mul, div int) {
for name, value := range g {
rv[key+"_"+name] = int64(value.Value() * float64(mul) / float64(div))
}
}
// Get gets counter instance by name
func (g GaugeVec) Get(name string) *Gauge {
item, _ := g.GetP(name)
return item
}
// GetP gets counter instance by name
func (g GaugeVec) GetP(name string) (gauge *Gauge, ok bool) {
gauge, ok = g[name]
if ok {
return
}
gauge = new(Gauge)
g[name] = gauge
return
}
|
