Module: Sidekiq::Canary

Defined in:
lib/sidekiq/canary.rb,
lib/sidekiq/canary/version.rb

Constant Summary collapse

VERSION = 
"0.0.2"

Instance Method Summary collapse

Instance Method Details

#canary_percent(default) ⇒ Object 



16
17
18
 
# File 'lib/sidekiq/canary.rb', line 16

def canary_percent(default)
  ENV["#{default.upcase}_CANARY_PERCENT"].to_i
end

#get_sidekiq_options ⇒ Object 



3
4
5
6
 
# File 'lib/sidekiq/canary.rb', line 3

def get_sidekiq_options
  options = super
  options.merge('queue' => queue(options["queue"]))
end

#queue(default) ⇒ Object 



8
9
10
 
# File 'lib/sidekiq/canary.rb', line 8

def queue(default)
  use_canary_queue?(default) ? "#{default}_canary" : default
end

#use_canary_queue?(default) ⇒ Boolean

Returns:

  • (Boolean) 


12
13
14
 
# File 'lib/sidekiq/canary.rb', line 12

def use_canary_queue?(default)
  rand(100) < canary_percent(default)
end