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 subscription groups details
          class ConsumerGroup < Tracking::Contracts::Base
            configure

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

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

              subscription_group_contract = SubscriptionGroup.new

              data.fetch(:subscription_groups).each do |_subscription_group_name, details|
                subscription_group_contract.validate!(details)
              end

              nil
            end
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
karafka-web-0.6.3	lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.6.2	lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.6.1	lib/karafka/web/tracking/consumers/contracts/consumer_group.rb
karafka-web-0.6.0	lib/karafka/web/tracking/consumers/contracts/consumer_group.rb