Sha256: a9faed759128f30459f787735c60669e83c00b2788cf14f20239a93382f6a79d
Contents?: true
Size: 1.22 KB
Versions: 9
Compression:
Stored size: 1.22 KB
Contents
local function toversion(version)
local _, _, maj, min, pat = string.find(version, "(%d+)%.(%d+)%.(%d+)")
return {
["version"] = version,
["major"] = tonumber(maj),
["minor"] = tonumber(min),
["patch"] = tonumber(pat)
}
end
local function log_debug( ... )
if debug_lua ~= true then return end
local result = ""
for _,v in ipairs(arg) do
result = result .. " " .. tostring(v)
end
redis.log(redis.LOG_DEBUG, script_name .. " -" .. result)
end
local function log(message, prev_jid)
if not max_history or max_history == 0 then return end
local entry = cjson.encode({digest = digest, job_id = job_id, script = script_name, message = message, time = current_time, prev_jid = prev_jid })
log_debug("ZADD", changelog, current_time, entry);
redis.call("ZADD", changelog, current_time, entry);
local total_entries = redis.call("ZCARD", changelog)
local removed_entries = redis.call("ZREMRANGEBYRANK", changelog, 0, -1 * max_history)
if removed_entries > 0 then
log_debug("Removing", removed_entries , "entries from changelog (total entries", total_entries, "exceeds max_history:", max_history ..")");
end
log_debug("PUBLISH", changelog, entry);
redis.call("PUBLISH", changelog, entry);
end
Version data entries
9 entries across 9 versions & 1 rubygems