Class: Lowkiq::Queue::Keys

Inherits:
Object
  • Object
show all
Defined in:
lib/lowkiq/queue/keys.rb

Constant Summary collapse

PREFIX = 
'lowkiq:A:v1'.freeze

Instance Method Summary collapse

Constructor Details

#initialize(name) ⇒ Keys

Returns a new instance of Keys.



6
7
8
 
# File 'lib/lowkiq/queue/keys.rb', line 6

def initialize(name)
  @prefix = [PREFIX, name].join(':').freeze
end

Instance Method Details

#all_ids_lex_zset ⇒ Object 



18
19
20
 
# 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 ⇒ Object 



22
23
24
 
# 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 ⇒ Object 



26
27
28
 
# 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 ⇒ Object 



38
39
40
 
# File 'lib/lowkiq/queue/keys.rb', line 38

def errors_hash
  [@prefix, :errors].join(':')
end

#failed_key ⇒ Object 



14
15
16
 
# File 'lib/lowkiq/queue/keys.rb', line 14

def failed_key
  [@prefix, :failed].join(':')
end

#ids_scored_by_perform_in_zset(shard) ⇒ Object 



30
31
32
 
# 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 ⇒ Object 



62
63
64
 
# 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 ⇒ Object 



66
67
68
 
# 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 ⇒ Object 



74
75
76
 
# File 'lib/lowkiq/queue/keys.rb', line 74

def morgue_errors_hash
  [@prefix, :morgue, :errors].join(':')
end

#morgue_payloads_zset(id) ⇒ Object 



70
71
72
 
# File 'lib/lowkiq/queue/keys.rb', line 70

def morgue_payloads_zset(id)
  [@prefix, :morgue, :payloads, id].join(':')
end

#payloads_zset(id) ⇒ Object 



34
35
36
 
# File 'lib/lowkiq/queue/keys.rb', line 34

def payloads_zset(id)
  [@prefix, :payloads, id].join(':')
end

#processed_key ⇒ Object 



10
11
12
 
# File 'lib/lowkiq/queue/keys.rb', line 10

def processed_key
  [@prefix, :processed].join(':')
end

#processing_errors_hash(shard) ⇒ Object 



58
59
60
 
# 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) ⇒ Object 



46
47
48
 
# 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) ⇒ Object 



50
51
52
 
# 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 ⇒ Object 



42
43
44
 
# 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) ⇒ Object 



54
55
56
 
# File 'lib/lowkiq/queue/keys.rb', line 54

def processing_payloads_zset(id)
  [@prefix, :processing, :payloads, id].join(':')
end