# File lib/fluent/plugin/buf_memory.rb, line 25 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 & 0xffffffff, rand(0xffffffff), rand(0xffffffff)].pack('NNNN') super(key) end
# File lib/fluent/plugin/buf_memory.rb, line 36 def <<(data) data.force_encoding('ASCII-8BIT') @data << data end
# File lib/fluent/plugin/buf_memory.rb, line 45 def close end
optimize
# File lib/fluent/plugin/buf_memory.rb, line 65 def msgpack_each(&block) u = Fluent::Engine.msgpack_factory.unpacker u.feed_each(@data, &block) end
# File lib/fluent/plugin/buf_memory.rb, line 55 def open(&block) StringIO.open(@data, &block) end
# File lib/fluent/plugin/buf_memory.rb, line 48 def purge end
# File lib/fluent/plugin/buf_memory.rb, line 51 def read @data end
# File lib/fluent/plugin/buf_memory.rb, line 41 def size @data.bytesize end
optimize
# File lib/fluent/plugin/buf_memory.rb, line 60 def write_to(io) io.write @data end