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