Sha256: af48dca7af87c88adc29c5f90fb38d95e0994061ec19d6ef9045b3b7c067280b
Contents?: true
Size: 1.07 KB
Versions: 7
Compression:
Stored size: 1.07 KB
Contents
# frozen_string_literal: true
module PrometheusExporter::Instrumentation
class Sidekiq
def self.death_handler
-> (job, ex) do
PrometheusExporter::Client.default.send_json(
type: "sidekiq",
name: job["class"],
dead: true,
)
end
end
def initialize(client: nil)
@client = client || PrometheusExporter::Client.default
end
def call(worker, msg, queue)
success = false
shutdown = false
start = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC)
result = yield
success = true
result
rescue ::Sidekiq::Shutdown => e
shutdown = true
raise e
ensure
duration = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC) - start
class_name = worker.class.to_s == 'ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper' ?
msg['wrapped'] : worker.class.to_s
@client.send_json(
type: "sidekiq",
name: class_name,
success: success,
shutdown: shutdown,
duration: duration
)
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems