class Fluent::Plugin::FileOutput
def write(chunk)
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 writer.call(path, chunk) 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