for tests
config_param :output_type, :string, :default => 'json' (StdoutFormatter defines this)
# File lib/fluent/plugin/filter_stdout.rb, line 31 def configure(conf) super @formatter = Plugin.new_formatter(@format) @formatter.configure(conf) end
# File lib/fluent/plugin/filter_stdout.rb, line 38 def filter_stream(tag, es) es.each { |time, record| begin log.write @formatter.format(tag, time, record) rescue => e router.emit_error_event(tag, time, record, e) end } log.flush es end