ZFS Collector: Add dmu_tx functionality

Signed-Off-By: Joe Handzik <joseph.t.handzik@hpe.com>

1 files changed, 36 insertions, 0 deletions

diff --git a/collector/zfs_linux_test.go b/collector/zfs_linux_test.go
index ea1229a..85b477d 100644
--- a/collector/zfs_linux_test.go
+++ b/collector/zfs_linux_test.go
@@ -233,3 +233,39 @@ func TestFmParsing(t *testing.T) {
                 t.Fatal("Fm parsing handler was not called for some expected sysctls")
         }
 }
+
+func TestDmuTxParsing(t *testing.T) {
+        dmuTxFile, err := os.Open("fixtures/proc/spl/kstat/zfs/dmu_tx")
+        if err != nil {
+                t.Fatal(err)
+        }
+        defer dmuTxFile.Close()
+
+        c := zfsCollector{}
+        if err != nil {
+                t.Fatal(err)
+        }
+
+        handlerCalled := false
+        err = c.parseProcfsFile(dmuTxFile, "dmu_tx", func(s zfsSysctl, v zfsMetricValue) {
+
+                if s != zfsSysctl("kstat.zfs.misc.dmu_tx.dmu_tx_assigned") {
+                        return
+                }
+
+                handlerCalled = true
+
+                if v != zfsMetricValue(3532844) {
+                        t.Fatalf("Incorrect value parsed from procfs data")
+                }
+
+        })
+
+        if err != nil {
+                t.Fatal(err)
+        }
+
+        if !handlerCalled {
+                t.Fatal("DmuTx parsing handler was not called for some expected sysctls")
+        }
+}