class AtomicSidekiq::InFlightKeymaker
Attributes
key_prefix[R]
Public Class Methods
new(key_prefix)
click to toggle source
# File lib/atomic_sidekiq/in_flight_keymaker.rb, line 3 def initialize(key_prefix) @key_prefix = key_prefix end
Public Instance Methods
job_key(job)
click to toggle source
# File lib/atomic_sidekiq/in_flight_keymaker.rb, line 20 def job_key(job) obj = job obj = JSON.parse(obj) if job.is_a?(String) "#{key_prefix}:#{obj['queue']}:#{obj['jid']}" end
job_matcher(jid)
click to toggle source
# File lib/atomic_sidekiq/in_flight_keymaker.rb, line 26 def job_matcher(jid) "#{key_prefix}:*:#{jid}" end
matcher()
click to toggle source
# File lib/atomic_sidekiq/in_flight_keymaker.rb, line 7 def matcher "#{key_prefix}:*" end
queue_matcher(queue)
click to toggle source
# File lib/atomic_sidekiq/in_flight_keymaker.rb, line 16 def queue_matcher(queue) "#{queue_prefix(queue)}*" end
queue_prefix(queue)
click to toggle source
# File lib/atomic_sidekiq/in_flight_keymaker.rb, line 11 def queue_prefix(queue) normalized_name = queue.gsub(/queue:/, "") "#{key_prefix}:#{normalized_name}:" end