diff --git a/metrics/disk.go b/metrics/disk.go
index 25142d2ad1..ba15b3fad9 100644
--- a/metrics/disk.go
+++ b/metrics/disk.go
@@ -18,8 +18,10 @@ package metrics
 
 // DiskStats is the per process disk io stats.
 type DiskStats struct {
-	ReadCount  int64 // Number of read operations executed
-	ReadBytes  int64 // Total number of bytes read
-	WriteCount int64 // Number of write operations executed
-	WriteBytes int64 // Total number of byte written
+	ReadCount    int64 // Number of read operations executed
+	ReadBytes    int64 // Total number of bytes read (include disk cache)
+	WriteCount   int64 // Number of write operations executed
+	WriteBytes   int64 // Total number of byte written
+	IOReadBytes  int64 // Total number of io bytes read
+	IOWriteBytes int64 // Total number of io bytes write
 }
diff --git a/metrics/disk_linux.go b/metrics/disk_linux.go
index 8d610cd674..4324adb4c7 100644
--- a/metrics/disk_linux.go
+++ b/metrics/disk_linux.go
@@ -67,6 +67,10 @@ func ReadDiskStats(stats *DiskStats) error {
 			stats.ReadBytes = value
 		case "wchar":
 			stats.WriteBytes = value
+		case "read_bytes":
+			stats.IOReadBytes = value
+		case "write_bytes":
+			stats.IOWriteBytes = value
 		}
 	}
 }
diff --git a/metrics/metrics.go b/metrics/metrics.go
index 9ca8f115c0..b6731fc6ed 100644
--- a/metrics/metrics.go
+++ b/metrics/metrics.go
@@ -171,27 +171,29 @@ func CollectProcessMetrics(refresh time.Duration) {
 
 	// Define the various metrics to collect
 	var (
-		cpuSysLoad            = GetOrRegisterGauge("system/cpu/sysload", DefaultRegistry)
-		cpuSysWait            = GetOrRegisterGauge("system/cpu/syswait", DefaultRegistry)
-		cpuProcLoad           = GetOrRegisterGauge("system/cpu/procload", DefaultRegistry)
-		cpuSysLoadTotal       = GetOrRegisterCounterFloat64("system/cpu/sysload/total", DefaultRegistry)
-		cpuSysWaitTotal       = GetOrRegisterCounterFloat64("system/cpu/syswait/total", DefaultRegistry)
-		cpuProcLoadTotal      = GetOrRegisterCounterFloat64("system/cpu/procload/total", DefaultRegistry)
-		cpuThreads            = GetOrRegisterGauge("system/cpu/threads", DefaultRegistry)
-		cpuGoroutines         = GetOrRegisterGauge("system/cpu/goroutines", DefaultRegistry)
-		cpuSchedLatency       = getOrRegisterRuntimeHistogram("system/cpu/schedlatency", secondsToNs, nil)
-		memPauses             = getOrRegisterRuntimeHistogram("system/memory/pauses", secondsToNs, nil)
-		memAllocs             = GetOrRegisterMeter("system/memory/allocs", DefaultRegistry)
-		memFrees              = GetOrRegisterMeter("system/memory/frees", DefaultRegistry)
-		memTotal              = GetOrRegisterGauge("system/memory/held", DefaultRegistry)
-		heapUsed              = GetOrRegisterGauge("system/memory/used", DefaultRegistry)
-		heapObjects           = GetOrRegisterGauge("system/memory/objects", DefaultRegistry)
-		diskReads             = GetOrRegisterMeter("system/disk/readcount", DefaultRegistry)
-		diskReadBytes         = GetOrRegisterMeter("system/disk/readdata", DefaultRegistry)
-		diskReadBytesCounter  = GetOrRegisterCounter("system/disk/readbytes", DefaultRegistry)
-		diskWrites            = GetOrRegisterMeter("system/disk/writecount", DefaultRegistry)
-		diskWriteBytes        = GetOrRegisterMeter("system/disk/writedata", DefaultRegistry)
-		diskWriteBytesCounter = GetOrRegisterCounter("system/disk/writebytes", DefaultRegistry)
+		cpuSysLoad              = GetOrRegisterGauge("system/cpu/sysload", DefaultRegistry)
+		cpuSysWait              = GetOrRegisterGauge("system/cpu/syswait", DefaultRegistry)
+		cpuProcLoad             = GetOrRegisterGauge("system/cpu/procload", DefaultRegistry)
+		cpuSysLoadTotal         = GetOrRegisterCounterFloat64("system/cpu/sysload/total", DefaultRegistry)
+		cpuSysWaitTotal         = GetOrRegisterCounterFloat64("system/cpu/syswait/total", DefaultRegistry)
+		cpuProcLoadTotal        = GetOrRegisterCounterFloat64("system/cpu/procload/total", DefaultRegistry)
+		cpuThreads              = GetOrRegisterGauge("system/cpu/threads", DefaultRegistry)
+		cpuGoroutines           = GetOrRegisterGauge("system/cpu/goroutines", DefaultRegistry)
+		cpuSchedLatency         = getOrRegisterRuntimeHistogram("system/cpu/schedlatency", secondsToNs, nil)
+		memPauses               = getOrRegisterRuntimeHistogram("system/memory/pauses", secondsToNs, nil)
+		memAllocs               = GetOrRegisterMeter("system/memory/allocs", DefaultRegistry)
+		memFrees                = GetOrRegisterMeter("system/memory/frees", DefaultRegistry)
+		memTotal                = GetOrRegisterGauge("system/memory/held", DefaultRegistry)
+		heapUsed                = GetOrRegisterGauge("system/memory/used", DefaultRegistry)
+		heapObjects             = GetOrRegisterGauge("system/memory/objects", DefaultRegistry)
+		diskReads               = GetOrRegisterMeter("system/disk/readcount", DefaultRegistry)
+		diskReadBytes           = GetOrRegisterMeter("system/disk/readdata", DefaultRegistry)
+		diskReadBytesCounter    = GetOrRegisterCounter("system/disk/readbytes", DefaultRegistry)
+		diskWrites              = GetOrRegisterMeter("system/disk/writecount", DefaultRegistry)
+		diskWriteBytes          = GetOrRegisterMeter("system/disk/writedata", DefaultRegistry)
+		diskWriteBytesCounter   = GetOrRegisterCounter("system/disk/writebytes", DefaultRegistry)
+		diskIOReadBytesCounter  = GetOrRegisterCounter("system/disk/io/readbytes", DefaultRegistry)
+		diskIOWriteBytesCounter = GetOrRegisterCounter("system/disk/io/writebytes", DefaultRegistry)
 	)
 
 	var lastCollectTime time.Time
@@ -243,6 +245,8 @@ func CollectProcessMetrics(refresh time.Duration) {
 			diskWriteBytes.Mark(diskstats[now].WriteBytes - diskstats[prev].WriteBytes)
 			diskReadBytesCounter.Inc(diskstats[now].ReadBytes - diskstats[prev].ReadBytes)
 			diskWriteBytesCounter.Inc(diskstats[now].WriteBytes - diskstats[prev].WriteBytes)
+			diskIOReadBytesCounter.Inc(diskstats[now].IOReadBytes - diskstats[prev].IOReadBytes)
+			diskIOWriteBytesCounter.Inc(diskstats[now].IOWriteBytes - diskstats[prev].IOWriteBytes)
 		}
 
 		time.Sleep(refresh)