Add log

influxdata · Nov 25, 2020 · dc49e7a · dc49e7a
1 parent 1a1539a
commit dc49e7a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/plugins/inputs/zfs/zfs.go b/plugins/inputs/zfs/zfs.go
@@ -1,5 +1,9 @@
 package zfs
 
+import (
+	"github.com/influxdata/telegraf"
+)
+
 type Sysctl func(metric string) ([]string, error)
 type Zpool func() ([]string, error)
 type Zdataset func(properties []string) ([]string, error)
@@ -12,6 +16,7 @@ type Zfs struct {
 	sysctl         Sysctl
 	zpool          Zpool
 	zdataset       Zdataset
+	Log            telegraf.Logger `toml:"-"`
 }
 
 var sampleConfig = `

diff --git a/plugins/inputs/zfs/zfs_freebsd.go b/plugins/inputs/zfs/zfs_freebsd.go
@@ -106,6 +106,7 @@ func (z *Zfs) gatherDatasetStats(acc telegraf.Accumulator) (string, error) {
 		for _, line := range lines {
 			col := strings.Split(line, "\t")
 			if len(col) != len(properties) {
+				z.Log.Warnf("Invalid number of columns for line: %s", line)
 				continue
 			}
 
@@ -183,7 +184,7 @@ func zpool() ([]string, error) {
 }
 
 func zdataset(properties []string) ([]string, error) {
-	return run("zfs", []string{"list", "-Hp", "-o", strings.join(properties, ',')}...)
+	return run("zfs", []string{"list", "-Hp", "-o", strings.Join(properties, ',')}...)
 }
 
 func sysctl(metric string) ([]string, error) {