module ActiveJob::Locks::Callbacks
Private Instance Methods
lock_resource(payload)
click to toggle source
# File lib/active_job/locks/callbacks.rb, line 20 def lock_resource(payload) [queue_name, payload_key(payload)].join(":") end
payload_key(payload)
click to toggle source
# File lib/active_job/locks/callbacks.rb, line 13 def payload_key(payload) return nil unless payload_lock payload.flat_map do |argument| argument.respond_to?(:to_global_id) ? argument.to_global_id.uri.to_s : argument.to_s end end
redis_lock()
click to toggle source
# File lib/active_job/locks/callbacks.rb, line 9 def redis_lock @redis_lock ||= Redlock::Client.new(redis) end