Class: Fluent::ExecUtil::TextParserWrapperParser

Inherits:
Parser
  • Object
show all
Defined in:
lib/fluent/plugin/exec_util.rb

Instance Method Summary collapse

Constructor Details

#initialize(conf, on_message) ⇒ TextParserWrapperParser

Returns a new instance of TextParserWrapperParser.



39
40
41
42
43
 
# File 'lib/fluent/plugin/exec_util.rb', line 39

def initialize(conf, on_message)
  @parser = Plugin.new_parser(conf['format'])
  @parser.configure(conf)
  super(on_message)
end

Instance Method Details

#call(io) ⇒ Object 



45
46
47
 
# File 'lib/fluent/plugin/exec_util.rb', line 45

def call(io)
  io.each_line(&method(:each_line))
end

#each_line(line) ⇒ Object 



49
50
51
52
53
54
 
# File 'lib/fluent/plugin/exec_util.rb', line 49

def each_line(line)
  line.chomp!
  @parser.parse(line) { |time, record|
    @on_message.call(record, time)
  }
end