Sha256: 24e280d530bedc0bfa1e0b4604db6dbf95d7cb76dc85d95de1f757ad791c3ba8

Contents?: true

Size: 1.04 KB

Versions: 20

Compression:

Stored size: 1.04 KB

Contents

# frozen_string_literal: true

# This Karafka component is a Pro component.
# 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 Contracts
      # Contract for validating correct Pro components setup on a consumer group and topic levels
      class ConsumerGroup < Base
        virtual do |data, errors|
          next unless errors.empty?
          next unless data.key?(:topics)

          fetched_errors = []

          data.fetch(:topics).each do |topic|
            ConsumerGroupTopic.new.call(topic).errors.each do |key, value|
              fetched_errors << [[topic, key].flatten, value]
            end
          end

          fetched_errors
        end
      end
    end
  end
end

Version data entries

20 entries across 20 versions & 1 rubygems

Version Path
karafka-2.0.15 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.14 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.13 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.12 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.11 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.10 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.9 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.8 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.7 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.6 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.5 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.4 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.3 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.2 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.1 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.0 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.0.rc6 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.0.rc5 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.0.rc4 lib/karafka/pro/contracts/consumer_group.rb
karafka-2.0.0.rc3 lib/karafka/pro/contracts/consumer_group.rb