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 72
def initialize(key)
  super()
  @key = key
end

Public Instance Methods

<<(data) click to toggle source
# File lib/fluent/buffer.rb, line 79
def <<(data)
  raise NotImplementedError, "Implement this method in child class"
end
close() click to toggle source
# File lib/fluent/buffer.rb, line 91
def close
  raise NotImplementedError, "Implement this method in child class"
end
empty?() click to toggle source
# File lib/fluent/buffer.rb, line 87
def empty?
  size == 0
end
msgpack_each(&block) click to toggle source
# File lib/fluent/buffer.rb, line 113
def msgpack_each(&block)
  open {|io|
    u = MessagePack::Unpacker.new(io)
    begin
      u.each(&block)
    rescue EOFError
    end
  }
end
open() click to toggle source
# File lib/fluent/buffer.rb, line 103
def open
  raise NotImplementedError, "Implement this method in child class"
end
purge() click to toggle source
# File lib/fluent/buffer.rb, line 95
def purge
  raise NotImplementedError, "Implement this method in child class"
end
read() click to toggle source
# File lib/fluent/buffer.rb, line 99
def read
  raise NotImplementedError, "Implement this method in child class"
end
size() click to toggle source
# File lib/fluent/buffer.rb, line 83
def size
  raise NotImplementedError, "Implement this method in child class"
end
write_to(io) click to toggle source
# File lib/fluent/buffer.rb, line 107
def write_to(io)
  open {|i|
    FileUtils.copy_stream(i, io)
  }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.