class Sidekiq::Instrumental::Middleware::Server

Server side sidekiq middleware

Protected Instance Methods

submit_general_stats(stats) click to toggle source
# File lib/sidekiq/instrumental/middleware/server.rb, line 27
def submit_general_stats(stats)
  increment('sidekiq.processed')
  {
    enqueued: nil,
    failed: nil,
    scheduled_size: 'scheduled'
  }.each do |method, name|
    gauge("sidekiq.#{(name || method)}", stats.send(method).to_i)
  end
end
track(stats, worker_instance, msg, queue, elapsed) click to toggle source
# File lib/sidekiq/instrumental/middleware/server.rb, line 10
def track(stats, worker_instance, msg, queue, elapsed)
  submit_general_stats(stats)

  return unless config.allowed_to_submit queue, worker_instance

  base_key = "sidekiq.#{queue}."

  increment(base_key + 'processed')
  gauge(base_key + 'time', elapsed)
  gauge(base_key + 'enqueued', stats.queues[queue].to_i)
  gauge(base_key + 'latency', Sidekiq::Queue.new(queue.to_s).latency)
  base_key += build_class_key(msg.display_class) + '.'

  increment(base_key + 'processed')
  gauge(base_key + 'time', elapsed)
end