Module: RRRSpec::PersisterQueue

Defined in:
lib/rrrspec/redis_models.rb

Constant Summary collapse

PERSISTER_QUEUE_KEY = 
'rrrspec:persister_queue'

Class Method Summary collapse

Class Method Details

.dequeue ⇒ Object

Public: Wait for the persistence request.



80
81
82
83
 
# File 'lib/rrrspec/redis_models.rb', line 80

def dequeue
  _, line = RRRSpec.redis.blpop(PERSISTER_QUEUE_KEY, 0)
  Taskset.new(line)
end

.empty? ⇒ Boolean

Returns:

  • (Boolean) 


85
86
87
 
# File 'lib/rrrspec/redis_models.rb', line 85

def empty?
  RRRSpec.redis.llen(PERSISTER_QUEUE_KEY) == 0
end

.enqueue(taskset) ⇒ Object

Public: Request the taskset to be persisted.



75
76
77
 
# File 'lib/rrrspec/redis_models.rb', line 75

def enqueue(taskset)
  RRRSpec.redis.rpush(PERSISTER_QUEUE_KEY, taskset.key)
end