diff options
Diffstat (limited to 'lib/api/sidekiq_metrics.rb')
-rw-r--r-- | lib/api/sidekiq_metrics.rb | 46 |
1 files changed, 23 insertions, 23 deletions
diff --git a/lib/api/sidekiq_metrics.rb b/lib/api/sidekiq_metrics.rb index daa9598a204..a8fd2a01b13 100644 --- a/lib/api/sidekiq_metrics.rb +++ b/lib/api/sidekiq_metrics.rb @@ -1,6 +1,6 @@ # frozen_string_literal: true -require 'sidekiq/api' +require "sidekiq/api" module API class SidekiqMetrics < Grape::API @@ -11,7 +11,7 @@ module API Sidekiq::Queue.all.each_with_object({}) do |queue, hash| hash[queue.name] = { backlog: queue.size, - latency: queue.latency.to_i + latency: queue.latency.to_i, } end end @@ -19,14 +19,14 @@ module API def process_metrics Sidekiq::ProcessSet.new.map do |process| { - hostname: process['hostname'], - pid: process['pid'], - tag: process['tag'], - started_at: Time.at(process['started_at']), - queues: process['queues'], - labels: process['labels'], - concurrency: process['concurrency'], - busy: process['busy'] + hostname: process["hostname"], + pid: process["pid"], + tag: process["tag"], + started_at: Time.at(process["started_at"]), + queues: process["queues"], + labels: process["labels"], + concurrency: process["concurrency"], + busy: process["busy"], } end end @@ -36,29 +36,29 @@ module API { processed: stats.processed, failed: stats.failed, - enqueued: stats.enqueued + enqueued: stats.enqueued, } end end - desc 'Get the Sidekiq queue metrics' - get 'sidekiq/queue_metrics' do - { queues: queue_metrics } + desc "Get the Sidekiq queue metrics" + get "sidekiq/queue_metrics" do + {queues: queue_metrics} end - desc 'Get the Sidekiq process metrics' - get 'sidekiq/process_metrics' do - { processes: process_metrics } + desc "Get the Sidekiq process metrics" + get "sidekiq/process_metrics" do + {processes: process_metrics} end - desc 'Get the Sidekiq job statistics' - get 'sidekiq/job_stats' do - { jobs: job_stats } + desc "Get the Sidekiq job statistics" + get "sidekiq/job_stats" do + {jobs: job_stats} end - desc 'Get the Sidekiq Compound metrics. Includes queue, process, and job statistics' - get 'sidekiq/compound_metrics' do - { queues: queue_metrics, processes: process_metrics, jobs: job_stats } + desc "Get the Sidekiq Compound metrics. Includes queue, process, and job statistics" + get "sidekiq/compound_metrics" do + {queues: queue_metrics, processes: process_metrics, jobs: job_stats} end end end |