Module: Fluent::FileOutput::SymlinkBufferMixin

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

Instance Method Summary collapse

Instance Method Details

#generate_chunk(metadata) ⇒ Object 



60
61
62
63
64
65
66
67
 
# File 'lib/fluent/plugin/out_file.rb', line 60

def generate_chunk(metadata)
  chunk = super
  latest_chunk = metadata_list.sort_by(&:timekey).last
  if chunk.metadata == latest_chunk
    FileUtils.ln_sf(chunk.path, @_symlink_path)
  end
  chunk
end

#symlink_path=(path) ⇒ Object 



56
57
58
 
# File 'lib/fluent/plugin/out_file.rb', line 56

def symlink_path=(path)
  @_symlink_path = path
end