diff --git a/collectors/monitors.go b/collectors/monitors.go index 4c521e0..da478db 100644 --- a/collectors/monitors.go +++ b/collectors/monitors.go @@ -271,13 +271,13 @@ func (m *MonitorCollector) collect() error { return err } - // Reset daemon specifc metrics; daemons can leave the cluster - m.TotalKBs.Reset() - m.UsedKBs.Reset() - m.AvailKBs.Reset() - m.PercentAvail.Reset() - m.Latency.Reset() - m.ClockSkew.Reset() + // Reset daemon specifc metrics; daemons can leave the cluster + m.TotalKBs.Reset() + m.UsedKBs.Reset() + m.AvailKBs.Reset() + m.PercentAvail.Reset() + m.Latency.Reset() + m.ClockSkew.Reset() for _, healthService := range stats.Health.Health.HealthServices { for _, monstat := range healthService.Mons { diff --git a/collectors/pool_usage.go b/collectors/pool_usage.go index 3ae1ccb..4d56570 100644 --- a/collectors/pool_usage.go +++ b/collectors/pool_usage.go @@ -210,16 +210,16 @@ func (p *PoolUsageCollector) collect() error { return err } - // Reset pool specfic metrics, pools can be removed - p.UsedBytes.Reset() - p.RawUsedBytes.Reset() - p.MaxAvail.Reset() - p.Objects.Reset() - p.DirtyObjects.Reset() - p.ReadIO.Reset() - p.ReadBytes.Reset() - p.WriteIO.Reset() - p.WriteBytes.Reset() + // Reset pool specfic metrics, pools can be removed + p.UsedBytes.Reset() + p.RawUsedBytes.Reset() + p.MaxAvail.Reset() + p.Objects.Reset() + p.DirtyObjects.Reset() + p.ReadIO.Reset() + p.ReadBytes.Reset() + p.WriteIO.Reset() + p.WriteBytes.Reset() for _, pool := range stats.Pools { p.UsedBytes.WithLabelValues(pool.Name).Set(pool.Stats.BytesUsed)