module Rworkflow::SidekiqHelper

Public Class Methods

configure_client(host, port, db) click to toggle source
# File lib/rworkflow/sidekiq_helper.rb, line 43
def configure_client(host, port, db)
  Sidekiq.configure_client do |config|
    config.redis = { url: "redis://#{host}:#{port}/#{db}", namespace: 'sidekiq' }
  end
end
configure_server(host, port, db) click to toggle source
# File lib/rworkflow/sidekiq_helper.rb, line 34
def configure_server(host, port, db)
  Sidekiq.configure_server do |config|
    config.redis = { url: "redis://#{host}:#{port}/#{db}", namespace: 'sidekiq' }
    config.server_middleware do |chain|
      chain.add SidekiqServerMiddleware
    end
  end
end
included(klass) click to toggle source
# File lib/rworkflow/sidekiq_helper.rb, line 5
def self.included(klass)
  klass.send :extend, ClassMethods
end
queue_sizes() click to toggle source
# File lib/rworkflow/sidekiq_helper.rb, line 49
def queue_sizes
  stats = Sidekiq::Stats.new
  return stats.queues
end