config_param_for_producer

in lib/fluent/plugin/kinesis_helper/class_methods.rb [45:70]

• 24 lines of code
• 2 McCabe index (conditional complexity)

      def config_param_for_producer
        const_set(:RequestType, :producer)
        config_param :stream_name,        :string, default: nil
        config_param :stream_name_prefix, :string, default: nil
        config_param :region,             :string, default: nil
        config_param :partition_key,      :string, default: nil
        config_param_for_credentials
        config_param_for_format
        config_param_for_debug

        config_section :kinesis_producer, multi: false do
          require 'kinesis_producer'
          type_map = {
            Protobuf::Field::BoolField   => :bool,
            Protobuf::Field::Uint64Field => :integer,
            Protobuf::Field::StringField => :string,
          }
          KinesisProducer::ConfigurationFields.each do |field|
            next if field.name == 'region'
            type = type_map[field.type_class]
            config_param field.name, type, default: field.default_value
          end
          config_param :credentials_refresh_delay, :integer, default: 5000
        end
      end