Method: Fluent::Plugin::FileOutput#write

Defined in:

lib/fluent/plugin/out_file.rb

#write(chunk) ⇒ Object

# File 'lib/fluent/plugin/out_file.rb', line 202

def write(chunk)
  path = extract_placeholders(@path_template, chunk)
  FileUtils.mkdir_p File.dirname(path), mode: @dir_perm

  writer = case
           when @compress_method.nil?
             method(:write_without_compression)
           when @compress_method == :gzip
             if @buffer.compress != :gzip || @recompress
               method(:write_gzip_with_compression)
             else
               method(:write_gzip_from_gzipped_chunk)
             end
           else
             raise "BUG: unknown compression method #{@compress_method}"
           end

  if @append
    if @need_lock
      acquire_worker_lock(path) do
        writer.call(path, chunk)
      end
    else
      writer.call(path, chunk)
    end
  else
    find_filepath_available(path, with_lock: @need_lock) do |actual_path|
      writer.call(actual_path, chunk)
      path = actual_path
    end
  end

  @last_written_path = path
end