to filter by filesystem type, we need to pass that up the chain

This commit is contained in:
Simon Fraser 2015-08-10 20:43:15 +01:00 committed by Cameron Sparr
parent 540ba6d6ae
commit bba162c55b
3 changed files with 4 additions and 2 deletions

View File

@ -24,9 +24,9 @@ func (s *DiskStats) Gather(acc plugins.Accumulator) error {
for _, du := range disks {
tags := map[string]string{
"path": du.Path,
"path": du.Path,
"fstype": du.Fstype,
}
acc.Add("total", du.Total, tags)
acc.Add("free", du.Free, tags)
acc.Add("used", du.Total-du.Free, tags)

View File

@ -63,6 +63,7 @@ func (s *systemPS) DiskUsage() ([]*disk.DiskUsageStat, error) {
for _, p := range parts {
du, err := disk.DiskUsage(p.Mountpoint)
du.Fstype = p.Fstype
if err != nil {
return nil, err
}

View File

@ -6,6 +6,7 @@ import (
type DiskUsageStat struct {
Path string `json:"path"`
Fstype string `json:"fstype"`
Total uint64 `json:"total"`
Free uint64 `json:"free"`
Used uint64 `json:"used"`