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 |