Sha256: 89d8e17da4b758ec553f37a261080e1bb1a9a5b31975ca2aaa1d736dc960af40
Contents?: true
Size: 1.8 KB
Versions: 84
Compression:
Stored size: 1.8 KB
Contents
require_relative '../helper'
require 'fluent/plugin_helper/event_emitter'
require 'fluent/plugin/base'
require 'flexmock/test_unit'
class EventEmitterTest < Test::Unit::TestCase
setup do
Fluent::Test.setup
end
class Dummy0 < Fluent::Plugin::TestBase
end
class Dummy < Fluent::Plugin::TestBase
helpers :event_emitter
end
test 'can be instantiated to be able to emit with router' do
d0 = Dummy0.new
assert d0.respond_to?(:has_router?)
assert !d0.has_router?
assert !d0.respond_to?(:router)
d1 = Dummy.new
assert d1.respond_to?(:has_router?)
assert d1.has_router?
assert d1.respond_to?(:router)
d1.stop; d1.shutdown; d1.close; d1.terminate
end
test 'can be configured with valid router' do
d1 = Dummy.new
assert d1.has_router?
assert_nil d1.router
assert_nothing_raised do
d1.configure(config_element())
end
assert d1.router
d1.shutdown
assert d1.router
d1.close
assert_nil d1.router
d1.terminate
end
test 'should not have event_emitter_router' do
d0 = Dummy0.new
assert !d0.respond_to?(:event_emitter_router)
end
test 'should have event_emitter_router' do
d = Dummy.new
assert d.respond_to?(:event_emitter_router)
end
test 'get router' do
router_mock = flexmock('mytest')
label_mock = flexmock('mylabel')
label_mock.should_receive(:event_router).twice.and_return(router_mock)
Fluent::Engine.root_agent.labels['@mytest'] = label_mock
d = Dummy.new
d.configure(config_element('ROOT', '', {'@label' => '@mytest'}))
router = d.event_emitter_router("@mytest")
assert_equal router_mock, router
end
test 'get root router' do
d = Dummy.new
router = d.event_emitter_router("@ROOT")
assert_equal Fluent::Engine.root_agent.event_router, router
end
end
Version data entries
84 entries across 84 versions & 7 rubygems