Sha256: c903f6aa045cf44f0109b8eea88d4e6b07c4968b7543dc722f08cca4c70f456e
Contents?: true
Size: 538 Bytes
Versions: 18
Compression:
Stored size: 538 Bytes
Contents
-- AUTOGENERATED FILE DO NOT EDIT DIRECTLY
local zset_key = KEYS[1]
local processed_key = KEYS[2]
local owners_key = KEYS[3]
local worker_queue_key = KEYS[4]
local current_time = ARGV[1]
local test = ARGV[2]
-- already processed, we do not need to bump the timestamp
if redis.call('sismember', processed_key, test) == 1 then
return false
end
-- we're still the owner of the test, we can bump the timestamp
if redis.call('hget', owners_key, test) == worker_queue_key then
return redis.call('zadd', zset_key, current_time, test)
end
Version data entries
18 entries across 18 versions & 1 rubygems