class Fluent::TestOutput

def configure(conf)
  if name = conf['name']
    @name = name
  end
end

def emit(tag, es, chain)
  chain.next
  @emit_streams << [tag, es.to_a]
end

def emits
  all = []
  @emit_streams.each {|tag,events|
    events.each {|time,record|
      all << [tag, time, record]
    }
  }
  all
end

def events
  all = []
  @emit_streams.each {|tag,events|
    all.concat events
  }
  all
end

def initialize
  @emit_streams = []
  @name = nil
end

def records
  all = []
  @emit_streams.each {|tag,events|
    events.each {|time,record|
      all << record
    }
  }
  all
end

def shutdown
end

def start
end