class Sidekiq::Cluster::Memory::Individual

Attributes

config[RW]
worker_pool[RW]

Public Class Methods

new(worker_pool) click to toggle source
# File lib/sidekiq/cluster/memory/individual.rb, line 9
def initialize(worker_pool)
  self.worker_pool = worker_pool
  self.config      = worker_pool.config
end

Public Instance Methods

offenders() click to toggle source
# File lib/sidekiq/cluster/memory/individual.rb, line 14
def offenders
  worker_pool.find do |worker|
    worker.memory_used_pct > config.max_memory_percent / worker_pool.size
  end
end