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