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 37
def initialize(klass, tag='test', &block)
  super(klass, &block)
  @tag = tag
end

Public Instance Methods

emit(record, time=Engine.now) click to toggle source
# File lib/fluent/test/output_test.rb, line 44
def emit(record, time=Engine.now)
  es = OneEventStream.new(time, record)
  @instance.emit_events(@tag, es)
end