class Lowkiq::Queue::Keys

Constants

PREFIX

Public Class Methods

new(name) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 6
def initialize(name)
  @prefix = [PREFIX, name].join(':').freeze
end

Public Instance Methods

all_ids_lex_zset() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 18
def all_ids_lex_zset
  [@prefix, :all_ids_lex].join(':')
end
all_ids_scored_by_perform_in_zset() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 22
def all_ids_scored_by_perform_in_zset
  [@prefix, :all_ids_scored_by_perfrom_in].join(':')
end
all_ids_scored_by_retry_count_zset() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 26
def all_ids_scored_by_retry_count_zset
  [@prefix, :all_ids_scored_by_retry_count].join(':')
end
errors_hash() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 38
def errors_hash
  [@prefix, :errors].join(':')
end
failed_key() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 14
def failed_key
  [@prefix, :failed].join(':')
end
ids_scored_by_perform_in_zset(shard) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 30
def ids_scored_by_perform_in_zset(shard)
  [@prefix, :ids_scored_by_perform_in, shard].join(':')
end
morgue_all_ids_lex_zset() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 62
def morgue_all_ids_lex_zset
  [@prefix, :morgue, :all_ids_lex].join(':')
end
morgue_all_ids_scored_by_updated_at_zset() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 66
def morgue_all_ids_scored_by_updated_at_zset
  [@prefix, :morgue, :all_ids_scored_by_updated_at].join(':')
end
morgue_errors_hash() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 74
def morgue_errors_hash
  [@prefix, :morgue, :errors].join(':')
end
morgue_payloads_zset(id) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 70
def morgue_payloads_zset(id)
  [@prefix, :morgue, :payloads, id].join(':')
end
payloads_zset(id) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 34
def payloads_zset(id)
  [@prefix, :payloads, id].join(':')
end
processed_key() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 10
def processed_key
  [@prefix, :processed].join(':')
end
processing_errors_hash(shard) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 58
def processing_errors_hash(shard)
  [@prefix, :processing, :errors, shard].join(':')
end
processing_ids_with_perform_in_hash(shard) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 46
def processing_ids_with_perform_in_hash(shard)
  [@prefix, :processing, :ids_with_perform_in, shard].join(':')
end
processing_ids_with_retry_count_hash(shard) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 50
def processing_ids_with_retry_count_hash(shard)
  [@prefix, :processing, :ids_with_retry_count, shard].join(':')
end
processing_length_by_shard_hash() click to toggle source
# File lib/lowkiq/queue/keys.rb, line 42
def processing_length_by_shard_hash
  [@prefix, :processing_length_by_shard].join(':')
end
processing_payloads_zset(id) click to toggle source
# File lib/lowkiq/queue/keys.rb, line 54
def processing_payloads_zset(id)
  [@prefix, :processing, :payloads, id].join(':')
end