Contents

module Sidekiq
  module Tracer
    class ClientMiddleware
      def call(_worker_class, job, _queue, _redis_pool)
        job["root_trace"] = root_trace
        yield
      end

      private

      def root_trace
        if Thread.current[:sidekiq_root_trace] &&
            Thread.current[:sidekiq_root_trace].last
          return Thread.current[:sidekiq_root_trace].last
        end
        SecureRandom.uuid
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sidekiq-tracer-0.1.4	lib/sidekiq/tracer/client_middleware.rb
sidekiq-tracer-0.1.3	lib/sidekiq/tracer/client_middleware.rb
sidekiq-tracer-0.1.2	lib/sidekiq/tracer/client_middleware.rb
sidekiq-tracer-0.1.1	lib/sidekiq/tracer/client_middleware.rb
sidekiq-tracer-0.1.0	lib/sidekiq/tracer/client_middleware.rb