Module: Octopusci::StageLocker

Defined in:
lib/octopusci/stage_locker.rb

Class Method Summary collapse

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

Returns:

  • (Boolean) 


14
15
16
 
# File 'lib/octopusci/stage_locker.rb', line 14

def self.empty?
  !exists?
end

.exists? ⇒ Boolean

Returns:

  • (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

.stages ⇒ Object 



34
35
36
 
# File 'lib/octopusci/stage_locker.rb', line 34

def self.stages
  Octopusci::Config['stages']
end