| 12345678910111213141516171819202122232425262728293031 |
- const content = `--[[
- Checks if queue is maxed.
- Input:
- KEYS[1] meta key
- KEYS[2] active key
- Output:
- 1 if element found in the list.
- ]]
- local rcall = redis.call
- -- Includes
- --[[
- Function to check if queue is maxed or not.
- ]]
- local function isQueueMaxed(queueMetaKey, activeKey)
- local maxConcurrency = rcall("HGET", queueMetaKey, "concurrency")
- if maxConcurrency then
- local activeCount = rcall("LLEN", activeKey)
- if activeCount >= tonumber(maxConcurrency) then
- return true
- end
- end
- return false
- end
- return isQueueMaxed(KEYS[1], KEYS[2])
- `;
- export const isMaxed = {
- name: 'isMaxed',
- content,
- keys: 2,
- };
- //# sourceMappingURL=isMaxed-2.js.map
|