LuaScripts
class LuaScripts (View source)
Methods
Get the Lua script for computing the size of queue.
Get the Lua script for pushing jobs onto the queue.
Get the Lua script for popping the next job off of the queue.
Get the Lua script for releasing reserved jobs.
Get the Lua script to migrate expired jobs back onto the queue.
Details
static string
size()
Get the Lua script for computing the size of queue.
KEYS[1] - The name of the primary queue KEYS[2] - The name of the "delayed" queue KEYS[3] - The name of the "reserved" queue
static string
push()
Get the Lua script for pushing jobs onto the queue.
KEYS[1] - The queue to push the job onto, for example: queues:foo KEYS[2] - The notification list fot the queue we are pushing jobs onto, for example: queues:foo:notify ARGV[1] - The job payload
static string
pop()
Get the Lua script for popping the next job off of the queue.
KEYS[1] - The queue to pop jobs from, for example: queues:foo KEYS[2] - The queue to place reserved jobs on, for example: queues:foo:reserved KEYS[3] - The notify queue ARGV[1] - The time at which the reserved job will expire
static string
release()
Get the Lua script for releasing reserved jobs.
KEYS[1] - The "delayed" queue we release jobs onto, for example: queues:foo:delayed KEYS[2] - The queue the jobs are currently on, for example: queues:foo:reserved ARGV[1] - The raw payload of the job to add to the "delayed" queue ARGV[2] - The UNIX timestamp at which the job should become available
static string
migrateExpiredJobs()
Get the Lua script to migrate expired jobs back onto the queue.
KEYS[1] - The queue we are removing jobs from, for example: queues:foo:reserved KEYS[2] - The queue we are moving jobs to, for example: queues:foo KEYS[3] - The notification list for the queue we are moving jobs to, for example queues:foo:notify ARGV[1] - The current UNIX timestamp