class Sidekiq::Stats::Queues
Public Instance Methods
lengths()
click to toggle source
# File lib/sidekiq/api.rb, line 118 def lengths Sidekiq.redis do |conn| queues = conn.smembers('queues') lengths = conn.pipelined do queues.each do |queue| conn.llen("queue:#{queue}") end end i = 0 array_of_arrays = queues.inject({}) do |memo, queue| memo[queue] = lengths[i] i += 1 memo end.sort_by { |_, size| size } Hash[array_of_arrays.reverse] end end