aboutsummaryrefslogtreecommitdiff
path: root/collector/udp_queues_linux.go
diff options
context:
space:
mode:
Diffstat (limited to 'collector/udp_queues_linux.go')
-rw-r--r--collector/udp_queues_linux.go13
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 @@
16package collector 16package collector
17 17
18import ( 18import (
19 "errors"
19 "fmt" 20 "fmt"
20 "os" 21 "os"
21 22
@@ -41,7 +42,7 @@ func init() {
41func NewUDPqueuesCollector(logger log.Logger) (Collector, error) { 42func 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