LuaScripts

Получить Lua скрипт для вычисления размера очереди.

KEYS[1] - Название основной очереди KEYS[2] - Название очереди «отложенных» задач KEYS[3] - Название очереди «зарезервированных» задач

Получить Lua скрипт для добавления задач в очередь.

KEYS[1] - Очередь для добавления задачи, например: queues:foo KEYS[2] - Список уведомлений для очереди, в которую мы добавляем задачи, например: queues:foo:notify ARGV[1] - Данные задачи

Получить Lua скрипт для извлечения следующей задачи из очереди.

KEYS[1] - Очередь для извлечения задач, например: queues:foo KEYS[2] - Очередь для размещения зарезервированных задач, например: queues:foo:reserved KEYS[3] - Очередь уведомлений ARGV[1] - Время истечения срока действия зарезервированной задачи

Получить Lua скрипт для высвобождения зарезервированных задач.

KEYS[1] - Очередь «отложенных» задач, в которую мы добавляем задачи, например: queues:foo:delayed KEYS[2] - Очередь, в которой задачи находятся сейчас, например: queues:foo:reserved ARGV[1] - Необработанные данные задачи для добавления в очередь «отложенных» задач ARGV[2] - Маркер времени (UNIX timestamp) когда задача должна стать доступной

Получить Lua скрипт для миграции истекших задач обратно в очередь.

KEYS[1] - Очередь, из которой мы удаляем задачи, например: queues:foo:reserved KEYS[2] - Очередь, в которую мы переносим задачи, например: queues:foo KEYS[3] - Список уведомлений для очереди, в которую мы переносим задачи, например queues:foo:notify ARGV[1] - Текущий маркер времени (UNIX timestamp)