Method: Fluent::Plugin::Output#backup_chunk

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

#backup_chunk(chunk, using_secondary, delayed_commit) ⇒ Object 



1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
 
# File 'lib/fluent/plugin/output.rb', line 1287

def backup_chunk(chunk, using_secondary, delayed_commit)
  if @buffer.disable_chunk_backup
    log.warn "disable_chunk_backup is true. #{dump_unique_id_hex(chunk.unique_id)} chunk is thrown away"
  else
    @buffer.backup(chunk.unique_id) { |f|
      chunk.write_to(f)
    }
  end
  commit_write(chunk.unique_id, secondary: using_secondary, delayed: delayed_commit)
end