diff options
Diffstat (limited to 'collector/udp_queues_linux.go')
-rw-r--r-- | collector/udp_queues_linux.go | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/collector/udp_queues_linux.go b/collector/udp_queues_linux.go index 512c010..e1b347e 100644 --- a/collector/udp_queues_linux.go +++ b/collector/udp_queues_linux.go | |||
@@ -16,6 +16,7 @@ | |||
16 | package collector | 16 | package collector |
17 | 17 | ||
18 | import ( | 18 | import ( |
19 | "errors" | ||
19 | "fmt" | 20 | "fmt" |
20 | "os" | 21 | "os" |
21 | 22 | ||
@@ -41,7 +42,7 @@ func init() { | |||
41 | func NewUDPqueuesCollector(logger log.Logger) (Collector, error) { | 42 | func NewUDPqueuesCollector(logger log.Logger) (Collector, error) { |
42 | fs, err := procfs.NewFS(*procPath) | 43 | fs, err := procfs.NewFS(*procPath) |
43 | if err != nil { | 44 | if err != nil { |
44 | return nil, fmt.Errorf("failed to open procfs: %v", err) | 45 | return nil, fmt.Errorf("failed to open procfs: %w", err) |
45 | } | 46 | } |
46 | return &udpQueuesCollector{ | 47 | return &udpQueuesCollector{ |
47 | fs: fs, | 48 | fs: fs, |
@@ -61,10 +62,10 @@ func (c *udpQueuesCollector) Update(ch chan<- prometheus.Metric) error { | |||
61 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s4.TxQueueLength), "tx", "v4") | 62 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s4.TxQueueLength), "tx", "v4") |
62 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s4.RxQueueLength), "rx", "v4") | 63 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s4.RxQueueLength), "rx", "v4") |
63 | } else { | 64 | } else { |
64 | if os.IsNotExist(errIPv4) { | 65 | if errors.Is(errIPv4, os.ErrNotExist) { |
65 | level.Debug(c.logger).Log("msg", "not collecting ipv4 based metrics") | 66 | level.Debug(c.logger).Log("msg", "not collecting ipv4 based metrics") |
66 | } else { | 67 | } else { |
67 | return fmt.Errorf("couldn't get upd queued bytes: %s", errIPv4) | 68 | return fmt.Errorf("couldn't get upd queued bytes: %w", errIPv4) |
68 | } | 69 | } |
69 | } | 70 | } |
70 | 71 | ||
@@ -73,14 +74,14 @@ func (c *udpQueuesCollector) Update(ch chan<- prometheus.Metric) error { | |||
73 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s6.TxQueueLength), "tx", "v6") | 74 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s6.TxQueueLength), "tx", "v6") |
74 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s6.RxQueueLength), "rx", "v6") | 75 | ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(s6.RxQueueLength), "rx", "v6") |
75 | } else { | 76 | } else { |
76 | if os.IsNotExist(errIPv6) { | 77 | if errors.Is(errIPv6, os.ErrNotExist) { |
77 | level.Debug(c.logger).Log("msg", "not collecting ipv6 based metrics") | 78 | level.Debug(c.logger).Log("msg", "not collecting ipv6 based metrics") |
78 | } else { | 79 | } else { |
79 | return fmt.Errorf("couldn't get upd6 queued bytes: %s", errIPv6) | 80 | return fmt.Errorf("couldn't get upd6 queued bytes: %w", errIPv6) |
80 | } | 81 | } |
81 | } | 82 | } |
82 | 83 | ||
83 | if os.IsNotExist(errIPv4) && os.IsNotExist(errIPv6) { | 84 | if errors.Is(errIPv4, os.ErrNotExist) && errors.Is(errIPv6, os.ErrNotExist) { |
84 | return ErrNoData | 85 | return ErrNoData |
85 | } | 86 | } |
86 | return nil | 87 | return nil |