class Honcho::Adapters::Sidekiq

Public Instance Methods

busy_count() click to toggle source
# File lib/honcho/adapters/sidekiq.rb, line 10
def busy_count
  processes = redis.smembers("#{namespace}:processes")
  counts = processes.map do |process|
    redis.hget("#{namespace}:#{process}", 'busy').to_i
  end
  counts.inject(&:+) || 0
end
namespace() click to toggle source
# File lib/honcho/adapters/sidekiq.rb, line 18
def namespace
  config.fetch('namespace')
end
queued_count() click to toggle source
# File lib/honcho/adapters/sidekiq.rb, line 4
def queued_count
  queues = redis.keys("#{namespace}:queue:*")
  counts = queues.map { |q| redis.llen(q) }
  counts.inject(&:+) || 0
end