Contents

require 'singleton'

module DynoscaleRuby
  module Worker
    class Resque
      include Singleton

      def self.enabled?
        return false if ENV['SKIP_DYNOSCALE_AGENT']

        require 'resque'
        require 'resque_latency'
        true
      rescue LoadError
        false
      end

      def self.queue_latencies
        queues.map do |queue|
          [queue.name, (::Resque.latency(queue)* 1000).ceil, ::Resque.size(queue)]
      	end
      end

      def self.queues(source = ::Resque.queues)
        @@queues ||= source
      end

      def self.name
         'resque'
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
dynoscale_ruby-1.0.3	lib/dynoscale_ruby/worker/resque.rb