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