Sha256: c196a9b2a30ba5e24b94f6fcf0c7778af3093aeb5d8e38059d69f6e31ac3aed0
Contents?: true
Size: 1.08 KB
Versions: 15
Compression:
Stored size: 1.08 KB
Contents
module Honeybadger
module Plugins
module SolidQueue
Plugin.register :solid_queue do
requirement { config.load_plugin_insights?(:solid_queue) && defined?(::SolidQueue) }
collect do
if config.cluster_collection?(:solid_queue)
metric_source 'solid_queue'
gauge 'jobs_in_progress', ->{ ::SolidQueue::ClaimedExecution.count }
gauge 'jobs_blocked', ->{ ::SolidQueue::BlockedExecution.count }
gauge 'jobs_failed', ->{ ::SolidQueue::FailedExecution.count }
gauge 'jobs_scheduled', ->{ ::SolidQueue::ScheduledExecution.count }
gauge 'jobs_processed', ->{ ::SolidQueue::Job.where.not(finished_at: nil).count }
gauge 'active_workers', ->{ ::SolidQueue::Process.where(kind: "Worker").count }
gauge 'active_dispatchers', ->{ ::SolidQueue::Process.where(kind: "Dispatcher").count }
::SolidQueue::Queue.all.each do |queue|
gauge 'queue_depth', { queue: queue.name }, ->{ queue.size }
end
end
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems