Class: AppPerfRpm::SidekiqServer

Inherits:
Object
  • Object
show all
Defined in:
lib/app_perf_rpm/instruments/sidekiq.rb

Instance Method Summary collapse

Instance Method Details

#call(*args) ⇒ Object



3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
# File 'lib/app_perf_rpm/instruments/sidekiq.rb', line 3

def call(*args)
  worker, msg, queue = args

  result = AppPerfRpm::Tracer.start_trace("sidekiq-worker") do |span|
    span.type = "job"
    span.controller = "Sidekiq_#{queue}"
    span.action = msg["wrapped"]
    span.url = "/sidekiq/#{queue}/#{msg['wrapped']}"
    span.domain = Socket.gethostname
    span.options = {
      "job_name" => worker.class.to_s,
      "queue" => queue
    }

    yield
  end

  result
end