Contents

# frozen_string_literal: true

module Karafka
  # App class
  class App
    class << self
      # Sets up the whole configuration
      # @param [Block] block configuration block
      def setup(&block)
        Setup::Config.setup(&block)
        initialize!
      end

      # Sets up all the internal components and bootstrap whole app
      # We need to know details about consumers in order to setup components,
      # that's why we don't setup them after std setup is done
      # @raise [Karafka::Errors::InvalidConfiguration] raised when configuration
      #   doesn't match with ConfigurationSchema
      def boot!
        Setup::Config.validate!
        Setup::Config.setup_components
      end

      # @return [Karafka::Config] config instance
      def config
        Setup::Config.config
      end

      # @return [Karafka::Routing::Builder] consumers builder instance
      def consumer_groups
        Routing::Builder.instance
      end

      Status.instance_methods(false).each do |delegated|
        define_method(delegated) do
          Status.instance.public_send(delegated)
        end
      end

      # Methods that should be delegated to Karafka module
      %i[
        root
        env
        logger monitor
      ].each do |delegated|
        define_method(delegated) do
          Karafka.public_send(delegated)
        end
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
karafka-1.1.2	lib/karafka/app.rb
karafka-1.1.1	lib/karafka/app.rb
karafka-1.1.0	lib/karafka/app.rb
karafka-1.1.0.alpha2	lib/karafka/app.rb
karafka-1.1.0.alpha1	lib/karafka/app.rb
karafka-1.0.1	lib/karafka/app.rb
karafka-1.0.0	lib/karafka/app.rb
karafka-1.0.0.rc1	lib/karafka/app.rb
karafka-0.6.0.rc2	lib/karafka/app.rb
karafka-0.6.0.rc1	lib/karafka/app.rb