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 |