Module: Octopusci::StageLocker
- Defined in:
- lib/octopusci/stage_locker.rb
Class Method Summary collapse
- .clear ⇒ Object
- .empty? ⇒ Boolean
- .exists? ⇒ Boolean
- .load(stages) ⇒ Object
- .pool ⇒ Object
- .pop ⇒ Object
- .push(v) ⇒ Object
- .redis ⇒ Object
- .rem(v) ⇒ Object
- .stages ⇒ Object
Class Method Details
.clear ⇒ Object
18 19 20 |
# File 'lib/octopusci/stage_locker.rb', line 18 def self.clear self.redis.del('octopusci:stagelocker') end |
.empty? ⇒ Boolean
14 15 16 |
# File 'lib/octopusci/stage_locker.rb', line 14 def self.empty? !exists? end |
.exists? ⇒ Boolean
10 11 12 |
# File 'lib/octopusci/stage_locker.rb', line 10 def self.exists? self.redis.exists('octopusci:stagelocker') end |
.load(stages) ⇒ Object
5 6 7 8 |
# File 'lib/octopusci/stage_locker.rb', line 5 def self.load(stages) clear stages.each { |s| push(s) } end |
.pool ⇒ Object
38 39 40 41 |
# File 'lib/octopusci/stage_locker.rb', line 38 def self.pool len = self.redis.size('octopusci:stagelocker') self.redis.peek('octopusci:stagelocker', 0, len) end |
.pop ⇒ Object
22 23 24 |
# File 'lib/octopusci/stage_locker.rb', line 22 def self.pop self.redis.lpop('octopusci:stagelocker') end |
.push(v) ⇒ Object
30 31 32 |
# File 'lib/octopusci/stage_locker.rb', line 30 def self.push(v) self.redis.rpush('octopusci:stagelocker', v) end |
.redis ⇒ Object
43 44 45 |
# File 'lib/octopusci/stage_locker.rb', line 43 def self.redis Resque.redis end |
.rem(v) ⇒ Object
26 27 28 |
# File 'lib/octopusci/stage_locker.rb', line 26 def self.rem(v) self.redis.lrem('octopusci:stagelocker', 1, v) end |