class Fluent::EventStream
Public Instance Methods
each(&block)
click to toggle source
# File lib/fluent/event.rb, line 26 def each(&block) raise NotImplementedError, "DO NOT USE THIS CLASS directly." end
repeatable?()
click to toggle source
# File lib/fluent/event.rb, line 22 def repeatable? false end
to_msgpack_stream()
click to toggle source
# File lib/fluent/event.rb, line 30 def to_msgpack_stream out = $use_msgpack_5 ? MessagePack::Buffer.new : ''.force_encoding('ASCII-8BIT') each {|time,record| [time,record].to_msgpack(out) } out.to_s end