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/sockstat_linux.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/sockstat_linux.go')
-rw-r--r-- | collector/sockstat_linux.go | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/collector/sockstat_linux.go b/collector/sockstat_linux.go index fceb0ed..c7596c9 100644 --- a/collector/sockstat_linux.go +++ b/collector/sockstat_linux.go | |||
@@ -19,8 +19,9 @@ import ( | |||
19 | "fmt" | 19 | "fmt" |
20 | "os" | 20 | "os" |
21 | 21 | ||
22 | "github.com/go-kit/kit/log" | ||
23 | "github.com/go-kit/kit/log/level" | ||
22 | "github.com/prometheus/client_golang/prometheus" | 24 | "github.com/prometheus/client_golang/prometheus" |
23 | "github.com/prometheus/common/log" | ||
24 | "github.com/prometheus/procfs" | 25 | "github.com/prometheus/procfs" |
25 | ) | 26 | ) |
26 | 27 | ||
@@ -31,15 +32,17 @@ const ( | |||
31 | // Used for calculating the total memory bytes on TCP and UDP. | 32 | // Used for calculating the total memory bytes on TCP and UDP. |
32 | var pageSize = os.Getpagesize() | 33 | var pageSize = os.Getpagesize() |
33 | 34 | ||
34 | type sockStatCollector struct{} | 35 | type sockStatCollector struct { |
36 | logger log.Logger | ||
37 | } | ||
35 | 38 | ||
36 | func init() { | 39 | func init() { |
37 | registerCollector(sockStatSubsystem, defaultEnabled, NewSockStatCollector) | 40 | registerCollector(sockStatSubsystem, defaultEnabled, NewSockStatCollector) |
38 | } | 41 | } |
39 | 42 | ||
40 | // NewSockStatCollector returns a new Collector exposing socket stats. | 43 | // NewSockStatCollector returns a new Collector exposing socket stats. |
41 | func NewSockStatCollector() (Collector, error) { | 44 | func NewSockStatCollector(logger log.Logger) (Collector, error) { |
42 | return &sockStatCollector{}, nil | 45 | return &sockStatCollector{logger}, nil |
43 | } | 46 | } |
44 | 47 | ||
45 | func (c *sockStatCollector) Update(ch chan<- prometheus.Metric) error { | 48 | func (c *sockStatCollector) Update(ch chan<- prometheus.Metric) error { |
@@ -53,7 +56,7 @@ func (c *sockStatCollector) Update(ch chan<- prometheus.Metric) error { | |||
53 | switch { | 56 | switch { |
54 | case err == nil: | 57 | case err == nil: |
55 | case os.IsNotExist(err): | 58 | case os.IsNotExist(err): |
56 | log.Debug("IPv4 sockstat statistics not found, skipping") | 59 | level.Debug(c.logger).Log("msg", "IPv4 sockstat statistics not found, skipping") |
57 | default: | 60 | default: |
58 | return fmt.Errorf("failed to get IPv4 sockstat data: %w", err) | 61 | return fmt.Errorf("failed to get IPv4 sockstat data: %w", err) |
59 | } | 62 | } |
@@ -62,7 +65,7 @@ func (c *sockStatCollector) Update(ch chan<- prometheus.Metric) error { | |||
62 | switch { | 65 | switch { |
63 | case err == nil: | 66 | case err == nil: |
64 | case os.IsNotExist(err): | 67 | case os.IsNotExist(err): |
65 | log.Debug("IPv6 sockstat statistics not found, skipping") | 68 | level.Debug(c.logger).Log("msg", "IPv6 sockstat statistics not found, skipping") |
66 | default: | 69 | default: |
67 | return fmt.Errorf("failed to get IPv6 sockstat data: %w", err) | 70 | return fmt.Errorf("failed to get IPv6 sockstat data: %w", err) |
68 | } | 71 | } |