class Pliny::Sidekiq::Middleware::Server::Log

Public Class Methods

new(_opts={}) click to toggle source
# File lib/pliny/sidekiq/middleware/server/log.rb, line 4
def initialize(_opts={})
end

Public Instance Methods

call(worker, job, queue) { || ... } click to toggle source
# File lib/pliny/sidekiq/middleware/server/log.rb, line 7
def call(worker, job, queue)
  context = {
    sidekiq: true,
    job:     job['class'],
    job_id:  job['jid'],
  }

  Pliny.context(context) do
    count("worker.#{worker.class.to_s.gsub('::', '.')}")
    count("queue.#{queue}")

    Pliny.log(job: job['class'], job_retry: job['retry']) do
      yield
    end
  end
end

Private Instance Methods

count(key, value=1) click to toggle source
# File lib/pliny/sidekiq/middleware/server/log.rb, line 26
def count(key, value=1)
  Pliny::Metrics.count("sidekiq.#{key}", value: value)
end