Sha256: 255d2828a2a57f6d515eb1c7725fb73e3090d1ea2befe9b35f4bfbde36a7600c
Contents?: true
Size: 1.82 KB
Versions: 28
Compression:
Stored size: 1.82 KB
Contents
# frozen_string_literal: true
module ElasticAPM
# @api private
module Spies
# @api private
class DelayedJobSpy
CLASS_SEPARATOR = '.'
METHOD_SEPARATOR = '#'
TYPE = 'Delayed::Job'
def install
::Delayed::Backend::Base.class_eval do
alias invoke_job_without_apm invoke_job
def invoke_job(*args, &block)
::ElasticAPM::Spies::DelayedJobSpy
.invoke_job(self, *args, &block)
end
end
end
def self.invoke_job(job, *args, &block)
job_name = name_from_payload(job.payload_object)
transaction = ElasticAPM.start_transaction(job_name, TYPE)
job.invoke_job_without_apm(*args, &block)
transaction.done 'success'
rescue ::Exception => e
ElasticAPM.report(e, handled: false)
transaction.done 'error'
raise
ensure
ElasticAPM.end_transaction
end
def self.name_from_payload(payload_object)
if payload_object.is_a?(::Delayed::PerformableMethod)
performable_method_name(payload_object)
else
payload_object.class.name
end
end
def self.performable_method_name(payload_object)
class_name = object_name(payload_object)
separator = name_separator(payload_object)
method_name = payload_object.method_name
"#{class_name}#{separator}#{method_name}"
end
def self.object_name(payload_object)
object = payload_object.object
klass = object.is_a?(Class) ? object : object.class
klass.name
end
def self.name_separator(payload_object)
payload_object.object.is_a?(Class) ? CLASS_SEPARATOR : METHOD_SEPARATOR
end
end
register(
'Delayed::Backend::Base',
'delayed/backend/base',
DelayedJobSpy.new
)
end
end
Version data entries
28 entries across 28 versions & 1 rubygems