Merge pull request #67 from simonpasquier/fix-collectd-decoder
Update collectd decoder for disk metrics
diff --git a/heka/files/lua/decoders/collectd.lua b/heka/files/lua/decoders/collectd.lua
index ad2118a..085821c 100644
--- a/heka/files/lua/decoders/collectd.lua
+++ b/heka/files/lua/decoders/collectd.lua
@@ -148,7 +148,11 @@
msg['Fields']['fs'] = mount
table.insert(msg['Fields']['tag_fields'], 'fs')
elseif metric_source == 'disk' then
- msg['Fields']['name'] = metric_name
+ if sample['type'] == 'disk_io_time' then
+ msg['Fields']['name'] = 'disk' .. sep .. sample['dsnames'][i]
+ else
+ msg['Fields']['name'] = metric_name
+ end
msg['Fields']['device'] = sample['plugin_instance']
table.insert(msg['Fields']['tag_fields'], 'device')
elseif metric_source == 'cpu' then