Sha256: 6314c0c5faa57009a4d9b17628ed95b12865f381143afa52bff24a68add85535
Contents?: true
Size: 470 Bytes
Versions: 21
Compression:
Stored size: 470 Bytes
Contents
local function delete_from_queue(queue, digest)
local per = 50
local total = redis.call("LLEN", queue)
local index = 0
local result = nil
while (index < total) do
local items = redis.call("LRANGE", queue, index, index + per -1)
for _, item in pairs(items) do
if string.find(item, digest) then
redis.call("LREM", queue, 1, item)
result = item
break
end
end
index = index + per
end
return result
end
Version data entries
21 entries across 21 versions & 1 rubygems