module Bellbro::SidekiqUtils
Public Instance Methods
jobs()
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 111 def jobs Job.all_for_class("#{self.name}") end
jobs_in_flight_with(arg)
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 115 def jobs_in_flight_with(arg) jobs_with(arg) + workers_with(arg) end
jobs_with(arg)
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 119 def jobs_with(arg) key = arg.keys.first value = arg.values.first jobs.select do |job| value == job.send(key) end end
number_of_active_workers(q_name)
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 141 def number_of_active_workers(q_name) workers_for_queue(q_name).count end
workers()
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 107 def workers Worker.all_for_class("#{self.name}") end
workers_for_queue(q)
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 135 def workers_for_queue(q) workers.select do |worker| worker.queue == q end end
workers_with(arg)
click to toggle source
# File lib/bellbro/sidekiq_utils.rb, line 127 def workers_with(arg) key = arg.keys.first value = arg.values.first workers.select do |worker| value == worker.send(key) end end