Sha256: 5a4ad8cc73f75fe4e66e43823532584c27145da54f0336a09d08aec0b9bc38db
Contents?: true
Size: 1.07 KB
Versions: 22
Compression:
Stored size: 1.07 KB
Contents
# frozen_string_literal: true
module Karafka
module Processing
# Selector of appropriate processing strategy matching topic combinations
class StrategySelector
def initialize
# We load them once for performance reasons not to do too many lookups
@available_strategies = Strategies
.constants
.delete_if { |k| k == :Base }
.map { |k| Strategies.const_get(k) }
end
# @param topic [Karafka::Routing::Topic] topic with settings based on which we find strategy
# @return [Module] module with proper strategy
def find(topic)
feature_set = [
topic.active_job? ? :active_job : nil,
topic.manual_offset_management? ? :manual_offset_management : nil,
topic.dead_letter_queue? ? :dead_letter_queue : nil
].compact
@available_strategies.find do |strategy|
strategy::FEATURES.sort == feature_set.sort
end || raise(Errors::StrategyNotFoundError, topic.name)
end
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems