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 



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

def process_key(&block)
  if block_given?
    @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.



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

def retry_after
  @retry_after
end

Class Method Details

.pause(queue, pkey = nil) ⇒ Object 



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

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

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



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

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

.unpause(queue, pkey = nil) ⇒ Object 



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

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

.unpause_all ⇒ Object 



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

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