class ResqueToCloudwatch::WorkersWorkingCollector
Public Class Methods
new(config)
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 27 def initialize(config) @config = config end
Public Instance Methods
get_value()
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 31 def get_value redis = Redis.new(:host => @config.redis_host, :port => @config.redis_port) redis.smembers('resque:workers').select do |worker_key| redis.exists("resque:worker:#{worker_key}") end.length end
metric_name()
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 38 def metric_name "resque_workers_working" end
to_s()
click to toggle source
# File lib/resque_to_cloudwatch/collectors.rb, line 42 def to_s metric_name end