Module: Sqeduler::Worker::KillSwitch

Defined in:
lib/sqeduler/worker/kill_switch.rb

Overview

Uses Redis hashes to enabled and disable workers across multiple hosts.

Defined Under Namespace

Modules: ClassMethods

Constant Summary collapse

SIDEKIQ_DISABLED_WORKERS = 
"sidekiq.disabled-workers".freeze

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.disabled ⇒ Object 



15
16
17
18
19
 
# File 'lib/sqeduler/worker/kill_switch.rb', line 15

def self.disabled
  Service.redis_pool.with do |redis|
    redis.hgetall(SIDEKIQ_DISABLED_WORKERS)
  end
end

.prepended(base) ⇒ Object 



8
9
10
11
12
13
 
# File 'lib/sqeduler/worker/kill_switch.rb', line 8

def self.prepended(base)
  if base.ancestors.include?(Sqeduler::Worker::Callbacks)
    raise "Sqeduler::Worker::Callbacks must be the last module that you prepend."
  end
  base.extend(ClassMethods)
end

Instance Method Details

#perform(*args) ⇒ Object

rubocop:enable Style/Documentation



49
50
51
52
53
54
55
 
# File 'lib/sqeduler/worker/kill_switch.rb', line 49

def perform(*args)
  if self.class.disabled?
    Service.logger.warn "#{self.class.name} is currently disabled."
  else
    super
  end
end