class TingYun::SidekiqInstrumentation

Public Class Methods

default_trace_args(msg) click to toggle source
# File lib/ting_yun/instrumentation/sidekiq.rb, line 33
def self.default_trace_args(msg)
  {
      :name => 'perform',
      :class_name => msg['class'],
      :category => 'TaskAction/Sidekiq'
  }
end

Public Instance Methods

call(worker_instance, msg, queue, *_) { || ... } click to toggle source
# File lib/ting_yun/instrumentation/sidekiq.rb, line 21
def call(worker_instance, msg, queue, *_)
  trace_args = if worker_instance.respond_to?(:tingyun_trace_args)
                 worker_instance.tingyun_trace_args(msg, queue)
               else
                 self.class.default_trace_args(msg)
               end
  perform_action_with_tingyun_trace(trace_args) do
    TingYun::Agent.add_custom_params(:job_arguments, msg['args'])
    yield
  end
end