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