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