class Resque::Metrics::Backends::Redis

Attributes

redis[RW]

Public Class Methods

new(redis) click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 7
def initialize(redis)
  @redis = redis
end

Public Instance Methods

get_metric(metric) click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 24
def get_metric(metric)
  redis.get("_metrics_:#{metric}").to_i
end
increment_metric(metric, by = 1) click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 11
def increment_metric(metric, by = 1)
  redis.incrby("_metrics_:#{metric}", by)
end
known_jobs() click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 32
def known_jobs
  redis.smembers('_metrics_:known_jobs')
end
register_job(job) click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 28
def register_job(job)
  redis.sadd('_metrics_:known_jobs', job)
end
set_avg(metric, num, total) click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 19
def set_avg(metric, num, total)
  val = total < 1 ? 0 : num / total
  set_metric(metric, val)
end
set_metric(metric, val) click to toggle source
# File lib/resque/metrics/backends/redis.rb, line 15
def set_metric(metric, val)
  redis.set("_metrics_:#{metric}", val)
end