Method: Fluent::MessagePackFactory.factory

Defined in:
lib/fluent/msgpack_factory.rb

.factory(enable_time_support: false) ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/fluent/msgpack_factory.rb', line 66

def self.factory(enable_time_support: false)
  factory = MessagePack::Factory.new
  factory.register_type(Fluent::EventTime::TYPE, Fluent::EventTime)
  if enable_time_support
    factory.register_type(
      MessagePack::Timestamp::TYPE, Time,
      packer: MessagePack::Time::Packer,
      unpacker: MessagePack::Time::Unpacker)
  end
  factory
end