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