class 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