class Fluent::Test::Driver::TestEventRouter

Public Class Methods

new(driver) click to toggle source
# File lib/fluent/test/driver/test_event_router.rb, line 23
def initialize(driver)
  @driver = driver
end

Public Instance Methods

emit(tag, time, record) click to toggle source
# File lib/fluent/test/driver/test_event_router.rb, line 27
def emit(tag, time, record)
  @driver.emit_event_stream(tag, OneEventStream.new(time, record))
end
emit_array(tag, array) click to toggle source
# File lib/fluent/test/driver/test_event_router.rb, line 31
def emit_array(tag, array)
  @driver.emit_event_stream(tag, ArrayEventStream.new(array))
end
emit_error_event(tag, time, record, error) click to toggle source
# File lib/fluent/test/driver/test_event_router.rb, line 39
def emit_error_event(tag, time, record, error)
  @driver.emit_error_event(tag, time, record, error)
end
emit_stream(tag, es) click to toggle source
# File lib/fluent/test/driver/test_event_router.rb, line 35
def emit_stream(tag, es)
  @driver.emit_event_stream(tag, es)
end