Contents

module WorkerKiller
  module Killer
    class Base

      attr_accessor :config, :kill_attempts, :logger

      def initialize(logger: WorkerKiller.configuration.logger, **_kwargs)
        @logger = logger
        @config = WorkerKiller.configuration
        @kill_attempts = 0
      end

      def kill(start_time, **params)
        alive_sec = (Time.now - start_time).round

        @kill_attempts += 1

        sig = :QUIT
        sig = :TERM if kill_attempts > config.quit_attempts
        sig = :KILL if kill_attempts > (config.quit_attempts + config.term_attempts)

        do_kill(sig, Process.pid, alive_sec, **params)
      end

      # :nocov:
      def do_kill(*_args)
        raise 'Not Implemented'
      end
      # :nocov:

    end
  end
end

require_relative 'killer/signal'
require_relative 'killer/passenger'
require_relative 'killer/delayed_job'

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
worker_killer-1.0.2.187805	lib/worker_killer/killer.rb
worker_killer-1.0.2.187732	lib/worker_killer/killer.rb
worker_killer-1.0.1.83603	lib/worker_killer/killer.rb
worker_killer-1.0.1.75538	lib/worker_killer/killer.rb
worker_killer-1.0.1.39842	lib/worker_killer/killer.rb
worker_killer-1.0.0.39841	lib/worker_killer/killer.rb
worker_killer-1.0.0.39839	lib/worker_killer/killer.rb
worker_killer-0.1.1.39838	lib/worker_killer/killer.rb