Sha256: d389651fb37ee7ea8eb69f3f6087a5634627519f20b776f1e20d1fd53e5dc5d5

Contents?: true

Size: 631 Bytes

Versions: 98

Compression:

Stored size: 631 Bytes

Contents

local function find_digest_in_sorted_set(name, digest)
  local cursor  = 0
  local count   = 5
  local pattern = "*" .. digest .. "*"
  local found   = false

  log_debug("searching in:", name,
            "for digest:", digest,
            "cursor:", cursor)
  repeat
    local pagination  = redis.call("ZSCAN", name, cursor, "MATCH", pattern, "COUNT", count)
    local next_cursor = pagination[1]
    local items       = pagination[2]

    if #items > 0 then
      log_debug("Found digest", digest, "in zset:", name)
      found = true
    end

    cursor = next_cursor
  until found == true or cursor == "0"

  return found
end

Version data entries

98 entries across 85 versions & 1 rubygems

Version Path
sidekiq-unique-jobs-7.0.0.beta26 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta25 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta24 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta23 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta22 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta21 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta20 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta19 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta18 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta17 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta16 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta15 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta14 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta14 lib/sidekiq_unique_jobs/lua/find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta13 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta13 lib/sidekiq_unique_jobs/lua/find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta12 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta12 lib/sidekiq_unique_jobs/lua/find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta11 lib/sidekiq_unique_jobs/lua/find_digest_in_sorted_set.lua
sidekiq-unique-jobs-7.0.0.beta11 lib/sidekiq_unique_jobs/lua/shared/_find_digest_in_sorted_set.lua