Sha256: 9252c10258e78b5a0a3cd16d711e95ad027738e965573338dae9a027206e9dae
Contents?: true
Size: 765 Bytes
Versions: 21
Compression:
Stored size: 765 Bytes
Contents
# frozen_string_literal: true module PrometheusExporter::Instrumentation class Shoryuken def initialize(client: nil) @client = client || PrometheusExporter::Client.default end def call(worker, queue, msg, body) success = false start = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC) result = yield success = true result rescue ::Shoryuken::Shutdown => e shutdown = true raise e ensure duration = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC) - start @client.send_json( type: "shoryuken", queue: queue, name: worker.class.name, success: success, shutdown: shutdown, duration: duration ) end end end
Version data entries
21 entries across 21 versions & 1 rubygems