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