Class: Labkit::Tracing::Sidekiq::ServerMiddleware

Inherits:
Object
  • Object
show all
Includes:
SidekiqCommon
Defined in:
lib/labkit/tracing/sidekiq/server_middleware.rb

Overview

ServerMiddleware provides a sidekiq server middleware for instrumenting distributed tracing calls when they are executed by the Sidekiq server

Constant Summary collapse

SPAN_KIND = 
"server"

Instance Method Summary collapse

Methods included from SidekiqCommon

#tags_from_job

Instance Method Details

#call(_worker, job, _queue) ⇒ Object 



16
17
18
19
20
 
# File 'lib/labkit/tracing/sidekiq/server_middleware.rb', line 16

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

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