Module: Resque::Plugins::MultiStepTask::AtomicCounters

Included in:
Resque::Plugins::MultiStepTask
Defined in:
lib/resque/plugins/multi_step_task/atomic_counters.rb

Instance Method Summary collapse

Instance Method Details

#counter(name) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/resque/plugins/multi_step_task/atomic_counters.rb', line 5

def counter(name)
  class_eval <<-INCR
    def increment_#{name}
      redis.incrby('#{name}', 1)
      logger.info("[Resque Multi-Step-Task] Incremented #{name}")
    end
    INCR

  class_eval <<-GETTER
    def #{name}
      redis.get('#{name}').to_i
    end
    GETTER
end