class ActiveJob::Locking::Adapters::SuoRedis
Public Instance Methods
create_lock_manager()
click to toggle source
# File lib/activejob/locking/adapters/suo-redis.rb, line 7 def create_lock_manager mapped_options = {connection: {host: self.options.hosts.first}, stale_lock_expiration: self.options.lock_time, acquisition_timeout: self.options.lock_acquire_time} Suo::Client::Redis.new(self.key, mapped_options) end
lock()
click to toggle source
# File lib/activejob/locking/adapters/suo-redis.rb, line 15 def lock self.lock_token = self.lock_manager.lock end
unlock()
click to toggle source
# File lib/activejob/locking/adapters/suo-redis.rb, line 19 def unlock self.lock_manager.unlock(self.lock_token) end