Commit 22f5b746 authored by Paul Asmuth's avatar Paul Asmuth
Browse files

renamed gauge to redismetric

parent ee85130a
Loading
Loading
Loading
Loading
+5 −3
Original line number Diff line number Diff line
@@ -101,9 +101,7 @@ module FnordMetric
end


require "fnordmetric/gauge_modifiers"
require "fnordmetric/gauge_calculations"
require "fnordmetric/gauge"

require "fnordmetric/remote_gauge"
require "fnordmetric/multi_gauge"

@@ -120,6 +118,10 @@ require "fnordmetric/gauges/numeric_gauge"
require "fnordmetric/widgets/widget"
require "fnordmetric/widgets/timeline_widget"

require "fnordmetric/metrics/redis_metric_calculations"
require "fnordmetric/metrics/redis_metric_modifiers"
require "fnordmetric/metrics/redis_metric"

require "fnordmetric/web/web"
require "fnordmetric/web/namespace"
require "fnordmetric/web/app"
+5 −5
Original line number Diff line number Diff line
@@ -16,7 +16,7 @@ class FnordMetric::NumericGauge < FnordMetric::MultiGauge
    )

    @overview_timeline.on(:values_at) do |_series, _ticks, _tick|
      series_count_gauges[_series][_tick].values_at(_ticks)
      series_count_metrics[_series][_tick].values_at(_ticks)
    end

  end
@@ -32,15 +32,15 @@ class FnordMetric::NumericGauge < FnordMetric::MultiGauge
private

  def incr_series(series, time, value = 1)
    series_count_gauges[series].values.each do |gauge|
      gauge.incr(time, value)
    series_count_metrics[series].values.each do |metric|
      metric.incr(time, value)
    end
  end

  def series_count_gauges
  def series_count_metrics
    @series_gauges ||= Hash[@opts[:series].map do |series|
      [series, Hash[@opts[:ticks].map do |tick|
        [tick.to_i, FnordMetric::Gauge.new(
        [tick.to_i, FnordMetric::RedisMetric.new(
          :key => "count-#{series}", 
          :key_prefix => key,
          :tick => tick.to_i,
+3 −3
Original line number Diff line number Diff line
class FnordMetric::Gauge
class FnordMetric::RedisMetric
  
  include FnordMetric::GaugeCalculations
  include FnordMetric::GaugeModifiers
  include FnordMetric::RedisMetricCalculations
  include FnordMetric::RedisMetricModifiers

  def initialize(opts)
    opts.fetch(:key) && opts.fetch(:key_prefix)
+1 −1
Original line number Diff line number Diff line
module FnordMetric::GaugeCalculations
module FnordMetric::RedisMetricCalculations

  @@avg_per_session_proc = proc{ |_v, _t|
    (_v.to_f / (sync_redis.get(tick_key(_t, :"sessions-count"))||1).to_i)
+1 −1
Original line number Diff line number Diff line
module FnordMetric::GaugeModifiers
module FnordMetric::RedisMetricModifiers

  def incr(time, value=1)
    assure_two_dimensional!(self)