Sha256: 81495506f538baa1d7f7b9b574e8a0f5a57165e0fb6cce92b4c3d6c061353c1d

Contents?: true

Size: 434 Bytes

Versions: 6

Compression:

Stored size: 434 Bytes

Contents

module Sidekiq
  module Tracer
    module Commons
      def operation_name(job)
        job['class']
      end

      def tags(job, kind)
        {
          'component' => 'Sidekiq',
          'span.kind' => kind,
          'sidekiq.queue' => job['queue'],
          'sidekiq.jid' => job['jid'],
          'sidekiq.retry' => job['retry'].to_s,
          'sidekiq.args' => job['args'].join(", ")
        }
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 3 rubygems

Version Path
sfx-sidekiq-opentracing-0.0.3 lib/sidekiq/tracer/commons.rb
sfx-sidekiq-opentracing-0.0.2 lib/sidekiq/tracer/commons.rb
sfx-sidekiq-opentracing-0.0.1 lib/sidekiq/tracer/commons.rb
sidekiq-opentracing-dox-fork-1.1.0.doximity2 lib/sidekiq/tracer/commons.rb
sidekiq-opentracing-dox-fork-1.1.0.doximity1 lib/sidekiq/tracer/commons.rb
sidekiq-opentracing-1.0.0 lib/sidekiq/tracer/commons.rb