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 unpacker = Thread.current[:local_msgpack_unpacker] if unpacker.nil? return Thread.current[:local_msgpack_unpacker] = MessagePackFactory.engine_factory.unpacker end unpacker.reset unpacker end
unpacker(*args)
click to toggle source
# File lib/fluent/msgpack_factory.rb, line 82 def self.unpacker(*args) factory.unpacker(*args) end