Class: Schked::RedisLocker

Inherits:
Object
  • Object
show all
Defined in:
lib/schked/redis_locker.rb

Constant Summary collapse

LOCK_KEY = 
"schked:redis_locker"
LOCK_TTL =

ms

60_000

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(redis_servers, lock_ttl: LOCK_TTL) ⇒ RedisLocker

Returns a new instance of RedisLocker.



12
13
14
15
 
# File 'lib/schked/redis_locker.rb', line 12

def initialize(redis_servers, lock_ttl: LOCK_TTL)
  @lock_manager = Redlock::Client.new(redis_servers, retry_count: 0)
  @lock_ttl = lock_ttl
end

Instance Attribute Details

#lock_id ⇒ Object (readonly)

Returns the value of attribute lock_id.



5
6
7
 
# File 'lib/schked/redis_locker.rb', line 5

def lock_id
  @lock_id
end

#lock_manager ⇒ Object (readonly)

Returns the value of attribute lock_manager.



5
6
7
 
# File 'lib/schked/redis_locker.rb', line 5

def lock_manager
  @lock_manager
end

#lock_ttl ⇒ Object (readonly)

Returns the value of attribute lock_ttl.



5
6
7
 
# File 'lib/schked/redis_locker.rb', line 5

def lock_ttl
  @lock_ttl
end

Instance Method Details

#extend_lock ⇒ Object 



25
26
27
28
29
30
31
 
# File 'lib/schked/redis_locker.rb', line 25

def extend_lock
  return false unless valid_lock?

  @lock_id = lock_manager.lock(LOCK_KEY, lock_ttl, extend: lock_id, extend_only_if_locked: true)

  !!@lock_id
end

#lock ⇒ Object 



17
18
19
 
# File 'lib/schked/redis_locker.rb', line 17

def lock
  valid_lock? || !!try_lock
end

#unlock ⇒ Object 



21
22
23
 
# File 'lib/schked/redis_locker.rb', line 21

def unlock
  lock_manager.unlock(lock_id) if valid_lock?
end

#valid_lock? ⇒ Boolean

Returns:

  • (Boolean) 


33
34
35
36
37
 
# File 'lib/schked/redis_locker.rb', line 33

def valid_lock?
  return false unless lock_id

  lock_manager.valid_lock?(lock_id)
end