# File lib/fluent/plugin/buf_memory.rb, line 22 def initialize(key, data='') @data = data @data.force_encoding('ASCII-8BIT') now = Time.now.utc u1 = ((now.to_i*1000*1000+now.usec) << 12 | rand(0xfff)) @unique_id = [u1 >> 32, u1 & u1 & 0xffffffff, rand(0xffffffff), rand(0xffffffff)].pack('NNNN') super(key) end
# File lib/fluent/plugin/buf_memory.rb, line 33 def <<(data) data.force_encoding('ASCII-8BIT') @data << data end
optimize
# File lib/fluent/plugin/buf_memory.rb, line 62 def msgpack_each(&block) u = MessagePack::Unpacker.new u.feed_each(@data, &block) end
# File lib/fluent/plugin/buf_memory.rb, line 52 def open(&block) StringIO.open(@data, &block) end
Generated with the Darkfish Rdoc Generator 2.