Fluent::BufferedOutput
# File lib/fluent/output.rb, line 401 def initialize super end
# File lib/fluent/output.rb, line 405 def emit(tag, es, chain) data = es.to_msgpack_stream key = tag if @buffer.emit(key, data, chain) submit_flush end end
# File lib/fluent/output.rb, line 429 def write(chunk) chunk.extend(BufferedEventStreamMixin) write_objects(chunk.key, chunk) end
[Validate]
Generated with the Darkfish Rdoc Generator 2.