Method: Fluent::Plugin::StdoutFilter#filter_stream

Defined in:
lib/fluent/plugin/filter_stdout.rb

#filter_stream(tag, es) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/fluent/plugin/filter_stdout.rb', line 40

def filter_stream(tag, es)
  es.each { |time, record|
    begin
      r = inject_values_to_record(tag, time, record)
      log.write @formatter.format(tag, time, r)
    rescue => e
      router.emit_error_event(tag, time, record, e)
    end
  }
  log.flush
  es
end