Sha256: e154b2667338e1340bc70c94fb53f31619bca0271c4c61b31be9c393653581ee

Contents?: true

Size: 270 Bytes

Versions: 7

Compression:

Stored size: 270 Bytes

Contents

local key = KEYS[1]
local jid = ARGV[1]
local lmt = tonumber(ARGV[2])
local ttl = tonumber(ARGV[3])

if lmt <= redis.call("SCARD", key) and 0 == redis.call("SISMEMBER", key, jid) then
  return 1
end

redis.call("SADD", key, jid)
redis.call("EXPIRE", key, ttl)

return 0

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
sidekiq-throttled-0.7.3 lib/sidekiq/throttled/strategy/concurrency.lua
sidekiq-throttled-0.7.2 lib/sidekiq/throttled/strategy/concurrency.lua
sidekiq-throttled-0.7.1 lib/sidekiq/throttled/strategy/concurrency.lua
sidekiq-throttled-0.7.0 lib/sidekiq/throttled/strategy/concurrency.lua
sidekiq-throttled-0.6.7 lib/sidekiq/throttled/strategy/concurrency.lua
sidekiq-throttled-0.6.6 lib/sidekiq/throttled/strategy/concurrency.lua
sidekiq-throttled-0.6.5 lib/sidekiq/throttled/strategy/concurrency.lua