– Current SHA: 9d2cca3846a96fee53000085e36638e74ed392ed – This is a generated file
– Forward declarations to make everything happy
local Qless
= {
ns = 'ql:'
}
– Queue forward delcaration local QlessQueue = {
ns = Qless.ns .. 'q:'
} QlessQueue.__index = QlessQueue
– Worker forward declaration local QlessWorker = {
ns = Qless.ns .. 'w:'
} QlessWorker.__index = QlessWorker
– Job forward declaration local QlessJob = {
ns = Qless.ns .. 'j:'
} QlessJob.__index = QlessJob
– RecurringJob forward declaration local QlessRecurringJob = {} QlessRecurringJob.__index = QlessRecurringJob
– Config forward declaration Qless.config = {}
– Extend a table. This comes up quite frequently function table.extend(self, other)
for i, v in ipairs(other) do table.insert(self, v) end
end
– This is essentially the same as redis' publish, but it prefixes the channel – with the Qless
namespace function Qless.publish(channel, message)
redis.call('publish', Qless.ns .. channel, message)
end
– Return a job object given its job id function Qless.job(jid)
assert(jid, 'Job(): no jid provided') local job = {} setmetatable(job, QlessJob) job.jid = jid return job
end
– Return a recurring job object function Qless.recurring(jid)
assert(jid, 'Recurring(): no jid provided') local job = {} setmetatable(job, QlessRecurringJob) job.jid = jid return job
end
– Failed([group, [start, [limit]]]) – ———————————— – If no group is provided, this returns a JSON blob of the counts of the – various groups of failures known. If a group is provided, it will report up – to `limit` from `start` of the jobs affected by that issue.