class Fluent::EventStream

Public Instance Methods

each(&block) click to toggle source
# File lib/fluent/event.rb, line 27
def each(&block)
  raise NotImplementedError, "DO NOT USE THIS CLASS directly."
end
repeatable?() click to toggle source
# File lib/fluent/event.rb, line 23
def repeatable?
  false
end
to_msgpack_stream() click to toggle source
# File lib/fluent/event.rb, line 31
def to_msgpack_stream
  out = Fluent::Engine.msgpack_factory.packer
  each {|time,record|
    out.write([time,record])
  }
  out.to_s
end