Class: Sidekiq::Stats
- Inherits:
-
Object
- Object
- Sidekiq::Stats
- Defined in:
- lib/sidekiq/api.rb
Defined Under Namespace
Classes: History
Instance Method Summary collapse
- #enqueued ⇒ Object
- #failed ⇒ Object
- #processed ⇒ Object
- #queues ⇒ Object
- #reset ⇒ Object
- #retry_size ⇒ Object
- #scheduled_size ⇒ Object
Instance Method Details
#enqueued ⇒ Object
33 34 35 |
# File 'lib/sidekiq/api.rb', line 33 def enqueued queues.values.inject(&:+) || 0 end |
#failed ⇒ Object
9 10 11 |
# File 'lib/sidekiq/api.rb', line 9 def failed Sidekiq.redis { |conn| conn.get("stat:failed") }.to_i end |
#processed ⇒ Object
5 6 7 |
# File 'lib/sidekiq/api.rb', line 5 def processed Sidekiq.redis { |conn| conn.get("stat:processed") }.to_i end |
#queues ⇒ Object
20 21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/sidekiq/api.rb', line 20 def queues Sidekiq.redis do |conn| queues = conn.smembers('queues') array_of_arrays = queues.inject({}) do |memo, queue| memo[queue] = conn.llen("queue:#{queue}") memo end.sort_by { |_, size| size } Hash[array_of_arrays.reverse] end end |
#reset ⇒ Object
13 14 15 16 17 18 |
# File 'lib/sidekiq/api.rb', line 13 def reset Sidekiq.redis do |conn| conn.set("stat:failed", 0) conn.set("stat:processed", 0) end end |