Sha256: 8552be32edb7a48936d89804394aaa8a9c6644bccae400196845cb43471a155f
Contents?: true
Size: 438 Bytes
Versions: 69
Compression:
Stored size: 438 Bytes
Contents
require "resque"
redis_server = Rubber.instances.for_role('redis_master').first.full_name rescue nil
redis_server ||= 'localhost' if Rubber.env == 'development'
Resque.redis = "#{redis_server}:6379"
queue_sizes = {}
Resque.redis.smembers("queues").each do |queue_name|
queue_size = Resque.redis.llen("queue:#{queue_name}")
puts "PUTVAL #{HOSTNAME}/resque_worker/gauge-#{queue_name}_queued interval=#{INTERVAL} N:#{queue_size}"
end
Version data entries
69 entries across 69 versions & 1 rubygems