Sha256: 8cd626294ab5e848c87b4f3a5033f95a06cb03e0f0d20597dde76f1181bb66fc

Contents?: true

Size: 990 Bytes

Versions: 3

Compression:

Stored size: 990 Bytes

Contents

require 'active_support/core_ext/string'
require 'active_support/configurable'
require 'active_support/core_ext/numeric/time'
require 'sidekiq/grouping/version'

module Sidekiq
  module Grouping
    autoload :Config, 'sidekiq/grouping/config'
    autoload :Redis, 'sidekiq/grouping/redis'
    autoload :Batch, 'sidekiq/grouping/batch'
    autoload :Middleware, 'sidekiq/grouping/middleware'
    autoload :Logging, 'sidekiq/grouping/logging'
    autoload :Actor, 'sidekiq/grouping/actor'
    autoload :Supervisor, 'sidekiq/grouping/supervisor'

    class << self
      attr_writer :logger

      def logger
        @logger ||= Sidekiq.logger
      end
    end
  end
end

Sidekiq.configure_client do |config|
  config.client_middleware do |chain|
    chain.add Sidekiq::Grouping::Middleware
  end
end

Sidekiq.configure_server do |config|
  config.client_middleware do |chain|
    chain.add Sidekiq::Grouping::Middleware
  end
end

if Sidekiq.server?
  Sidekiq::Grouping::Supervisor.run!
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
sidekiq-grouping-1.0.4 lib/sidekiq/grouping.rb
sidekiq-grouping-1.0.2 lib/sidekiq/grouping.rb
sidekiq-grouping-1.0.1 lib/sidekiq/grouping.rb