rimless.rb in rimless-1.0.0

- old
+ new

@@ -9,10 +9,12 @@
 require 'active_support/core_ext/module'
 require 'active_support/core_ext/hash'
 require 'active_support/core_ext/string'
 require 'waterdrop'
 require 'avro_turf/messaging'
+require 'karafka'
+require 'karafka-sidekiq-backend'
 require 'sparsify'
 require 'erb'
 require 'pp'
 
 # The top level namespace for the rimless gem.
@@ -22,16 +24,27 @@
   autoload :ConfigurationHandling, 'rimless/configuration_handling'
   autoload :AvroHelpers, 'rimless/avro_helpers'
   autoload :AvroUtils, 'rimless/avro_utils'
   autoload :KafkaHelpers, 'rimless/kafka_helpers'
   autoload :Dependencies, 'rimless/dependencies'
+  autoload :BaseConsumer, 'rimless/base_consumer'
+  autoload :Consumer, 'rimless/consumer'
+  autoload :ConsumerJob, 'rimless/consumer_job'
 
+  # All Karafka-framework related components
+  module Karafka
+    autoload :Base64Interchanger, 'rimless/karafka/base64_interchanger'
+    autoload :PassthroughMapper, 'rimless/karafka/passthrough_mapper'
+    autoload :AvroDeserializer, 'rimless/karafka/avro_deserializer'
+  end
+
   # Load standalone code
   require 'rimless/version'
   require 'rimless/railtie' if defined? Rails
 
   # Include top-level features
   include Rimless::ConfigurationHandling
   include Rimless::AvroHelpers
   include Rimless::KafkaHelpers
   include Rimless::Dependencies
+  include Rimless::Consumer
 end