module Fluent::Compat::TypeConverter
Private Class Methods
included(klass)
click to toggle source
# File lib/fluent/compat/type_converter.rb, line 40 def self.included(klass) klass.instance_eval { config_param :types, :string, default: nil config_param :types_delimiter, :string, default: ',' config_param :types_label_delimiter, :string, default: ':' } end
Private Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/compat/type_converter.rb, line 48 def configure(conf) super @type_converters = nil @type_converters = parse_types_parameter unless @types.nil? end
convert_type(name, value)
click to toggle source
# File lib/fluent/compat/type_converter.rb, line 57 def convert_type(name, value) converter = @type_converters[name] converter.nil? ? value : converter.call(value) end
parse_types_parameter()
click to toggle source
# File lib/fluent/compat/type_converter.rb, line 62 def parse_types_parameter converters = {} @types.split(@types_delimiter).each { |pattern_name| name, type, format = pattern_name.split(@types_label_delimiter, 3) raise ConfigError, "Type is needed" if type.nil? case type when 'time' require 'fluent/parser' t_parser = Fluent::TextParser::TimeParser.new(format) converters[name] = lambda { |v| Converters[type].call(v, t_parser) } when 'array' delimiter = format || ',' converters[name] = lambda { |v| Converters[type].call(v, delimiter) } else converters[name] = Converters[type] end } converters end