# File lib/resque/data_store.rb, line 186 def initialize(redis) @redis = redis end
# File lib/resque/data_store.rb, line 190 def add_failed_queue(failed_queue_name) @redis.sadd(:failed_queues, failed_queue_name) end
# File lib/resque/data_store.rb, line 214 def clear_failed_queue(failed_queue_name=:failed) @redis.del(failed_queue_name) end
# File lib/resque/data_store.rb, line 202 def failed_queue_names(find_queue_names_in_key=nil) if find_queue_names_in_key.nil? [:failed] else Array(@redis.smembers(find_queue_names_in_key)) end end
# File lib/resque/data_store.rb, line 198 def num_failed(failed_queue_name=:failed) @redis.llen(failed_queue_name).to_i end
# File lib/resque/data_store.rb, line 210 def push_to_failed_queue(data,failed_queue_name=:failed) @redis.rpush(failed_queue_name,data) end
# File lib/resque/data_store.rb, line 194 def remove_failed_queue(failed_queue_name=:failed) @redis.del(failed_queue_name) end
# File lib/resque/data_store.rb, line 222 def remove_from_failed_queue(index_in_failed_queue,failed_queue_name=nil) failed_queue_name ||= :failed hopefully_unique_value_we_can_use_to_delete_job = "" @redis.lset(failed_queue_name, index_in_failed_queue, hopefully_unique_value_we_can_use_to_delete_job) @redis.lrem(failed_queue_name, 1, hopefully_unique_value_we_can_use_to_delete_job) end
# File lib/resque/data_store.rb, line 218 def update_item_in_failed_queue(index_in_failed_queue,new_item_data,failed_queue_name=:failed) @redis.lset(failed_queue_name, index_in_failed_queue, new_item_data) end