class Fluent::Plugin::MessagePackParser

def configure(conf)
  super
  @unpacker = Fluent::MessagePackFactory.engine_factory.unpacker
end

def parse(data)
  @unpacker.feed_each(data) do |obj|
    yield convert_values(parse_time(obj), obj)
  end
end

def parse_io(io, &block)
  u = Fluent::MessagePackFactory.engine_factory.unpacker(io)
  u.each do |obj|
    time, record = convert_values(parse_time(obj), obj)
    yield time, record
  end
end

def parser_type
  :binary
end