class OurEelHacks::Sidekiq
Public Class Methods
new(flavor=:sidekiq)
click to toggle source
Calls superclass method
OurEelHacks::Middleware::new
# File lib/our-eel-hacks/sidekiq.rb, line 7 def initialize(flavor=:sidekiq) super end
Public Instance Methods
call(worker_class, item, queue) { || ... }
click to toggle source
# File lib/our-eel-hacks/sidekiq.rb, line 11 def call(worker_class, item, queue) begin autoscale(get_queue_length(queue)) rescue => ex puts "Problem in autoscaling: #{ex.inspect}" end yield end
get_queue_length(queue)
click to toggle source
# File lib/our-eel-hacks/sidekiq.rb, line 20 def get_queue_length(queue) {"queue_length" => ::Sidekiq.redis do |conn| conn.llen("queue:#{queue}") || 0 end } end