Contents

require_relative 'base_probe'

module Roqua
  module Probes
    class DelayedJobProbe
      extend BaseProbe

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

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

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
roqua-support-0.3.0	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.34	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.33	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.32	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.31	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.30	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.29	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.28	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.27	lib/roqua/probes/delayed_job_probe.rb
roqua-support-0.1.26	lib/roqua/probes/delayed_job_probe.rb