Sha256: 960a48a19d21b64789e8802987ebb8d97f3122f5a899e1fe6aff606cdb734c38

Contents?: true

Size: 389 Bytes

Versions: 30

Compression:

Stored size: 389 Bytes

Contents

local unique_key = KEYS[1]
local job_id     = ARGV[1]
local expires    = tonumber(ARGV[2])
local stored_jid = redis.pcall('get', unique_key)

if stored_jid then
  if stored_jid == job_id then
    return 1
  else
    return 0
  end
end

if redis.call('SET', unique_key, job_id, 'nx') then
  if expires then
    redis.call('EXPIRE', unique_key, expires)
  end
  return 1
else
  return 0
end

Version data entries

30 entries across 30 versions & 1 rubygems

Version Path
sidekiq-unique-jobs-6.0.25 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.24 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.23 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.22 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.21 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.20 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.16 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.19 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.13 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.12 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.11 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.10 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.9 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.8 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.7 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.6 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.5 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.4 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.3 redis/acquire_lock.lua
sidekiq-unique-jobs-6.0.2 redis/acquire_lock.lua