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