module Fluent::ChunkMessagePackEventStreamer

Public Instance Methods

each(unpacker: nil, &block) click to toggle source

chunk.extend(ChunkEventStreamer)

=> chunk.each{|time, record| ... }
# File lib/fluent/event.rb, line 313
def each(unpacker: nil, &block)
  open do |io|
    (unpacker || Fluent::MessagePackFactory.msgpack_unpacker(io)).each(&block)
  end
  nil
end
Also aliased as: msgpack_each
msgpack_each(unpacker: nil, &block)
Alias for: each
to_msgpack_stream(time_int: false, packer: nil) click to toggle source
# File lib/fluent/event.rb, line 321
def to_msgpack_stream(time_int: false, packer: nil)
  # time_int is always ignored because data is already packed and written in chunk
  read
end