Class: Sidekiq::PriorityQueue::Queue
- Inherits:
-
Object
- Object
- Sidekiq::PriorityQueue::Queue
- Includes:
- Enumerable
- Defined in:
- lib/sidekiq/priority_queue/api.rb
Instance Attribute Summary collapse
-
#name ⇒ Object
readonly
Returns the value of attribute name.
Class Method Summary collapse
Instance Method Summary collapse
- #each ⇒ Object
-
#initialize(name = 'default') ⇒ Queue
constructor
A new instance of Queue.
- #size ⇒ Object
Constructor Details
#initialize(name = 'default') ⇒ Queue
Returns a new instance of Queue.
12 13 14 15 |
# File 'lib/sidekiq/priority_queue/api.rb', line 12 def initialize(name='default') @name = name @rname = "priority-queue:#{name}" end |
Instance Attribute Details
#name ⇒ Object (readonly)
Returns the value of attribute name.
10 11 12 |
# File 'lib/sidekiq/priority_queue/api.rb', line 10 def name @name end |
Class Method Details
Instance Method Details
#each ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 |
# File 'lib/sidekiq/priority_queue/api.rb', line 21 def each initial_size = size deleted_size = 0 page = 0 page_size = 50 while true do range_start = page * page_size - deleted_size range_end = range_start + page_size - 1 entries = Sidekiq.redis do |conn| conn.zrange @rname, range_start, range_end, withscores: true end break if entries.empty? page += 1 entries.each do |entry, priority| yield Job.new(entry, @name, priority) end deleted_size = initial_size - size end end |
#size ⇒ Object
17 18 19 |
# File 'lib/sidekiq/priority_queue/api.rb', line 17 def size Sidekiq.redis { |con| con.zcard(@rname) } end |