class Fluent::Plugin::MessagePackParser

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method Fluent::Plugin::Parser#configure
# File lib/fluent/plugin/parser_msgpack.rb, line 25
def configure(conf)
  super
  @unpacker = Fluent::MessagePackFactory.engine_factory.unpacker
end
parse(data) { |convert_values(parse_time(obj), obj)| ... } click to toggle source
# File lib/fluent/plugin/parser_msgpack.rb, line 34
def parse(data)
  @unpacker.feed_each(data) do |obj|
    yield convert_values(parse_time(obj), obj)
  end
end
Also aliased as: parse_partial_data
parse_io(io) { |time, record| ... } click to toggle source
# File lib/fluent/plugin/parser_msgpack.rb, line 41
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
parse_partial_data(data)
Alias for: parse
parser_type() click to toggle source
# File lib/fluent/plugin/parser_msgpack.rb, line 30
def parser_type
  :binary
end