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, когда задача должна стать доступной

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

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

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

KEYS[1] - Имя основной очереди KEYS[2] - Имя очереди "отложенных" задач KEYS[3] - Имя очереди "зарезервированных" задач KEYS[4] - Имя очереди "уведомлений"