Packages

verk

1.0.1
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 lpop_rpush_src_dest.lua
Raw

priv/lpop_rpush_src_dest.lua 

local size = tonumber(ARGV[1])

local jobs = redis.call('LRANGE', KEYS[1], 0, size-1)

local len_before = redis.call('LLEN', KEYS[1])



if table.getn(jobs) > 0 then

  local queue_key = KEYS[2]

  redis.call('RPUSH', queue_key, unpack(jobs))



  redis.call('LTRIM', KEYS[1], size, -1)

end

local len_after = redis.call('LLEN', KEYS[1])

return { len_after, len_before - len_after }