Module: Sidekiq::QueuePause

Defined in:
lib/sidekiq-queue-pause.rb

Defined Under Namespace

Classes: PausingFetch

Constant Summary collapse

PREFIX = 
"queue_pause"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.process_key(&block) ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/sidekiq-queue-pause.rb', line 12

def process_key(&block)
  if block
    @process_key = block
  else
    @process_key.is_a?(Proc) ? @process_key.call : @process_key
  end
end

.retry_after ⇒ Object

Returns the value of attribute retry_after.



9
10
11
 
# File 'lib/sidekiq-queue-pause.rb', line 9

def retry_after
  @retry_after
end

Class Method Details

.pause(queue, pkey = nil) ⇒ Object 



20
21
22
 
# File 'lib/sidekiq-queue-pause.rb', line 20

def pause(queue, pkey = nil)
  Sidekiq.redis { |it| it.set rkey(queue, pkey), true }
end

.paused?(queue, pkey = nil) ⇒ Boolean

Returns:

  • (Boolean) 


28
29
30
 
# File 'lib/sidekiq-queue-pause.rb', line 28

def paused?(queue, pkey = nil)
  Sidekiq.redis { |it| it.exists? rkey(queue, pkey) }
end

.unpause(queue, pkey = nil) ⇒ Object 



24
25
26
 
# File 'lib/sidekiq-queue-pause.rb', line 24

def unpause(queue, pkey = nil)
  Sidekiq.redis { |it| it.del rkey(queue, pkey) }
end

.unpause_all ⇒ Object 



32
33
34
 
# File 'lib/sidekiq-queue-pause.rb', line 32

def unpause_all
  Sidekiq.redis { |it| it.keys("#{PREFIX}:*").each { |k| it.del k } }
end