Sha256: e1203d35d5947642a61197a537661696f87fa6a0c261e9e0eb20d5101d1c9f58
Contents?: true
Size: 1.29 KB
Versions: 2
Compression:
Stored size: 1.29 KB
Contents
# frozen_string_literal: true module Sidekiq module Paginator def page(key, pageidx = 1, page_size = 25, opts = nil) current_page = pageidx.to_i < 1 ? 1 : pageidx.to_i pageidx = current_page - 1 total_size = 0 items = [] starting = pageidx * page_size ending = starting + page_size - 1 Sidekiq.redis do |conn| type = conn.type(key) rev = opts && opts[:reverse] case type when "zset" total_size, items = conn.multi { |transaction| transaction.zcard(key) if rev transaction.zrevrange(key, starting, ending, with_scores: true) else transaction.zrange(key, starting, ending, with_scores: true) end } [current_page, total_size, items] when "list" total_size, items = conn.multi { |transaction| transaction.llen(key) if rev transaction.lrange(key, -ending - 1, -starting - 1) else transaction.lrange(key, starting, ending) end } items.reverse! if rev [current_page, total_size, items] when "none" [1, 0, []] else raise "can't page a #{type}" end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-6.4.2 | lib/sidekiq/paginator.rb |
sidekiq-6.4.1 | lib/sidekiq/paginator.rb |