Class: Wayfarer::Redis::Barrier
- Inherits:
-
Object
- Object
- Wayfarer::Redis::Barrier
- Includes:
- Resettable
- Defined in:
- lib/wayfarer/redis/barrier.rb
Instance Attribute Summary collapse
-
#task ⇒ Object
readonly
Returns the value of attribute task.
Instance Method Summary collapse
- #check!(url) ⇒ Object
-
#initialize(task) ⇒ Barrier
constructor
A new instance of Barrier.
- #redis_key ⇒ Object
Methods included from Resettable
Constructor Details
#initialize(task) ⇒ Barrier
Returns a new instance of Barrier.
10 11 12 13 |
# File 'lib/wayfarer/redis/barrier.rb', line 10 def initialize(task) @task = task @redis_pool = task[:redis_pool] end |
Instance Attribute Details
#task ⇒ Object (readonly)
Returns the value of attribute task.
8 9 10 |
# File 'lib/wayfarer/redis/barrier.rb', line 8 def task @task end |
Instance Method Details
#check!(url) ⇒ Object
19 20 21 |
# File 'lib/wayfarer/redis/barrier.rb', line 19 def check!(url) !redis_pool.with { |conn| conn.hsetnx(redis_key, url, "") } end |
#redis_key ⇒ Object
15 16 17 |
# File 'lib/wayfarer/redis/barrier.rb', line 15 def redis_key "wayfarer-barrier-#{task.batch}" end |