mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
37 lines
1 KiB
Ruby
37 lines
1 KiB
Ruby
module Sidekiq
|
|
module_function
|
|
|
|
def info
|
|
results = {}
|
|
futures = {}
|
|
queues_with_sizes = Sidekiq.redis { |conn|
|
|
conn.pipelined do
|
|
futures[:processed] = conn.get('stat:processed')
|
|
futures[:failed] = conn.get('stat:failed')
|
|
futures[:queues] = conn.smembers('queues')
|
|
end
|
|
}
|
|
results[:queues_with_sizes] = Sidekiq.redis do |conn|
|
|
futures[:queues].value.inject({}) { |memo, q|
|
|
memo[q] = conn.llen("queue:#{q}")
|
|
memo
|
|
}.sort_by { |_, size| size }
|
|
end
|
|
results[:processed] = (futures[:processed].value || 0).to_i
|
|
results[:failed] = (futures[:failed].value || 0).to_i
|
|
results[:backlog] = results[:queues_with_sizes].
|
|
map {|_, size| size }.
|
|
inject(0) {|memo, val| memo + val }
|
|
results
|
|
end
|
|
|
|
def size(*queues)
|
|
return info[:backlog] if queues.empty?
|
|
|
|
Sidekiq.redis { |conn|
|
|
conn.pipelined {
|
|
queues.map { |q| conn.llen("queue:#{q}") }
|
|
}
|
|
}.inject(0) { |memo, count| memo += count }
|
|
end
|
|
end
|