class Sidekiq::Health::QueueStatus
Public Instance Methods
print()
click to toggle source
# File lib/sidekiq/health/queue_status.rb, line 71 def print output = "" queue_names.each do |name| output << "\n" unless output == "" output << QueueHealthFormatter.new(name, queue_size(name)).to_s end output end
statuses()
click to toggle source
# File lib/sidekiq/health/queue_status.rb, line 82 def statuses queue_names.map do |name| Status.new \ name, dead_set_for(queue_name: name) end end
Private Instance Methods
all_dead_jobs()
click to toggle source
# File lib/sidekiq/health/queue_status.rb, line 104 def all_dead_jobs @all_dead_jobs ||= Sidekiq::DeadSet.new.inject({}) do |all_jobs, item| all_jobs[item.queue] = all_jobs.fetch(item.queue, []) + [item] all_jobs end end
dead_set_for(queue_name:)
click to toggle source
# File lib/sidekiq/health/queue_status.rb, line 100 def dead_set_for(queue_name:) all_dead_jobs.fetch(queue_name, []) end
queue_names()
click to toggle source
# File lib/sidekiq/health/queue_status.rb, line 96 def queue_names Sidekiq::Health::QueueNames.new.get end
queue_size(name)
click to toggle source
# File lib/sidekiq/health/queue_status.rb, line 92 def queue_size(name) Sidekiq::Queue.new(name).size end