lib/metricize/forwarder.rb in metricize-0.5.2 vs lib/metricize/forwarder.rb in metricize-0.5.3
- old
+ new
@@ -56,11 +56,10 @@
def add_aggregate_info(metrics)
counters, measurements = metrics.partition {|metric| metric.fetch(:name) =~ /.count$/ }
counters = consolidate_counts(counters)
measurements = add_value_stats(measurements)
- measurements << add_stat_by_key(@queue_name + '.counters', counters.size)
{ :gauges => counters + measurements, :measure_time => Time.now.to_i }
end
def consolidate_counts(counters)
aggregated_counts = {}
@@ -87,15 +86,15 @@
end
value_groups.each do |key, values|
with_error_handling do
print_histogram(key, values)
end
+ gauges << add_stat_by_key(key, values.size, '.count').merge(counter_attributes)
[0.50, 0.95].each do |p|
percentile = values.extend(Stats).calculate_percentile(p)
gauges << add_stat_by_key(key, percentile, ".#{(p*100).to_i}e")
end
end
- gauges << add_stat_by_key(@queue_name + '.measurements', value_groups.size)
gauges
end
def print_histogram(name, values)
return if values.size < 5