1 files changed, 103 insertions, 0 deletions
diff --git a/src/go/collectors/go.d.plugin/pkg/metrics/gauge.go b/src/go/collectors/go.d.plugin/pkg/metrics/gauge.go
new file mode 100644
index 000000000..6f0930f66
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/pkg/metrics/gauge.go
@@ -0,0 +1,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
+}