Sha256: 21b89b71539c98ae5540c79db77f61d1a3f9d92dabc00ca087a22971ae2a7d5c
Contents?: true
Size: 1.15 KB
Versions: 10
Compression:
Stored size: 1.15 KB
Contents
require 'redlock'
module Hyrax
class LockManager
class UnableToAcquireLockError < StandardError; end
attr_reader :client
# @param [Fixnum] time_to_live How long to hold the lock in milliseconds
# @param [Fixnum] retry_count How many times to retry to acquire the lock before raising UnableToAcquireLockError
# @param [Fixnum] retry_delay Maximum wait time in milliseconds before retrying. Wait time is a random value between 0 and retry_delay.
def initialize(time_to_live, retry_count, retry_delay)
@ttl = time_to_live
@client = Redlock::Client.new([uri], retry_count: retry_count, retry_delay: retry_delay)
end
# Blocks until lock is acquired or timeout.
def lock(key)
returned_from_block = nil
client.lock(key, @ttl) do |locked|
raise UnableToAcquireLockError unless locked
returned_from_block = yield
end
returned_from_block
end
private
def uri
@uri ||= begin
opts = options
URI("#{opts[:scheme]}://#{opts[:host]}:#{opts[:port]}").to_s
end
end
def options
::Redis.current.client.options
end
end
end
Version data entries
10 entries across 10 versions & 2 rubygems