Contents

# frozen_string_literal: true

module Karafka
  # Namespace for additional extensions that we include into some Karafka components, to gain
  # extra features that we require
  module Extensions
    # Additional Karafka::Routing::Topic methods that are required to work with Sidekiq backend
    module SidekiqTopicAttributes
      # @return [Class] Class (not an instance) of a worker that should be used to schedule the
      #   background job
      # @note If not provided - will be built based on the provided controller
      def worker
        @worker ||= backend == :sidekiq ? Karafka::Workers::Builder.new(controller).build : nil
      end

      # @return [Class] Interchanger class (not an instance) that we want to use to interchange
      #   params between Karafka server and Karafka background job
      def interchanger
        @interchanger ||= Karafka::Interchanger
      end

      # Creates attributes writers for worker and interchanger, so they can be overwritten
      # @param base [Class] Karafka::Routing::Topic class
      def self.included(base)
        base.send :attr_writer, :worker
        base.send :attr_writer, :interchanger
      end
    end
  end
end

Karafka::Routing::Topic.include Karafka::Extensions::SidekiqTopicAttributes

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
karafka-sidekiq-backend-1.1.0	lib/karafka/extensions/sidekiq_topic_attributes.rb
karafka-sidekiq-backend-1.1.0.alpha1	lib/karafka/extensions/sidekiq_topic_attributes.rb
karafka-sidekiq-backend-1.0.0	lib/karafka/extensions/sidekiq_topic_attributes.rb