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