Sha256: c10860b3f40f39a5685880f72e4471ef112326cf5c43a6e7cef5122e872b7440

Contents?: true

Size: 1000 Bytes

Versions: 2

Compression:

Stored size: 1000 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Setup
    class Configurators
      # Class to configure all the Sidekiq settings based on Karafka settings
      class Sidekiq < Base
        # Sets up sidekiq client and server
        def setup
          setup_sidekiq_client
          setup_sidekiq_server
        end

        private

        # Configure sidekiq client
        def setup_sidekiq_client
          ::Sidekiq.configure_client do |sidekiq_config|
            sidekiq_config.redis = config.redis.to_h.merge(
              size: config.concurrency
            )
          end
        end

        # Configure sidekiq setorrver
        def setup_sidekiq_server
          ::Sidekiq.configure_server do |sidekiq_config|
            # We don't set size for the server - this will be set automatically based
            # on the Sidekiq concurrency level (Sidekiq not Karafkas)
            sidekiq_config.redis = config.redis.to_h
          end
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
karafka-0.6.0.rc2 lib/karafka/setup/configurators/sidekiq.rb
karafka-0.6.0.rc1 lib/karafka/setup/configurators/sidekiq.rb