Contents

require 'skylight'

module Sidekiq
  module Skylight
    class ServerMiddleware
      def call(worker, job, _queue)
        name = expand_worker_name(worker, job)
        if config.blacklisted_workers.include?(name)
          yield
        else
          ::Skylight.trace("#{name}#perform", 'app.sidekiq.worker', 'process', &Proc.new)
        end
      end

      def config
        Sidekiq::Skylight.config
      end

      private

      def expand_worker_name(worker, job)
        job['wrapped'] || worker.class.name
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-skylight-0.2.0	lib/sidekiq/skylight/server_middleware.rb