module RRRSpec::StatisticsUpdaterQueue
Constants
- STATISTICS_UPDATER_QUEUE_KEY
Public Instance Methods
dequeue()
click to toggle source
Public: Wait for the update request.
# File lib/rrrspec/redis_models.rb, line 102 def dequeue _, line = RRRSpec.redis.blpop(STATISTICS_UPDATER_QUEUE_KEY, 0) request = JSON.parse(line) [Taskset.new(request['taskset']), request['recalculate']] end
empty?()
click to toggle source
# File lib/rrrspec/redis_models.rb, line 109 def empty? RRRSpec.redis.llen(STATISTICS_UPDATER_QUEUE_KEY) == 0 end
enqueue(taskset, recalculate = false)
click to toggle source
Public: Request the taskset to be added to statistics.
# File lib/rrrspec/redis_models.rb, line 96 def enqueue(taskset, recalculate = false) RRRSpec.redis.rpush(STATISTICS_UPDATER_QUEUE_KEY, {taskset: taskset.key, recalculate: recalculate}.to_json) end