Method: Fluent::Plugin::Output#execute_chunking

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

#execute_chunking(tag, es, enqueue: false) ⇒ Object 



965
966
967
968
969
970
971
972
973
 
# File 'lib/fluent/plugin/output.rb', line 965

def execute_chunking(tag, es, enqueue: false)
  if @simple_chunking
    handle_stream_simple(tag, es, enqueue: enqueue)
  elsif @custom_format
    handle_stream_with_custom_format(tag, es, enqueue: enqueue)
  else
    handle_stream_with_standard_format(tag, es, enqueue: enqueue)
  end
end