--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/mod_statistics_statsd/mod_statistics_statsd.lua Tue Mar 10 14:44:55 2015 +0000
@@ -0,0 +1,36 @@
+local statsmanager = require "core.statsmanager";
+local udp = require "socket".udp();
+
+local server = module:get_option_string("statsd_server_ip", "127.0.0.1");
+local server_port = module:get_option_number("statsd_server_port", 8124);
+local max_datagram_size = module:get_option_number("statds_packet_size", 512);
+
+function push_stats(stats, meta)
+ local metric_strings, remaining_bytes = {}, max_datagram_size;
+ for name, value in pairs(stats) do
+ local value_meta = meta[name];
+ log("warn", "%s %s", name, tostring(value_meta));
+ --if not value_meta then
+ -- Simple value (gauge)
+ local metric_string = ("%s|%d|g"):format(name, value);
+ if #metric_string > remaining_bytes then
+ udp:sendto(table.concat(metric_strings, "\n"), server, server_port);
+ metric_strings, remaining_bytes = {}, max_datagram_size;
+ end
+ table.insert(metric_strings, metric_string);
+ remaining_bytes = remaining_bytes - (#metric_string + 1); -- +1 for newline
+ --end
+ end
+ if #metric_strings > 0 then
+ udp:sendto(table.concat(metric_strings, "\n"), server, server_port);
+ end
+end
+
+module:hook_global("stats-updated", function (event)
+ push_stats(event.changed_stats, event.stats_extra);
+end);
+
+function module.load()
+ local all, changed, extra = statsmanager.get_stats();
+ push_stats(all, extra);
+end