Parent

Included Modules

Class/Module Index [+]

Quicksearch

Fluent::BufferChunk

Attributes

key[R]

Public Class Methods

new(key) click to toggle source
# File lib/fluent/buffer.rb, line 71
def initialize(key)
  super()
  @key = key
end

Public Instance Methods

empty?() click to toggle source

def size end

# File lib/fluent/buffer.rb, line 84
def empty?
  size == 0
end
msgpack_each(&block) click to toggle source
# File lib/fluent/buffer.rb, line 106
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 100
def write_to(io)
  open {|i|
    FileUtils.copy_stream(i, io)
  }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.