class Sidekiq::Health::QueueStatus

Public Instance Methods

print() click to toggle source
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