Module: Autoscale::Queue::Sidekiq

Defined in:
lib/autoscale/queue/sidekiq.rb,
lib/autoscale/queue/sidekiq/version.rb

Constant Summary collapse

VERSION = 
"0.2.0".freeze

Class Method Summary collapse

Class Method Details

.job_queue_time(*queues) ⇒ Object 



8
9
10
11
 
# File 'lib/autoscale/queue/sidekiq.rb', line 8

def job_queue_time(*queues)
  queues = ::Sidekiq::Queue.all.map(&:name) if queues.empty?
  queues.map { |queue| ::Sidekiq::Queue.new(queue).latency }.max.round
end