# File lib/fluent/plugin/out_stdout.rb, line 48 def initialize super @delayed = false end
# File lib/fluent/plugin/out_stdout.rb, line 53 def configure(conf) if conf['output_type'] && !conf['format'] conf['format'] = conf['output_type'] end compat_parameters_convert(conf, :inject, :formatter) super @formatter = formatter_create(conf: conf.elements('format').first, default_type: DEFAULT_FORMAT_TYPE) end
# File lib/fluent/plugin/out_stdout.rb, line 71 def format(tag, time, record) record = inject_values_to_record(tag, time, record) "#{Time.at(time).localtime.strftime(TIME_FORMAT)} #{tag}: #{@formatter.format(tag, time, record).chomp}\n" end
# File lib/fluent/plugin/out_stdout.rb, line 38 def prefer_buffered_processing false end
# File lib/fluent/plugin/out_stdout.rb, line 42 def prefer_delayed_commit @delayed end
# File lib/fluent/plugin/out_stdout.rb, line 64 def process(tag, es) es.each {|time,record| $log.write(format(tag, time, record)) } $log.flush end
# File lib/fluent/plugin/out_stdout.rb, line 80 def try_write(chunk) chunk.write_to($log) commit_write(chunk.unique_id) end
# File lib/fluent/plugin/out_stdout.rb, line 76 def write(chunk) chunk.write_to($log) end