module Fluent::MessagePackFactory

def self.engine_factory
  @@engine_factory || factory
end

def self.factory
  factory = MessagePack::Factory.new
  factory.register_type(Fluent::EventTime::TYPE, Fluent::EventTime)
  factory
end

def self.init
  factory = MessagePack::Factory.new
  factory.register_type(Fluent::EventTime::TYPE, Fluent::EventTime)
  @@engine_factory = factory
end

def self.packer(*args)
  factory.packer(*args)
end

def self.unpacker(*args)
  factory.unpacker(*args)
end