class Resque::DataStore::FailedQueueAccess
Public Class Methods
new(redis)
click to toggle source
# File lib/resque/data_store.rb, line 170 def initialize(redis) @redis = redis end
Public Instance Methods
add_failed_queue(failed_queue_name)
click to toggle source
# File lib/resque/data_store.rb, line 174 def add_failed_queue(failed_queue_name) @redis.sadd(:failed_queues, failed_queue_name) end
clear_failed_queue(failed_queue_name=:failed)
click to toggle source
# File lib/resque/data_store.rb, line 198 def clear_failed_queue(failed_queue_name=:failed) @redis.del(failed_queue_name) end
failed_queue_names(find_queue_names_in_key=nil)
click to toggle source
# File lib/resque/data_store.rb, line 186 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
num_failed(failed_queue_name=:failed)
click to toggle source
# File lib/resque/data_store.rb, line 182 def num_failed(failed_queue_name=:failed) @redis.llen(failed_queue_name).to_i end
push_to_failed_queue(data,failed_queue_name=:failed)
click to toggle source
# File lib/resque/data_store.rb, line 194 def push_to_failed_queue(data,failed_queue_name=:failed) @redis.rpush(failed_queue_name,data) end
remove_failed_queue(failed_queue_name=:failed)
click to toggle source
# File lib/resque/data_store.rb, line 178 def remove_failed_queue(failed_queue_name=:failed) @redis.del(failed_queue_name) end
remove_from_failed_queue(index_in_failed_queue,failed_queue_name=nil)
click to toggle source
# File lib/resque/data_store.rb, line 206 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
update_item_in_failed_queue(index_in_failed_queue,new_item_data,failed_queue_name=:failed)
click to toggle source
# File lib/resque/data_store.rb, line 202 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