class ResqueToCloudwatch::WorkRemainingCollector
Public Class Methods
new(config)
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 71 def initialize(config) @config = config end
Public Instance Methods
get_value()
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 75 def get_value redis = Redis.new(:host => @config.redis_host, :port => @config.redis_port) working = redis.smembers('resque:workers').select do |worker_key| redis.exists("resque:worker:#{worker_key}") end.length queue_length = redis.smembers('resque:queues').map do |queue_key| redis.llen("resque:queue:#{queue_key}") end.reduce(:+) working + queue_length end
metric_name()
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 86 def metric_name "resque_work_remaining" end
to_s()
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 90 def to_s metric_name end