summaryrefslogtreecommitdiff
path: root/lib/api/sidekiq_metrics.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/api/sidekiq_metrics.rb')
-rw-r--r--lib/api/sidekiq_metrics.rb46
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