class Fluent::ObjectBufferedOutput
Public Class Methods
new()
click to toggle source
Calls superclass method
Fluent::BufferedOutput.new
# File lib/fluent/output.rb, line 432 def initialize super end
Public Instance Methods
emit(tag, es, chain)
click to toggle source
# File lib/fluent/output.rb, line 436 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
write(chunk)
click to toggle source
# File lib/fluent/output.rb, line 461 def write(chunk) chunk.extend(BufferedEventStreamMixin) write_objects(chunk.key, chunk) end