Sha256: 7b6c4851c46bc8b96bdb4bf5437f3644a1bf7e63a08a864bd5c926fd4f76d877

Contents?: true

Size: 461 Bytes

Versions: 44

Compression:

Stored size: 461 Bytes

Contents

-- AUTOGENERATED FILE DO NOT EDIT DIRECTLY
local queue_key = KEYS[1]
local zset_key = KEYS[2]
local processed_key = KEYS[3]
local worker_queue_key = KEYS[4]
local owners_key = KEYS[5]

local current_time = ARGV[1]

local test = redis.call('rpop', queue_key)
if test then
  redis.call('zadd', zset_key, current_time, test)
  redis.call('lpush', worker_queue_key, test)
  redis.call('hset', owners_key, test, worker_queue_key)
  return test
else
  return nil
end

Version data entries

44 entries across 44 versions & 1 rubygems

Version Path
ci-queue-0.62.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.61.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.60.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.59.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.58.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.57.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.56.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.55.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.52.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.51.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.50.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.49.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.48.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.47.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.46.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.45.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.44.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.43.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.42.0 lib/ci/queue/redis/reserve.lua
ci-queue-0.41.0 lib/ci/queue/redis/reserve.lua