Module: Fluent::MessagePackFactory

Defined in:
lib/fluent/msgpack_factory.rb

Defined Under Namespace

Modules: Mixin

Constant Summary collapse

@@engine_factory = 
nil

Class Method Summary collapse

Class Method Details

.engine_factory ⇒ Object 



38
39
40
 
# File 'lib/fluent/msgpack_factory.rb', line 38

def self.engine_factory
  @@engine_factory || factory
end

.factory ⇒ Object 



42
43
44
45
46
 
# File 'lib/fluent/msgpack_factory.rb', line 42

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

.init ⇒ Object 



56
57
58
59
60
 
# File 'lib/fluent/msgpack_factory.rb', line 56

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

.packer(*args) ⇒ Object 



48
49
50
 
# File 'lib/fluent/msgpack_factory.rb', line 48

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

.unpacker(*args) ⇒ Object 



52
53
54
 
# File 'lib/fluent/msgpack_factory.rb', line 52

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