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