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