class Fluent::StdoutExOutput

Constants

OUTPUT_PROCS

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_stdout_ex.rb, line 39
def configure(conf)
  super
  @output_proc = OUTPUT_PROCS[@output_type]
  @format_proc =
    if @format == "ltsv"
      Proc.new {|time, tag, record| "current_time:#{Time.now.localtime}\ttime:#{Time.at(time).localtime}\ttag:#{tag}\trecord:#{@output_proc.call(record)}\n" }
    else
      # [info]: is a fake ;-)
      Proc.new {|time, tag, record| "#{Time.now.localtime} [info]: #{Time.at(time).localtime} #{tag}: #{@output_proc.call(record)}\n" }
    end
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/plugin/out_stdout_ex.rb, line 51
def emit(tag, es, chain)
  es.each {|time,record|
    $log.write @format_proc.call(time, tag, record)
  }
  $log.flush

  chain.next
end