Methods

Class/Module Index [+]

Quicksearch

Fluent::ObjectBufferedOutput

Public Class Methods

new() click to toggle source
# File lib/fluent/output.rb, line 419
def initialize
  super
end

Public Instance Methods

emit(tag, es, chain) click to toggle source
# File lib/fluent/output.rb, line 423
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 448
def write(chunk)
  chunk.extend(BufferedEventStreamMixin)
  write_objects(chunk.key, chunk)
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.