class Yabeda::Faktory::ClientMiddleware
Client middleware to count number of enqueued jobs
Public Instance Methods
call(payload, _connection_pool) { || ... }
click to toggle source
# File lib/yabeda/faktory/client_middleware.rb, line 7 def call(payload, _connection_pool) success = true start = Process.clock_gettime(Process::CLOCK_MONOTONIC) yield rescue Exception # rubocop: disable Lint/RescueException success = false raise ensure elapsed = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start labels = { success: success }.merge(Yabeda::Faktory.labelize(payload)) Yabeda.faktory.jobs_enqueued_total.increment(labels) Yabeda.faktory.job_enqueue_runtime.measure(labels, elapsed.round(3)) end