Class: Sidekiq::Stats
- Inherits:
-
Object
- Object
- Sidekiq::Stats
- Defined in:
- lib/sidekiq/api.rb
Overview
Defined Under Namespace
Classes: History
Instance Method Summary collapse
- #dead_size ⇒ Object
- #default_queue_latency ⇒ Object
- #enqueued ⇒ Object
- #failed ⇒ Object
-
#initialize ⇒ Stats
constructor
A new instance of Stats.
- #processed ⇒ Object
- #processes_size ⇒ Object
- #queues ⇒ Object
- #retry_size ⇒ Object
- #scheduled_size ⇒ Object
- #workers_size ⇒ Object
Constructor Details
#initialize ⇒ Stats
Returns a new instance of Stats.
29 30 31 |
# File 'lib/sidekiq/api.rb', line 29 def initialize fetch_stats_fast! end |
Instance Method Details
#dead_size ⇒ Object
49 50 51 |
# File 'lib/sidekiq/api.rb', line 49 def dead_size stat :dead_size end |
#default_queue_latency ⇒ Object
65 66 67 |
# File 'lib/sidekiq/api.rb', line 65 def default_queue_latency stat :default_queue_latency end |
#enqueued ⇒ Object
53 54 55 |
# File 'lib/sidekiq/api.rb', line 53 def enqueued stat :enqueued end |
#failed ⇒ Object
37 38 39 |
# File 'lib/sidekiq/api.rb', line 37 def failed stat :failed end |
#processed ⇒ Object
33 34 35 |
# File 'lib/sidekiq/api.rb', line 33 def processed stat :processed end |
#processes_size ⇒ Object
57 58 59 |
# File 'lib/sidekiq/api.rb', line 57 def processes_size stat :processes_size end |
#queues ⇒ Object
69 70 71 72 73 74 75 76 77 78 79 80 81 82 |
# File 'lib/sidekiq/api.rb', line 69 def queues Sidekiq.redis do |conn| queues = conn.sscan("queues").to_a lengths = conn.pipelined { |pipeline| queues.each do |queue| pipeline.llen("queue:#{queue}") end } array_of_arrays = queues.zip(lengths).sort_by { |_, size| -size } array_of_arrays.to_h end end |
#retry_size ⇒ Object
45 46 47 |
# File 'lib/sidekiq/api.rb', line 45 def retry_size stat :retry_size end |
#scheduled_size ⇒ Object
41 42 43 |
# File 'lib/sidekiq/api.rb', line 41 def scheduled_size stat :scheduled_size end |
#workers_size ⇒ Object
61 62 63 |
# File 'lib/sidekiq/api.rb', line 61 def workers_size stat :workers_size end |