Class: AsyncCache::Workers::SidekiqWorker

Inherits:
Object
  • Object
show all
Includes:
Base, Sidekiq::Worker
Defined in:
lib/async_cache/workers/sidekiq.rb

Class Method Summary collapse

Methods included from Base

#backend, #perform

Class Method Details

.clear ⇒ Object 



26
27
28
29
30
 
# File 'lib/async_cache/workers/sidekiq.rb', line 26

def self.clear
  queue = Sidekiq::Queue.new sidekiq_queue

  queue.clear
end

.enqueue_async_job(key:, version:, expires_in:, block:, arguments:) ⇒ Object 



32
33
34
 
# File 'lib/async_cache/workers/sidekiq.rb', line 32

def self.enqueue_async_job(key:, version:, expires_in:, block:, arguments:)
  self.perform_async key, version, expires_in, arguments, block
end

.has_workers? ⇒ Boolean

Use the Sidekiq API to see if there are worker processes available to handle the async cache jobs queue.

Returns:

  • (Boolean) 


15
16
17
18
19
20
21
22
23
24
 
# File 'lib/async_cache/workers/sidekiq.rb', line 15

def self.has_workers?
  processes = Sidekiq::ProcessSet.new.to_a
  queues_being_processed = processes.flat_map { |p| p['queues'] }

  if queues_being_processed.include? sidekiq_queue
    true
  else
    false
  end
end

.sidekiq_queue ⇒ Object (private) 



38
39
40
 
# File 'lib/async_cache/workers/sidekiq.rb', line 38

def self.sidekiq_queue
  self.sidekiq_options['queue'].to_s
end