Contents

require_relative 'base_probe'

module Roqua
  module Probes
    class DelayedJobProbe
      include BaseProbe

      def backlog_count
        Delayed::Job.where(locked_at: nil).where('run_at < ?', Time.zone.now).count
      end

      def run
        Appsignal.set_gauge('delayed_job_backlog_count', backlog_count)
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
roqua-support-0.4.6	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.4.5	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.4.4	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.4.3	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.4.2	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.4.1	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.4.0	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.3.5	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.3.4	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.3.3	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.3.2	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.3.1	lib/roqua/probes/delayed_job_probe.rb