Sha256: 434bd2ad9022e33256860b8d39720d716416db8b82a9332905e5940728869932
Contents?: true
Size: 1.31 KB
Versions: 13
Compression:
Stored size: 1.31 KB
Contents
module Sidekiq
module Middleware
module Server
class HarnessInstrumentation
def call(worker_class, item, queue)
if instrument? worker_class
logger.debug "Instrumenting: #{worker_class.inspect}"
options = {}
options[:gauge] = "#{worker_class.class.to_s.underscore}.sidekiq"
options[:counter] = "#{worker_class.class.to_s.pluralize.underscore}.sidekiq"
ActiveSupport::Notifications.instrument "#{worker_class.class.to_s.underscore}.sidekiq", options do
yield
end
ActiveSupport::Notifications.instrument "job.sidekiq", :counter => true
else
logger.debug "Skipped Instrumenting: #{worker_class.inspect}"
yield
end
end
private
def instrument?(worker_class)
if worker_class.is_a? Harness::SidekiqQueue::SendCounter
false
elsif worker_class.is_a? Harness::SidekiqQueue::SendGauge
false
else
worker_class.to_s !~ /^harness/i
end
end
def logger
Sidekiq.logger
end
end
end
end
end
Sidekiq.configure_server do |config|
config.server_middleware do |chain|
chain.add Sidekiq::Middleware::Server::HarnessInstrumentation
end
end
Version data entries
13 entries across 13 versions & 1 rubygems