Sha256: a8a176868e995fe146d99b62979d978b5af17269c1d49f8dfb470c492e866733

Contents?: true

Size: 1.07 KB

Versions: 33

Compression:

Stored size: 1.07 KB

Contents

# frozen_string_literal: true

module Labkit
  module Middleware
    module Sidekiq
      module Tracing
        # SidekiqCommon is a mixin for the sidekiq middleware components
        module SidekiqCommon
          def job_class(job)
            # Active Job wrapping can be found at
            # https://github.com/rails/rails/blob/v6.0.3.1/activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb
            job["wrapped"].presence || job["class"].presence || "undefined"
          end

          def wrapped?(job)
            job["wrapped"].present?
          end

          def tags_from_job(job, kind)
            tags = {
              "component" => "sidekiq",
              "span.kind" => kind,
              "sidekiq.wrapped" => wrapped?(job),
              "sidekiq.queue" => job["queue"],
              "sidekiq.jid" => job["jid"],
              "sidekiq.retry" => job["retry"].to_s,
              "sidekiq.args" => job["args"]&.join(", "),
            }
            tags["sidekiq.at"] = job["at"] if job["at"]
            tags
          end
        end
      end
    end
  end
end

Version data entries

33 entries across 33 versions & 1 rubygems

Version Path
gitlab-labkit-0.37.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.36.1 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.36.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.35.1 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.35.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.34.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.33.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.32.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.31.1 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.31.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.30.1 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.30.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.29.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.28.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.27.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.26.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.25.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.24.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.23.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb
gitlab-labkit-0.22.0 lib/labkit/middleware/sidekiq/tracing/sidekiq_common.rb