Packages

verk

1.5.0
1.7.3 1.7.2 1.7.1 1.7.0 1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.5.0 1.4.1 1.4.0 1.3.0 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.1.1 1.1.0 1.0.2 1.0.1 1.0.0 0.14.1 0.14.0 0.13.6 0.13.5 0.13.4 0.13.3 0.13.2 0.13.1 0.13.0 0.12.1 0.12.0 0.11.1 0.11.0 0.10.0 0.9.13 0.9.12 0.9.11 0.9.10 0.9.9 0.9.8 0.9.7 0.9.6 0.9.5 0.9.4 0.9.3 0.9.2 0.9.1 0.9.0

Verk is a job processing system backed by Redis.

HexDocs

Current section

Files

Jump to
Readme
51 Versions
5 Dependencies
3 Dependants
Files
Activity
verk priv mrpop_lpush_src_dest.lua
Raw

priv/mrpop_lpush_src_dest.lua 

local jobs = {}

local n_jobs = tonumber(ARGV[1])

local n = 0



repeat

  local job = redis.call('RPOPLPUSH', KEYS[1], KEYS[2])

  if job then

    n = n + 1

    table.insert(jobs, job)

  else

    break

  end

until n == n_jobs



return jobs