diff options
author | Ben Ye <yb532204897@gmail.com> | 2019-12-31 11:19:37 -0500 |
---|---|---|
committer | Ben Kochie <superq@gmail.com> | 2019-12-31 17:19:37 +0100 |
commit | 2477c5c67dff7e7655a9d466450235e9c9eac193 (patch) | |
tree | 198cb44d48f454df765984bc614e1b1972a646e8 /collector/meminfo.go | |
parent | a80b7d0bc5ee93e704bab22e7592ed8b7d65899e (diff) | |
download | prometheus_node_collector-2477c5c67dff7e7655a9d466450235e9c9eac193.tar.bz2 prometheus_node_collector-2477c5c67dff7e7655a9d466450235e9c9eac193.tar.xz prometheus_node_collector-2477c5c67dff7e7655a9d466450235e9c9eac193.zip |
switch to go-kit/log (#1575)
Signed-off-by: yeya24 <yb532204897@gmail.com>
Diffstat (limited to 'collector/meminfo.go')
-rw-r--r-- | collector/meminfo.go | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/collector/meminfo.go b/collector/meminfo.go index 1652b8b..d3d3b8d 100644 --- a/collector/meminfo.go +++ b/collector/meminfo.go | |||
@@ -20,23 +20,26 @@ import ( | |||
20 | "fmt" | 20 | "fmt" |
21 | "strings" | 21 | "strings" |
22 | 22 | ||
23 | "github.com/go-kit/kit/log" | ||
24 | "github.com/go-kit/kit/log/level" | ||
23 | "github.com/prometheus/client_golang/prometheus" | 25 | "github.com/prometheus/client_golang/prometheus" |
24 | "github.com/prometheus/common/log" | ||
25 | ) | 26 | ) |
26 | 27 | ||
27 | const ( | 28 | const ( |
28 | memInfoSubsystem = "memory" | 29 | memInfoSubsystem = "memory" |
29 | ) | 30 | ) |
30 | 31 | ||
31 | type meminfoCollector struct{} | 32 | type meminfoCollector struct { |
33 | logger log.Logger | ||
34 | } | ||
32 | 35 | ||
33 | func init() { | 36 | func init() { |
34 | registerCollector("meminfo", defaultEnabled, NewMeminfoCollector) | 37 | registerCollector("meminfo", defaultEnabled, NewMeminfoCollector) |
35 | } | 38 | } |
36 | 39 | ||
37 | // NewMeminfoCollector returns a new Collector exposing memory stats. | 40 | // NewMeminfoCollector returns a new Collector exposing memory stats. |
38 | func NewMeminfoCollector() (Collector, error) { | 41 | func NewMeminfoCollector(logger log.Logger) (Collector, error) { |
39 | return &meminfoCollector{}, nil | 42 | return &meminfoCollector{logger}, nil |
40 | } | 43 | } |
41 | 44 | ||
42 | // Update calls (*meminfoCollector).getMemInfo to get the platform specific | 45 | // Update calls (*meminfoCollector).getMemInfo to get the platform specific |
@@ -47,7 +50,7 @@ func (c *meminfoCollector) Update(ch chan<- prometheus.Metric) error { | |||
47 | if err != nil { | 50 | if err != nil { |
48 | return fmt.Errorf("couldn't get meminfo: %s", err) | 51 | return fmt.Errorf("couldn't get meminfo: %s", err) |
49 | } | 52 | } |
50 | log.Debugf("Set node_mem: %#v", memInfo) | 53 | level.Debug(c.logger).Log("msg", "Set node_mem", "memInfo", memInfo) |
51 | for k, v := range memInfo { | 54 | for k, v := range memInfo { |
52 | if strings.HasSuffix(k, "_total") { | 55 | if strings.HasSuffix(k, "_total") { |
53 | metricType = prometheus.CounterValue | 56 | metricType = prometheus.CounterValue |