Sha256: 142718334d5e6a472ccc0d4e2b01d64647a3a46f9cc11d498583bbba879923b3
Contents?: true
Size: 787 Bytes
Versions: 27
Compression:
Stored size: 787 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Contracts
# Contract with validation rules for Karafka configuration details
# @note There are many more configuration options inside of the
# Karafka::Setup::Config model, but we don't validate them here as they are
# validated per each route (topic + consumer_group) because they can be overwritten,
# so we validate all of that once all the routes are defined and ready
class Config < Dry::Validation::Contract
params do
required(:client_id).filled(:str?, format?: Karafka::Contracts::TOPIC_REGEXP)
required(:shutdown_timeout) { (int? & gt?(0)) }
required(:consumer_mapper)
required(:topic_mapper)
optional(:backend).filled
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems