Sha256: be026c535b73ac24bfd2a5dde1deb41bf272e5aa933c5d725edda15156a47e25
Contents?: true
Size: 1.13 KB
Versions: 39
Compression:
Stored size: 1.13 KB
Contents
# frozen_string_literal: true
module Karafka
module Routing
# Namespace for all the topic related features we support
#
# @note Not all the Karafka features need to be defined here as only those that have routing
# or other extensions need to be here. That is why we keep (for now) features under the
# routing namespace.
module Features
# Base for all the features
class Base
class << self
# Extends topic and builder with given feature API
def activate
Topic.prepend(self::Topic) if const_defined?('Topic', false)
Proxy.prepend(self::Builder) if const_defined?('Builder', false)
Builder.prepend(self::Builder) if const_defined?('Builder', false)
Builder.prepend(Base::Expander.new(self)) if const_defined?('Contract', false)
end
# Loads all the features and activates them
def load_all
ObjectSpace
.each_object(Class)
.select { |klass| klass < self }
.sort_by(&:to_s)
.each(&:activate)
end
end
end
end
end
end
Version data entries
39 entries across 39 versions & 1 rubygems