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
- #retry_size ⇒ Object
- #scheduled_size ⇒ Object
Instance Method Details
#enqueued ⇒ Object
32 33 34 |
# File 'lib/sidekiq/api.rb', line 32 def enqueued queues.values.inject(&:+) || 0 end |
#failed ⇒ Object
12 13 14 15 16 17 |
# File 'lib/sidekiq/api.rb', line 12 def failed count = Sidekiq.redis do |conn| conn.get("stat:failed") end count.nil? ? 0 : count.to_i end |
#processed ⇒ Object
5 6 7 8 9 10 |
# File 'lib/sidekiq/api.rb', line 5 def processed count = Sidekiq.redis do |conn| conn.get("stat:processed") end count.nil? ? 0 : count.to_i end |
#queues ⇒ Object
19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/sidekiq/api.rb', line 19 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 |