Method: Fluent::Plugin::Output#generate_format_proc

Defined in:
lib/fluent/plugin/output.rb

#generate_format_proc ⇒ Object 



1021
1022
1023
1024
1025
1026
1027
 
# File 'lib/fluent/plugin/output.rb', line 1021

def generate_format_proc
  if @buffer && @buffer.compress == :gzip
    @time_as_integer ? FORMAT_COMPRESSED_MSGPACK_STREAM_TIME_INT : FORMAT_COMPRESSED_MSGPACK_STREAM
  else
    @time_as_integer ? FORMAT_MSGPACK_STREAM_TIME_INT : FORMAT_MSGPACK_STREAM
  end
end