Parent

Methods

Class/Module Index [+]

Quicksearch

Fluent::StreamOutput::ReformatWriter

Public Class Methods

new(secondary) click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 63
def initialize(secondary)
  @secondary = secondary
end

Public Instance Methods

write(chunk) click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 67
def write(chunk)
  chain = NullOutputChain.instance
  chunk.open {|io|
    # TODO use MessagePackIoEventStream
    u = MessagePack::Unpacker.new(io)
    begin
      u.each {|(tag,entries)|
        es = MultiEventStream.new
        entries.each {|o|
          es.add(o[0], o[1])
        }
        @secondary.emit(tag, es, chain)
      }
    rescue EOFError
    end
  }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.