class Fluent::BufferChunk
Attributes
key[R]
Public Class Methods
new(key)
click to toggle source
Calls superclass method
# File lib/fluent/buffer.rb, line 69 def initialize(key) super() @key = key end
Public Instance Methods
empty?()
click to toggle source
def size end
# File lib/fluent/buffer.rb, line 82 def empty? size == 0 end
msgpack_each(&block)
click to toggle source
# File lib/fluent/buffer.rb, line 104 def msgpack_each(&block) open {|io| u = MessagePack::Unpacker.new(io) begin u.each(&block) rescue EOFError end } end
write_to(io)
click to toggle source
def open end
# File lib/fluent/buffer.rb, line 98 def write_to(io) open {|i| FileUtils.copy_stream(i, io) } end