Class: Fluent::ParsePostfixFilter
- Inherits:
-
Filter
- Object
- Filter
- Fluent::ParsePostfixFilter
- Defined in:
- lib/fluent/plugin/filter_parse_postfix.rb
Instance Method Summary collapse
Instance Method Details
#filter_stream(tag, es) ⇒ Object
11 12 13 14 15 16 17 18 19 20 21 22 |
# File 'lib/fluent/plugin/filter_parse_postfix.rb', line 11 def filter_stream(tag, es) result_es = Fluent::MultiEventStream.new es.each do |time, record| parse_postfix(time, record, result_es) end result_es rescue => e log.warn e. log.warn e.backtrace.join(', ') end |