Sha256: 271f26a098888ae799140c464bc3b29291ef5f828f11fbaf28187d2233c65040
Contents?: true
Size: 1.82 KB
Versions: 16
Compression:
Stored size: 1.82 KB
Contents
# frozen_string_literal: true %w[ delegate English waterdrop kafka envlogic json thor forwardable fileutils dry-configurable dry-validation dry/events/publisher dry/inflector dry/monitor/notifications dry/core/constants zeitwerk ].each(&method(:require)) # Karafka library module Karafka extend Envlogic class << self # @return [Logger] logger that we want to use. Will use ::Karafka::Logger by default def logger @logger ||= App.config.logger end # @return [::Karafka::Monitor] monitor that we want to use def monitor @monitor ||= App.config.monitor end # @return [String] root path of this gem def gem_root Pathname.new(File.expand_path('..', __dir__)) end # @return [String] Karafka app root path (user application path) def root Pathname.new(ENV['KARAFKA_ROOT_DIR'] || File.dirname(ENV['BUNDLE_GEMFILE'])) end # @return [String] path to Karafka gem root core def core_root Pathname.new(File.expand_path('karafka', __dir__)) end # @return [String] path to a default file that contains booting procedure etc # @note By default it is a file called 'karafka.rb' but it can be specified as you wish if you # have Karafka that is merged into a Sinatra/Rails app and karafka.rb is taken. # It will be used for console/consumers/etc # @example Standard only-Karafka case # Karafka.boot_file #=> '/home/app_path/karafka.rb' # @example Non standard case # KARAFKA_BOOT_FILE='/home/app_path/app.rb' # Karafka.boot_file #=> '/home/app_path/app.rb' def boot_file Pathname.new(ENV['KARAFKA_BOOT_FILE'] || File.join(Karafka.root, 'karafka.rb')) end end end Zeitwerk::Loader .for_gem .tap(&:setup) .tap(&:eager_load) Kafka::Consumer.prepend(Karafka::Patches::RubyKafka)
Version data entries
16 entries across 16 versions & 1 rubygems