class Fluent::StdoutFilter
Attributes
formatter[R]
for tests
Public Instance Methods
configure(conf)
click to toggle source
config_param :output_type, :string, :default => 'json' (StdoutFormatter defines this)
Calls superclass method
Fluent::Filter#configure
# File lib/fluent/plugin/filter_stdout.rb, line 27 def configure(conf) super @formatter = Plugin.new_formatter(@format) @formatter.configure(conf) end
filter_stream(tag, es)
click to toggle source
# File lib/fluent/plugin/filter_stdout.rb, line 34 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