Sha256: c450e3fbaf6e13ec3edcbc09432402012f929bf0d8bed34705c295dd0ba4b5bd
Contents?: true
Size: 1.2 KB
Versions: 10
Compression:
Stored size: 1.2 KB
Contents
#!/usr/bin/env ruby require 'fileutils' class Sidekiqctl attr_reader :stage, :pidfile, :timeout def initialize(stage, pidfile, timeout) @stage = stage @pidfile = pidfile @timeout = timeout done 'No pidfile given' if !pidfile done 'Pidfile does not exist' if !File.exist?(pidfile) done 'Invalid pidfile content' if pid == 0 fetch_process begin send(stage) rescue NoMethodError done 'Invalid control command' end end def fetch_process Process.getpgid(pid) rescue Errno::ESRCH done "Process doesn't exist" end def done(msg) puts msg exit(0) end def pid File.read(pidfile).to_i end def quiet `kill -USR1 #{pid}` end def stop `kill -TERM #{pid}` timeout.times do begin Process.getpgid(pid) rescue Errno::ESRCH FileUtils.rm_f pidfile done 'Sidekiq shut down gracefully.' end sleep 1 end `kill -9 #{pid}` FileUtils.rm_f pidfile done 'Sidekiq shut down forcefully.' end def shutdown quiet stop end end stage = ARGV[0] pidfile = ARGV[1] timeout = ARGV[2].to_i timeout = 10 if timeout == 0 Sidekiqctl.new(stage, pidfile, timeout)
Version data entries
10 entries across 10 versions & 1 rubygems