knowledge/node_modules/bullmq/dist/cjs/scripts/isMaxed-2.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.isMaxed = void 0;
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])
`;
exports.isMaxed = {
    name: 'isMaxed',
    content,
    keys: 2,
};
//# sourceMappingURL=isMaxed-2.js.map