class Fluent::Plugin::KVParser
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/parser_kv.rb, line 13 def configure(conf) super if @kv_delimiter[0] == '/' and @kv_delimiter[-1] == '/' @kv_delimiter = Regexp.new(@kv_delimiter[1..-2]) end end
parse(text) { |time, record| ... }
click to toggle source
# File lib/fluent/plugin/parser_kv.rb, line 20 def parse(text) record = {} text.split(@kv_delimiter).each do |kv| key, value = kv.split(@kv_char, 2) record[key] = value end time = parse_time(record) time, record = convert_values(time, record) yield time, record end