Parent

Class/Module Index [+]

Quicksearch

Fluent::TestOutput

Attributes

emit_streams[R]
name[R]

Public Class Methods

new() click to toggle source
# File lib/fluent/plugin/out_test.rb, line 24
def initialize
  @emit_streams = []
  @name = nil
end

Public Instance Methods

configure(conf) click to toggle source
# File lib/fluent/plugin/out_test.rb, line 59
def configure(conf)
  if name = conf['name']
    @name = name
  end
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/plugin/out_test.rb, line 71
def emit(tag, es, chain)
  chain.next
  @emit_streams << [tag, es.to_a]
end
emits() click to toggle source
# File lib/fluent/plugin/out_test.rb, line 31
def emits
  all = []
  @emit_streams.each {|tag,events|
    events.each {|time,record|
      all << [tag, time, record]
    }
  }
  all
end
events() click to toggle source
# File lib/fluent/plugin/out_test.rb, line 41
def events
  all = []
  @emit_streams.each {|tag,events|
    all.concat events
  }
  all
end
records() click to toggle source
# File lib/fluent/plugin/out_test.rb, line 49
def records
  all = []
  @emit_streams.each {|tag,events|
    events.each {|time,record|
      all << record
    }
  }
  all
end
shutdown() click to toggle source
# File lib/fluent/plugin/out_test.rb, line 68
def shutdown
end
start() click to toggle source
# File lib/fluent/plugin/out_test.rb, line 65
def start
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.