Packages

bullmq

1.3.5
1.3.7 1.3.6 1.3.5 1.3.4 1.3.3 1.3.2 1.3.1 1.3.0 1.2.7 1.2.6 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.1.0 1.0.1 1.0.0

A powerful, fast, and robust job queue for Elixir backed by Redis

HexDocs

Current section

Files

Jump to
Readme
19 Versions
9 Dependencies
Dependants
Files
Activity
bullmq priv scripts isMaxed-2.lua
Raw

priv/scripts/isMaxed-2.lua 

--[[

  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])