Class: Wayfarer::Redis::Counter
- Inherits:
-
Object
- Object
- Wayfarer::Redis::Counter
- Includes:
- Resettable
- Defined in:
- lib/wayfarer/redis/counter.rb
Instance Attribute Summary collapse
-
#task ⇒ Object
readonly
Returns the value of attribute task.
Instance Method Summary collapse
- #decrement ⇒ Object
- #increment ⇒ Object
-
#initialize(task, &callback) ⇒ Counter
constructor
A new instance of Counter.
- #redis_key ⇒ Object
- #value ⇒ Object
Methods included from Resettable
Constructor Details
#initialize(task, &callback) ⇒ Counter
Returns a new instance of Counter.
10 11 12 13 14 |
# File 'lib/wayfarer/redis/counter.rb', line 10 def initialize(task, &callback) @task = task @callback = callback @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/counter.rb', line 8 def task @task end |
Instance Method Details
#decrement ⇒ Object
28 29 30 31 32 |
# File 'lib/wayfarer/redis/counter.rb', line 28 def decrement redis_pool.with { |conn| conn.decr(redis_key) }.tap do |val| @callback&.call if val == 0 end end |
#increment ⇒ Object
24 25 26 |
# File 'lib/wayfarer/redis/counter.rb', line 24 def increment redis_pool.with { |conn| conn.incr(redis_key) } end |
#redis_key ⇒ Object
16 17 18 |
# File 'lib/wayfarer/redis/counter.rb', line 16 def redis_key "wayfarer-counter-#{@task.batch}" end |
#value ⇒ Object
20 21 22 |
# File 'lib/wayfarer/redis/counter.rb', line 20 def value redis_pool.with { |conn| conn.get(redis_key) }.to_i end |