Class: Autoscaler::Sidekiq::EntireQueueSystem

Inherits:

Object

• Object
• Autoscaler::Sidekiq::EntireQueueSystem

Defined in:

lib/autoscaler/sidekiq/entire_queue_system.rb

Overview

Interface to to interrogate the queuing system Includes every queue

Instance Method Summary

• #queue_names ⇒ Array[String]
• #queued ⇒ Integer

  Amount work ready to go.

• #retrying ⇒ Integer

  Amount of work still being retried.

• #scheduled ⇒ Integer

  Amount of work scheduled for some time in the future.

• #workers ⇒ Integer

  Number of workers actively engaged.

Instance Method Details

#queue_names ⇒ Array[String]

# File 'lib/autoscaler/sidekiq/entire_queue_system.rb', line 30

def queue_names
  sidekiq_queues.keys
end

#queued ⇒ Integer

# File 'lib/autoscaler/sidekiq/entire_queue_system.rb', line 15

def queued
  sidekiq_queues.values.map(&:to_i).reduce(&:+) || 0
end

#retrying ⇒ Integer

# File 'lib/autoscaler/sidekiq/entire_queue_system.rb', line 25

def retrying
  ::Sidekiq::RetrySet.new.size
end

#scheduled ⇒ Integer

# File 'lib/autoscaler/sidekiq/entire_queue_system.rb', line 20

def scheduled
  ::Sidekiq::ScheduledSet.new.size
end

#workers ⇒ Integer

# File 'lib/autoscaler/sidekiq/entire_queue_system.rb', line 9

def workers
  ::Sidekiq::Workers.new.map {|pid, _, _| pid}.uniq.size
  # #size may be out-of-date.
end