Sha256: fb9bb593a0d35bf50572c2395f41170641d93ffa81d321d2b5da67b331a973fd

Contents?: true

Size: 805 Bytes

Versions: 12

Compression:

Stored size: 805 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Tracking
      module Consumers
        # Consumer tracking related contracts
        module Contracts
          # Expected data for each consumer group
          # It's mostly about topics details
          class ConsumerGroup < BaseContract
            configure

            required(:id) { |val| val.is_a?(String) && !val.empty? }
            required(:topics) { |val| val.is_a?(Hash) }

            virtual do |data, errors|
              next unless errors.empty?

              topic_contract = Topic.new

              data.fetch(:topics).each do |_topic_name, details|
                topic_contract.validate!(details)
              end

              nil
            end
          end
        end
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version Path
karafka-web-0.3.1 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.3.0 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.2.5 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.2.4 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.2.3 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.2.2 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.2.1 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.2.0 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.1.3 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.1.2 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.1.1 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.1.0 lib/karafka/web/tracking/consumers/contracts/consumer_group.rb