Class/Module Index [+]

Quicksearch

Fluent::FileBufferChunk

Attributes

path[R]
unique_id[R]

Public Class Methods

new(key, path, unique_id, mode="a+") click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 22
def initialize(key, path, unique_id, mode="a+")
  super(key)
  @path = path
  @unique_id = unique_id
  @file = File.open(@path, mode, DEFAULT_FILE_PERMISSION)
  @file.sync = true
  @size = @file.stat.size
end

Public Instance Methods

<<(data) click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 33
def <<(data)
  @file.write(data)
  @size += data.bytesize
end
close() click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 46
def close
  stat = @file.stat
  @file.close
  if stat.size == 0
    File.unlink(@path)
  end
end
empty?() click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 42
def empty?
  @size == 0
end
mv(path) click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 71
def mv(path)
  File.rename(@path, path)
  @path = path
end
open(&block) click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 64
def open(&block)
  @file.pos = 0
  yield @file
end
purge() click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 54
def purge
  @file.close
  File.unlink(@path) rescue nil  # TODO rescue?
end
read() click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 59
def read
  @file.pos = 0
  @file.read
end
size() click to toggle source
# File lib/fluent/plugin/buf_file.rb, line 38
def size
  @size
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.