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