Sha256: 0f49dd60f2c6c0d42d6455ee247f00ad768d39582dd668199e2f289673a3ed6b

Contents?: true

Size: 563 Bytes

Versions: 2

Compression:

Stored size: 563 Bytes

Contents

require 'singleton'

module DynoscaleRuby
  module Worker
    class Resque
      include Singleton

      def self.enabled?
        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

2 entries across 2 versions & 1 rubygems

Version Path
dynoscale_ruby-1.0.2 lib/dynoscale_ruby/worker/resque.rb
dynoscale_ruby-1.0.1 lib/dynoscale_ruby/worker/resque.rb