– 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.