-
Notifications
You must be signed in to change notification settings - Fork 1.6k
/
integer.go
50 lines (40 loc) · 876 Bytes
/
integer.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
47
48
49
50
package plugin
import (
"sync/atomic"
"configcenter/src/common/metric"
)
//integer
func NewIntegerCounter(name, help string) *IntegerCounter {
return &IntegerCounter{
name: name,
help: help,
value: 0,
}
}
//IntegerCounter counter for integer
type IntegerCounter struct {
name string
help string
value int64
}
func (c *IntegerCounter) GetMeta() metric.MetricMeta {
return metric.MetricMeta{
Name: c.name,
Help: c.help,
}
}
func (c *IntegerCounter) GetValue() (*metric.FloatOrString, error) {
return metric.FormFloatOrString(c.value)
}
func (c *IntegerCounter) GetExtension() (*metric.MetricExtension, error) {
return nil, nil
}
func (c *IntegerCounter) Reset() {
atomic.StoreInt64(&c.value, 0)
}
func (c *IntegerCounter) Inc(i int64) {
atomic.AddInt64(&c.value, i)
}
func (c *IntegerCounter) Dec(i int64) {
atomic.AddInt64(&c.value, -i)
}