module Resque::Plugins::QueueStats
Public Instance Methods
after_perform_queue_stats(*payload)
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 31 def after_perform_queue_stats(*payload) Resque.redis.incr("stat:queue:#{@queue}:performed") end
around_perform_queue_stats(*payload) { || ... }
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 35 def around_perform_queue_stats(*payload) start = Time.now yield total_time = Time.now - start Resque.redis.multi do if longest_job.to_f < total_time.to_f Resque.redis.set("stat:queue:#{@queue}:longest_job",total_time) end end end
failed_count()
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 15 def failed_count Resque.redis.get("stat:queue:#{@queue}:failed").to_i end
longest_job()
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 23 def longest_job Resque.redis.get("stat:queue:#{@queue}:longest_job").to_f end
on_failure_queue_stats(e,*payload)
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 49 def on_failure_queue_stats(e,*payload) Resque.redis.incr("stat:queue:#{@queue}:failed") end
performed_count()
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 7 def performed_count Resque.redis.get("stat:queue:#{@queue}:performed").to_i end
reset_failed_count()
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 19 def reset_failed_count Resque.redis.set("stat:queue:#{@queue}:failed",0) end
reset_longest_job()
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 27 def reset_longest_job Resque.redis.set("stat:queue:#{@queue}:longest_job",0.0) end
reset_performed_count()
click to toggle source
# File lib/resque/plugins/queue_stats.rb, line 11 def reset_performed_count Resque.redis.set("stat:queue:#{@queue}:performed",0) end