Contents

# frozen_string_literal: true

require "opentracing"

module Labkit
  module Tracing
    module Sidekiq
      # ServerMiddleware provides a sidekiq server middleware for
      # instrumenting distributed tracing calls when they are
      # executed by the Sidekiq server
      class ServerMiddleware
        include SidekiqCommon

        SPAN_KIND = "server"

        def call(_worker, job, _queue)
          context = tracer.extract(OpenTracing::FORMAT_TEXT_MAP, job)

          in_tracing_span(operation_name: "sidekiq:#{job["class"]}", child_of: context, tags: tags_from_job(job, SPAN_KIND)) { |_span| yield }
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
gitlab-labkit-0.1.2	lib/labkit/tracing/sidekiq/server_middleware.rb
gitlab-labkit-0.1.0.pre.1.pre.gcb57c95	lib/labkit/tracing/sidekiq/server_middleware.rb
gitlab-labkit-0.1.0	lib/labkit/tracing/sidekiq/server_middleware.rb