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