delayed_jobs_ready metric added to DelayedJob plugin

Author: benngarcia

README.md

@@ -538,6 +538,7 @@ end
 | Counter | `delayed_jobs_total`                      | Total number of delayed jobs executed                              | `job_name` |
 | Gauge   | `delayed_jobs_enqueued`                   | Number of enqueued delayed jobs                                    | -          |
 | Gauge   | `delayed_jobs_pending`                    | Number of pending delayed jobs                                     | -          |
+| Gauge   | `delayed_jobs_ready`                      | Number of ready delayed jobs                                       | -          |
 | Counter | `delayed_failed_jobs_total`               | Total number failed delayed jobs executed                          | `job_name` |
 | Counter | `delayed_jobs_max_attempts_reached_total` | Total number of delayed jobs that reached max attempts             | -          |
 | Summary | `delayed_job_duration_seconds_summary`    | Summary of the time it takes jobs to execute                       | `status`   |
@@ -884,7 +885,7 @@ prometheus_exporter -p 8080 \
                     --prefix 'foo_'
 ```
 
-You can use `-b` option to bind the `prometheus_exporter` web server to any IPv4 interface with `-b 0.0.0.0`, 
+You can use `-b` option to bind the `prometheus_exporter` web server to any IPv4 interface with `-b 0.0.0.0`,
 any IPv6 interface with `-b ::`, or `-b ANY` to any IPv4/IPv6 interfaces available on your host system.
 
 #### Enabling Basic Authentication

lib/prometheus_exporter/instrumentation/delayed_job.rb

@@ -4,6 +4,8 @@ module PrometheusExporter::Instrumentation
   class DelayedJob
     JOB_CLASS_REGEXP = %r{job_class: (\w+:{0,2})+}.freeze
 
+    RuntimeMetric = Struct.new(:max_attempts, :enqueued_count, :pending_count, :ready_count)
+
     class << self
       def register_plugin(client: nil)
         instrumenter = self.new(client: client)
@@ -15,7 +17,8 @@ def register_plugin(client: nil)
               max_attempts = Delayed::Worker.max_attempts
               enqueued_count = Delayed::Job.where(queue: job.queue).count
               pending_count = Delayed::Job.where(attempts: 0, locked_at: nil, queue: job.queue).count
-              instrumenter.call(job, max_attempts, enqueued_count, pending_count, *args, &block)
+              ready_count = Delayed::Job.where(queue: job.queue, run_at: ..Time.current).count
+              instrumenter.call(job, max_attempts, enqueued_count, pending_count, ready_count, *args, &block)
             end
           end
         end
@@ -28,7 +31,7 @@ def initialize(client: nil)
       @client = client || PrometheusExporter::Client.default
     end
 
-    def call(job, max_attempts, enqueued_count, pending_count, *args, &block)
+    def call(job, max_attempts, enqueued_count, pending_count, ready_count, *args, &block)
       success = false
       start = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC)
       latency = Time.current - job.run_at
@@ -49,7 +52,8 @@ def call(job, max_attempts, enqueued_count, pending_count, *args, &block)
         attempts: attempts,
         max_attempts: max_attempts,
         enqueued: enqueued_count,
-        pending: pending_count
+        pending: pending_count,
+        ready_count: ready_count
       )
     end
   end

lib/prometheus_exporter/server/delayed_job_collector.rb

@@ -13,6 +13,7 @@ def initialize
       @delayed_job_attempts_summary = nil
       @delayed_jobs_enqueued = nil
       @delayed_jobs_pending = nil
+      @delayed_jobs_ready = nil
     end
 
     def type
@@ -36,6 +37,7 @@ def collect(obj)
       @delayed_job_attempts_summary.observe(obj["attempts"], counter_labels) if obj["success"]
       @delayed_jobs_enqueued.observe(obj["enqueued"], gauge_labels)
       @delayed_jobs_pending.observe(obj["pending"], gauge_labels)
+      @delayed_jobs_ready.observe(obj["ready"], gauge_labels)
     end
 
     def metrics
@@ -73,6 +75,11 @@ def ensure_delayed_job_metrics
         PrometheusExporter::Metric::Gauge.new(
           "delayed_jobs_pending", "Number of pending delayed jobs.")
 
+        @delayed_jobs_ready =
+        PrometheusExporter::Metric::Gauge.new(
+          "delayed_jobs_ready", "Number of ready delayed jobs."
+        )
+
         @delayed_failed_jobs_total =
         PrometheusExporter::Metric::Counter.new(
           "delayed_failed_jobs_total", "Total number failed delayed jobs executed.")