<<(data)
click to toggle source
def <<(data)
raise NotImplementedError, "Implement this method in child class"
end
close()
click to toggle source
def close
raise NotImplementedError, "Implement this method in child class"
end
empty?()
click to toggle source
msgpack_each(&block)
click to toggle source
def msgpack_each(&block)
open {|io|
u = Fluent::Engine.msgpack_factory.unpacker(io)
begin
u.each(&block)
rescue EOFError
end
}
end
open()
click to toggle source
def open
raise NotImplementedError, "Implement this method in child class"
end
purge()
click to toggle source
def purge
raise NotImplementedError, "Implement this method in child class"
end
read()
click to toggle source
def read
raise NotImplementedError, "Implement this method in child class"
end
size()
click to toggle source
def size
raise NotImplementedError, "Implement this method in child class"
end
write_to(io)
click to toggle source
def write_to(io)
open {|i|
FileUtils.copy_stream(i, io)
}
end