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