Contents

require_relative 'base'

module Sidekiq
  module Cluster
    module Monitors
      class DeadChildren < Base
        def monitor
          pool.info 'watching for workers that died...'
          loop do
            sleep SLEEP_DELAY - 1
            pool.workers.each(&:check_worker)
            break unless pool.operational?
            "monitor for Dead Children is operational, last logged at #{@last_logged_at}"
          end
          pool.info 'leaving Dead Children Monitor'
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-cluster-0.1.2	lib/sidekiq/cluster/monitors/dead_children.rb