module Fluent::MessagePackFactory

Public Class Methods

engine_factory(enable_time_support: false) click to toggle source
# File lib/fluent/msgpack_factory.rb, line 54
def self.engine_factory(enable_time_support: false)
  @@engine_factory || factory(enable_time_support: enable_time_support)
end
factory(enable_time_support: false) click to toggle source
# 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
init(enable_time_support: false) click to toggle source
# File lib/fluent/msgpack_factory.rb, line 86
def self.init(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
  @@engine_factory = factory
end
msgpack_packer(*args) click to toggle source
# File lib/fluent/msgpack_factory.rb, line 58
def self.msgpack_packer(*args)
  engine_factory.packer(*args)
end
msgpack_unpacker(*args) click to toggle source
# File lib/fluent/msgpack_factory.rb, line 62
def self.msgpack_unpacker(*args)
  engine_factory.unpacker(*args)
end
packer(*args) click to toggle source
# File lib/fluent/msgpack_factory.rb, line 78
def self.packer(*args)
  factory.packer(*args)
end
thread_local_msgpack_packer() click to toggle source
# File lib/fluent/msgpack_factory.rb, line 98
def self.thread_local_msgpack_packer
  Thread.current[:local_msgpack_packer] ||= MessagePackFactory.engine_factory.packer
end
thread_local_msgpack_unpacker() click to toggle source
# File lib/fluent/msgpack_factory.rb, line 102
def self.thread_local_msgpack_unpacker
  Thread.current[:local_msgpack_unpacker] ||= MessagePackFactory.engine_factory.unpacker
end
unpacker(*args) click to toggle source
# File lib/fluent/msgpack_factory.rb, line 82
def self.unpacker(*args)
  factory.unpacker(*args)
end