Sha256: 787c0de3dd1c07c3c6718d3602852997e0edf21c66cdeaa72ae3a6df57be8a2e
Contents?: true
Size: 796 Bytes
Versions: 3
Compression:
Stored size: 796 Bytes
Contents
local exists_key = KEYS[1] local grabbed_key = KEYS[2] local available_key = KEYS[3] local version_key = KEYS[4] local unique_keys = KEYS[5] local unique_digest = KEYS[6] -- TODO: Legacy support (Remove in v6.1) local token = ARGV[1] local expiration = tonumber(ARGV[2]) redis.call('HDEL', grabbed_key, token) redis.call('SREM', unique_keys, unique_digest) local available_count = redis.call('LPUSH', available_key, token) if expiration then redis.log(redis.LOG_DEBUG, "signal_locks.lua - expiring stale locks") redis.call('EXPIRE', exists_key, expiration) redis.call('EXPIRE', available_key, expiration) redis.call('EXPIRE', version_key, expiration) redis.call('EXPIRE', unique_digest, expiration) -- TODO: Legacy support (Remove in v6.1) end return available_count
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-unique-jobs-6.0.4 | redis/signal.lua |
sidekiq-unique-jobs-6.0.3 | redis/signal.lua |
sidekiq-unique-jobs-6.0.2 | redis/signal.lua |