class Fluent::Test::OutputTestDriver
Attributes
tag[RW]
Public Class Methods
new(klass, tag='test', &block)
click to toggle source
Calls superclass method
Fluent::Test::InputTestDriver.new
# File lib/fluent/test/output_test.rb, line 33 def initialize(klass, tag='test', &block) super(klass, &block) @tag = tag end
Public Instance Methods
emit(record, time=Time.now)
click to toggle source
# File lib/fluent/test/output_test.rb, line 40 def emit(record, time=Time.now) es = OneEventStream.new(time.to_i, record) chain = TestOutputChain.new @instance.emit(@tag, es, chain) assert_equal 1, chain.called end