class Librato::Sidekiq::ClientMiddleware

Public Class Methods

reconfigure() click to toggle source
# File lib/librato-sidekiq/client_middleware.rb, line 4
def self.reconfigure
  # puts "Reconfiguring with: #{options}"
  ::Sidekiq.configure_client do |config|
    config.client_middleware do |chain|
      chain.remove self
      chain.add self, options
    end
  end
end

Protected Instance Methods

track(tracking_group, stats, worker_instance, msg, queue, elapsed) click to toggle source
# File lib/librato-sidekiq/client_middleware.rb, line 16
def track(tracking_group, stats, worker_instance, msg, queue, elapsed)
  tracking_group.increment 'queued'
  return unless allowed_to_submit queue, worker_instance
  # puts "doing Librato insert"
  tracking_group.group queue.to_s do |q|
    q.increment 'queued'

    # using something like User.delay.send_email invokes
    # a class name with slashes. remove them in favor of underscores
    q.group msg['class'].underscore.gsub('/', '_') do |w|
      w.increment 'queued'
    end
  end
end