Class: Sidekiq::Pauzer::Queues

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/sidekiq/pauzer/queues.rb

Overview

Eventually consistent list of paused queues. Used by Sidekiq fetchers to avoid hitting Redis on every fetch call.

Instance Method Summary collapse

Constructor Details

#initialize(refresh_rate, repository:) ⇒ Queues

Returns a new instance of Queues.

Parameters:



16
17
18
19
20
21
 
# File 'lib/sidekiq/pauzer/queues.rb', line 16

def initialize(refresh_rate, repository:)
  @names     = [].freeze
  @refresher = Concurrent::TimerTask.new(execution_interval: refresh_rate, run_now: true) do
    @names = repository.to_a.freeze
  end
end

Instance Method Details

#each ⇒ Enumerator<String> #each {|queue_name| ... } ⇒ self

Overloads:

  • #each ⇒ Enumerator<String>

    Returns:

    • (Enumerator<String>)
  • #each {|queue_name| ... } ⇒ self

    For a block { |queue_name| … }

    Yield Parameters:

    • queue_name (String)

    Returns:

    • (self) 


30
31
32
33
34
35
36
37
 
# File 'lib/sidekiq/pauzer/queues.rb', line 30

def each(&block)
  return to_enum __method__ unless block

  start_refresher unless refresher_running?
  @names.each(&block)

  self
end

#refresher_running? ⇒ Boolean

Returns:

  • (Boolean) 


55
56
57
 
# File 'lib/sidekiq/pauzer/queues.rb', line 55

def refresher_running?
  @refresher.running?
end

#start_refresher ⇒ self

Starts paused queues list async poller.

Returns:

  • (self) 


42
43
44
45
 
# File 'lib/sidekiq/pauzer/queues.rb', line 42

def start_refresher
  @refresher.execute
  self
end

#stop_refresher ⇒ self

Stops paused queues list async poller.

Returns:

  • (self) 


50
51
52
53
 
# File 'lib/sidekiq/pauzer/queues.rb', line 50

def stop_refresher
  @refresher.shutdown
  self
end