From 79c3c61df3a0da724fd92c837bb755033dadb8f7 Mon Sep 17 00:00:00 2001 From: alistar79 Date: Sun, 23 Jun 2013 21:55:45 +0200 Subject: [PATCH 1/3] Update statsd.rb Added gauge metric. --- lib/logstash/outputs/statsd.rb | 3 +++ 1 file changed, 3 insertions(+) diff --git a/lib/logstash/outputs/statsd.rb b/lib/logstash/outputs/statsd.rb index 90bdbecd9..8bf443b81 100644 --- a/lib/logstash/outputs/statsd.rb +++ b/lib/logstash/outputs/statsd.rb @@ -52,6 +52,9 @@ class LogStash::Outputs::Statsd < LogStash::Outputs::Base # A count metric. metric_name => count as hash config :count, :validate => :hash, :default => {} + # A gauge metric. metric_name => guage as hash + config :gauge, :validate => :hash, :default => {} + # The sample rate for the metric config :sample_rate, :validate => :number, :default => 1 From 86e2186088f25182cf3eb75a1b265319dce2b120 Mon Sep 17 00:00:00 2001 From: alistar79 Date: Sun, 23 Jun 2013 21:59:05 +0200 Subject: [PATCH 2/3] Update statsd.rb typo fix. --- lib/logstash/outputs/statsd.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/logstash/outputs/statsd.rb b/lib/logstash/outputs/statsd.rb index 8bf443b81..8a788c992 100644 --- a/lib/logstash/outputs/statsd.rb +++ b/lib/logstash/outputs/statsd.rb @@ -52,7 +52,7 @@ class LogStash::Outputs::Statsd < LogStash::Outputs::Base # A count metric. metric_name => count as hash config :count, :validate => :hash, :default => {} - # A gauge metric. metric_name => guage as hash + # A gauge metric. metric_name => gauge as hash config :gauge, :validate => :hash, :default => {} # The sample rate for the metric From a3e0371a12ddacb6601d1dfe7d69210e59b0ae57 Mon Sep 17 00:00:00 2001 From: alistar79 Date: Sun, 23 Jun 2013 22:08:43 +0200 Subject: [PATCH 3/3] Update statsd.rb Added gauge client. --- lib/logstash/outputs/statsd.rb | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/lib/logstash/outputs/statsd.rb b/lib/logstash/outputs/statsd.rb index 8a788c992..b6b8da984 100644 --- a/lib/logstash/outputs/statsd.rb +++ b/lib/logstash/outputs/statsd.rb @@ -93,6 +93,10 @@ class LogStash::Outputs::Statsd < LogStash::Outputs::Base @client.timing(build_stat(event.sprintf(metric), sender), event.sprintf(val).to_f, @sample_rate) end + @gauge.each do |metric, val| + @client.gauge(build_stat(event.sprintf(metric), sender), + event.sprintf(val).to_f, @sample_rate) + end end # def receive def build_stat(metric, sender=@sender)