Module: Autoscaler::Sidekiq::QueueSystem

Defined in:
lib/autoscaler/sidekiq/queue_system.rb

Overview

Interface to to interrogate the queuing system convenience constructor for SpecifiedQueueSystem and EntireQueueSystem

Class Method Summary collapse

Class Method Details

.new(specified_queues = nil) ⇒ Object

Parameters:

  • specified_queues (Array[String]) (defaults to: nil) —

    list of queues to monitor to determine if there is work left. Defaults to all sidekiq queues.



11
12
13
14
15
16
17
 
# File 'lib/autoscaler/sidekiq/queue_system.rb', line 11

def self.new(specified_queues = nil)
  if specified_queues
    SpecifiedQueueSystem.new(specified_queues)
  else
    EntireQueueSystem.new
  end
end