# File lib/fluent/output.rb, line 459 def initialize super end
# File lib/fluent/output.rb, line 463 def emit(tag, es, chain) @emit_count += 1 data = es.to_msgpack_stream key = tag if @buffer.emit(key, data, chain) submit_flush end end
# File lib/fluent/output.rb, line 488 def write(chunk) chunk.extend(BufferedEventStreamMixin) write_objects(chunk.key, chunk) end