Class: Autoscaler::Sidekiq::EntireQueueSystem

Inherits:
Object
  • Object
show all
Defined in:
lib/autoscaler/sidekiq/entire_queue_system.rb

Overview

Interface to to interrogate the queuing system Includes every queue

Instance Method Summary collapse

Instance Method Details

#queue_names ⇒ Array[String]

Returns:

  • (Array[String]) 


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

def queue_names
  sidekiq_queues.keys
end

#queued ⇒ Integer

Returns amount work ready to go.

Returns:

  • (Integer) —

    amount work ready to go



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

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

#retrying ⇒ Integer

Returns amount of work still being retried.

Returns:

  • (Integer) —

    amount of work still being retried



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

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

#scheduled ⇒ Integer

Returns amount of work scheduled for some time in the future.

Returns:

  • (Integer) —

    amount of work scheduled for some time in the future



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

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

#workers ⇒ Integer

Returns number of workers actively engaged.

Returns:

  • (Integer) —

    number of workers actively engaged



9
10
11
12
 
# 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