Sha256: 569b51b33a2169a4805ed266b4f173d53b33867e4382af1b9bfbdf58d6674422

Contents?: true

Size: 1.37 KB

Versions: 8

Compression:

Stored size: 1.37 KB

Contents

-------- BEGIN keys ---------
local digest    = KEYS[1]
local queued    = KEYS[2]
local primed    = KEYS[3]
local locked    = KEYS[4]
local info      = KEYS[5]
local changelog = KEYS[6]
local digests   = KEYS[7]
-------- END keys ---------

-------- BEGIN lock arguments ---------
local job_id       = ARGV[1]
local pttl         = tonumber(ARGV[2])
local lock_type    = ARGV[3]
local limit        = tonumber(ARGV[4])
-------- END lock arguments -----------

--------  BEGIN injected arguments --------
local current_time = tonumber(ARGV[5])
local debug_lua    = tostring(ARGV[6]) == "1"
local max_history  = tonumber(ARGV[7])
local script_name  = tostring(ARGV[8]) .. ".lua"
local redisversion = tostring(ARGV[9])
---------  END injected arguments ---------

--------  BEGIN local functions --------
<%= include_partial "shared/_common.lua" %>
----------  END local functions ----------


--------  BEGIN delete.lua --------
log_debug("BEGIN delete", digest)

local redis_version  = toversion(redisversion)
local count          = 0

log_debug("ZREM", digests, digest)
count = count + redis.call("ZREM", digests, digest)

log_debug("UNLINK", digest, queued, primed, locked, info)
count = count + redis.call("UNLINK", digest, queued, primed, locked, info)


log("Deleted (" .. count .. ") keys")
log_debug("END delete (" .. count .. ") keys for:", digest)

return count
--------  END delete.lua --------

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
sidekiq-unique-jobs-8.0.9 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.8 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.7 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.6 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.5 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.4 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.3 lib/sidekiq_unique_jobs/lua/delete.lua
sidekiq-unique-jobs-8.0.2 lib/sidekiq_unique_jobs/lua/delete.lua