Methods

Class/Module Index [+]

Quicksearch

Fluent::ObjectBufferedOutput

Public Class Methods

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

Public Instance Methods

emit(tag, es, chain) click to toggle source
# 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
write(chunk) click to toggle source
# 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.