aboutsummaryrefslogtreecommitdiff
path: root/collector/sockstat_linux.go
diff options
context:
space:
mode:
authorBen Ye <yb532204897@gmail.com>2019-12-31 11:19:37 -0500
committerBen Kochie <superq@gmail.com>2019-12-31 17:19:37 +0100
commit2477c5c67dff7e7655a9d466450235e9c9eac193 (patch)
tree198cb44d48f454df765984bc614e1b1972a646e8 /collector/sockstat_linux.go
parenta80b7d0bc5ee93e704bab22e7592ed8b7d65899e (diff)
downloadprometheus_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.go15
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.
32var pageSize = os.Getpagesize() 33var pageSize = os.Getpagesize()
33 34
34type sockStatCollector struct{} 35type sockStatCollector struct {
36 logger log.Logger
37}
35 38
36func init() { 39func 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.
41func NewSockStatCollector() (Collector, error) { 44func NewSockStatCollector(logger log.Logger) (Collector, error) {
42 return &sockStatCollector{}, nil 45 return &sockStatCollector{logger}, nil
43} 46}
44 47
45func (c *sockStatCollector) Update(ch chan<- prometheus.Metric) error { 48func (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 }