class OpenTelemetry::Adapters::Sidekiq::Middlewares::Server::TracerMiddleware
Public Instance Methods
call(_worker, msg, _queue) { || ... }
click to toggle source
# File lib/opentelemetry/adapters/sidekiq/middlewares/server/tracer_middleware.rb, line 13 def call(_worker, msg, _queue) parent_context = OpenTelemetry.propagation.text.extract(msg) tracer.in_span( msg['wrapped']&.to_s || msg['class'], attributes: { 'messaging.message_id' => msg['jid'], 'messaging.destination' => msg['queue'], }, with_parent_context: parent_context, kind: :consumer ) do |span| span.add_event(name: 'created_at', timestamp: msg['created_at']) span.add_event(name: 'enqueued_at', timestamp: msg['enqueued_at']) yield end end
Private Instance Methods
tracer()
click to toggle source
# File lib/opentelemetry/adapters/sidekiq/middlewares/server/tracer_middleware.rb, line 32 def tracer Sidekiq::Adapter.instance.tracer end