diff options
author | Joe Handzik <joseph.t.handzik@hpe.com> | 2017-01-25 21:47:48 -0600 |
---|---|---|
committer | Joe Handzik <joseph.t.handzik@hpe.com> | 2017-01-27 14:02:28 -0600 |
commit | e213ccbc57a87016d683aeae1db78a58cf5c6a23 (patch) | |
tree | 5cc74e241d86b95265a242078d839be6f7b0a725 /collector/zfs_linux_test.go | |
parent | 1dde3ec31ba1d9e50eeff26c44179b411fd21349 (diff) | |
download | prometheus_node_collector-e213ccbc57a87016d683aeae1db78a58cf5c6a23.tar.bz2 prometheus_node_collector-e213ccbc57a87016d683aeae1db78a58cf5c6a23.tar.xz prometheus_node_collector-e213ccbc57a87016d683aeae1db78a58cf5c6a23.zip |
ZFS Collector: Refactor to use maps/slices and fewer globals
Removed all global types that were unnecessary, and refactored to use constructor-created values and inline values instead of globals.
Signed-Off-By: Joe Handzik <joseph.t.handzik@hpe.com>
Diffstat (limited to 'collector/zfs_linux_test.go')
-rw-r--r-- | collector/zfs_linux_test.go | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/collector/zfs_linux_test.go b/collector/zfs_linux_test.go index 85b477d..8a10231 100644 --- a/collector/zfs_linux_test.go +++ b/collector/zfs_linux_test.go | |||
@@ -31,7 +31,7 @@ func TestArcstatsParsing(t *testing.T) { | |||
31 | } | 31 | } |
32 | 32 | ||
33 | handlerCalled := false | 33 | handlerCalled := false |
34 | err = c.parseProcfsFile(arcstatsFile, "arcstats", func(s zfsSysctl, v zfsMetricValue) { | 34 | err = c.parseProcfsFile(arcstatsFile, "arcstats", func(s zfsSysctl, v int) { |
35 | 35 | ||
36 | if s != zfsSysctl("kstat.zfs.misc.arcstats.hits") { | 36 | if s != zfsSysctl("kstat.zfs.misc.arcstats.hits") { |
37 | return | 37 | return |
@@ -39,7 +39,7 @@ func TestArcstatsParsing(t *testing.T) { | |||
39 | 39 | ||
40 | handlerCalled = true | 40 | handlerCalled = true |
41 | 41 | ||
42 | if v != zfsMetricValue(8772612) { | 42 | if v != int(8772612) { |
43 | t.Fatalf("Incorrect value parsed from procfs data") | 43 | t.Fatalf("Incorrect value parsed from procfs data") |
44 | } | 44 | } |
45 | 45 | ||
@@ -67,7 +67,7 @@ func TestZfetchstatsParsing(t *testing.T) { | |||
67 | } | 67 | } |
68 | 68 | ||
69 | handlerCalled := false | 69 | handlerCalled := false |
70 | err = c.parseProcfsFile(zfetchstatsFile, "zfetchstats", func(s zfsSysctl, v zfsMetricValue) { | 70 | err = c.parseProcfsFile(zfetchstatsFile, "zfetchstats", func(s zfsSysctl, v int) { |
71 | 71 | ||
72 | if s != zfsSysctl("kstat.zfs.misc.zfetchstats.hits") { | 72 | if s != zfsSysctl("kstat.zfs.misc.zfetchstats.hits") { |
73 | return | 73 | return |
@@ -75,7 +75,7 @@ func TestZfetchstatsParsing(t *testing.T) { | |||
75 | 75 | ||
76 | handlerCalled = true | 76 | handlerCalled = true |
77 | 77 | ||
78 | if v != zfsMetricValue(7067992) { | 78 | if v != int(7067992) { |
79 | t.Fatalf("Incorrect value parsed from procfs data") | 79 | t.Fatalf("Incorrect value parsed from procfs data") |
80 | } | 80 | } |
81 | 81 | ||
@@ -103,7 +103,7 @@ func TestZilParsing(t *testing.T) { | |||
103 | } | 103 | } |
104 | 104 | ||
105 | handlerCalled := false | 105 | handlerCalled := false |
106 | err = c.parseProcfsFile(zilFile, "zil", func(s zfsSysctl, v zfsMetricValue) { | 106 | err = c.parseProcfsFile(zilFile, "zil", func(s zfsSysctl, v int) { |
107 | 107 | ||
108 | if s != zfsSysctl("kstat.zfs.misc.zil.zil_commit_count") { | 108 | if s != zfsSysctl("kstat.zfs.misc.zil.zil_commit_count") { |
109 | return | 109 | return |
@@ -111,7 +111,7 @@ func TestZilParsing(t *testing.T) { | |||
111 | 111 | ||
112 | handlerCalled = true | 112 | handlerCalled = true |
113 | 113 | ||
114 | if v != zfsMetricValue(10) { | 114 | if v != int(10) { |
115 | t.Fatalf("Incorrect value parsed from procfs data") | 115 | t.Fatalf("Incorrect value parsed from procfs data") |
116 | } | 116 | } |
117 | 117 | ||
@@ -139,7 +139,7 @@ func TestVdevCacheStatsParsing(t *testing.T) { | |||
139 | } | 139 | } |
140 | 140 | ||
141 | handlerCalled := false | 141 | handlerCalled := false |
142 | err = c.parseProcfsFile(vdevCacheStatsFile, "vdev_cache_stats", func(s zfsSysctl, v zfsMetricValue) { | 142 | err = c.parseProcfsFile(vdevCacheStatsFile, "vdev_cache_stats", func(s zfsSysctl, v int) { |
143 | 143 | ||
144 | if s != zfsSysctl("kstat.zfs.misc.vdev_cache_stats.delegations") { | 144 | if s != zfsSysctl("kstat.zfs.misc.vdev_cache_stats.delegations") { |
145 | return | 145 | return |
@@ -147,7 +147,7 @@ func TestVdevCacheStatsParsing(t *testing.T) { | |||
147 | 147 | ||
148 | handlerCalled = true | 148 | handlerCalled = true |
149 | 149 | ||
150 | if v != zfsMetricValue(40) { | 150 | if v != int(40) { |
151 | t.Fatalf("Incorrect value parsed from procfs data") | 151 | t.Fatalf("Incorrect value parsed from procfs data") |
152 | } | 152 | } |
153 | 153 | ||
@@ -175,7 +175,7 @@ func TestXuioStatsParsing(t *testing.T) { | |||
175 | } | 175 | } |
176 | 176 | ||
177 | handlerCalled := false | 177 | handlerCalled := false |
178 | err = c.parseProcfsFile(xuioStatsFile, "xuio_stats", func(s zfsSysctl, v zfsMetricValue) { | 178 | err = c.parseProcfsFile(xuioStatsFile, "xuio_stats", func(s zfsSysctl, v int) { |
179 | 179 | ||
180 | if s != zfsSysctl("kstat.zfs.misc.xuio_stats.onloan_read_buf") { | 180 | if s != zfsSysctl("kstat.zfs.misc.xuio_stats.onloan_read_buf") { |
181 | return | 181 | return |
@@ -183,7 +183,7 @@ func TestXuioStatsParsing(t *testing.T) { | |||
183 | 183 | ||
184 | handlerCalled = true | 184 | handlerCalled = true |
185 | 185 | ||
186 | if v != zfsMetricValue(32) { | 186 | if v != int(32) { |
187 | t.Fatalf("Incorrect value parsed from procfs data") | 187 | t.Fatalf("Incorrect value parsed from procfs data") |
188 | } | 188 | } |
189 | 189 | ||
@@ -211,7 +211,7 @@ func TestFmParsing(t *testing.T) { | |||
211 | } | 211 | } |
212 | 212 | ||
213 | handlerCalled := false | 213 | handlerCalled := false |
214 | err = c.parseProcfsFile(fmFile, "fm", func(s zfsSysctl, v zfsMetricValue) { | 214 | err = c.parseProcfsFile(fmFile, "fm", func(s zfsSysctl, v int) { |
215 | 215 | ||
216 | if s != zfsSysctl("kstat.zfs.misc.fm.erpt-dropped") { | 216 | if s != zfsSysctl("kstat.zfs.misc.fm.erpt-dropped") { |
217 | return | 217 | return |
@@ -219,7 +219,7 @@ func TestFmParsing(t *testing.T) { | |||
219 | 219 | ||
220 | handlerCalled = true | 220 | handlerCalled = true |
221 | 221 | ||
222 | if v != zfsMetricValue(18) { | 222 | if v != int(18) { |
223 | t.Fatalf("Incorrect value parsed from procfs data") | 223 | t.Fatalf("Incorrect value parsed from procfs data") |
224 | } | 224 | } |
225 | 225 | ||
@@ -247,7 +247,7 @@ func TestDmuTxParsing(t *testing.T) { | |||
247 | } | 247 | } |
248 | 248 | ||
249 | handlerCalled := false | 249 | handlerCalled := false |
250 | err = c.parseProcfsFile(dmuTxFile, "dmu_tx", func(s zfsSysctl, v zfsMetricValue) { | 250 | err = c.parseProcfsFile(dmuTxFile, "dmu_tx", func(s zfsSysctl, v int) { |
251 | 251 | ||
252 | if s != zfsSysctl("kstat.zfs.misc.dmu_tx.dmu_tx_assigned") { | 252 | if s != zfsSysctl("kstat.zfs.misc.dmu_tx.dmu_tx_assigned") { |
253 | return | 253 | return |
@@ -255,7 +255,7 @@ func TestDmuTxParsing(t *testing.T) { | |||
255 | 255 | ||
256 | handlerCalled = true | 256 | handlerCalled = true |
257 | 257 | ||
258 | if v != zfsMetricValue(3532844) { | 258 | if v != int(3532844) { |
259 | t.Fatalf("Incorrect value parsed from procfs data") | 259 | t.Fatalf("Incorrect value parsed from procfs data") |
260 | } | 260 | } |
261 | 261 | ||