Sha256: fdb645db12f10ee3e52f6d1a2db4afb92d5b4fc8edc456889024be0493df52e6
Contents?: true
Size: 1.77 KB
Versions: 42
Compression:
Stored size: 1.77 KB
Contents
# frozen_string_literal: true
# This Karafka component is a Pro component under a commercial license.
# This Karafka component is NOT licensed under LGPL.
#
# All of the commercial components are present in the lib/karafka/pro directory of this
# repository and their usage requires commercial license agreement.
#
# Karafka has also commercial-friendly license, commercial support and commercial components.
#
# By sending a pull request to the pro components, you are agreeing to transfer the copyright of
# your code to Maciej Mensfeld.
module Karafka
module Pro
module Routing
module Features
class Patterns < Base
# Patterns feature topic extensions
module Topic
# @return [String] subscription name or the regexp string representing matching of
# new topics that should be detected.
def subscription_name
patterns.active? && patterns.matcher? ? patterns.pattern.regexp_string : super
end
# @param active [Boolean] is this topic active member of patterns
# @param type [Symbol] type of topic taking part in pattern matching
# @param pattern [Regexp] regular expression for matching
def patterns(active: false, type: :regular, pattern: nil)
@patterns ||= Config.new(active: active, type: type, pattern: pattern)
end
# @return [Boolean] is this topic a member of patterns
def patterns?
patterns.active?
end
# @return [Hash] topic with all its native configuration options plus patterns
def to_h
super.merge(
patterns: patterns.to_h
).freeze
end
end
end
end
end
end
end
Version data entries
42 entries across 42 versions & 1 rubygems