Sha256: c04eb00e2f295b27c9cce8fb02514bfe73a8ba98cb42c3851f6df841ae7bd1f7
Contents?: true
Size: 493 Bytes
Versions: 23
Compression:
Stored size: 493 Bytes
Contents
# frozen_string_literal: true
class Sbmt::KafkaConsumer::Config::Deserializer < Dry::Struct
transform_keys(&:to_sym)
attribute :klass, Sbmt::KafkaConsumer::Types::Strict::String
.optional
.default(Sbmt::KafkaConsumer::Serialization::NullDeserializer.to_s.freeze)
attribute :init_attrs, Sbmt::KafkaConsumer::Types::ConfigAttrs.optional.default({}.freeze)
def instantiate
return klass.constantize.new if init_attrs.blank?
klass.constantize.new(**init_attrs)
end
end
Version data entries
23 entries across 23 versions & 1 rubygems