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
parser_type()
click to toggle source
# File lib/fluent/plugin/parser_msgpack.rb, line 30 def parser_type :binary end