Parent

Included Modules

Class/Module Index [+]

Quicksearch

Fluent::EventStream

Public Instance Methods

each(&block) click to toggle source
# File lib/fluent/event.rb, line 25
def each(&block)
  raise NotImplementedError, "DO NOT USE THIS CLASS directly."
end
repeatable?() click to toggle source
# File lib/fluent/event.rb, line 21
def repeatable?
  false
end
to_msgpack_stream() click to toggle source
# File lib/fluent/event.rb, line 29
def to_msgpack_stream
  out = MessagePack::Packer.new # MessagePack::Packer is fastest way to serialize events
  each {|time,record|
    out.write([time,record])
  }
  out.to_s
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.