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