Module: RRRSpec::PersisterQueue
- Defined in:
- lib/rrrspec/redis_models.rb
Constant Summary collapse
- PERSISTER_QUEUE_KEY =
'rrrspec:persister_queue'
Class Method Summary collapse
-
.dequeue ⇒ Object
Public: Wait for the persistence request.
- .empty? ⇒ Boolean
-
.enqueue(taskset) ⇒ Object
Public: Request the taskset to be persisted.
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
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 |