Sha256: 5923b5f6bd9c73a8e1fa72527ce8958ac01218f99008c06aa803131807d24afa
Contents?: true
Size: 812 Bytes
Versions: 293
Compression:
Stored size: 812 Bytes
Contents
require_relative 'helper'
require 'fluent/input'
class FluentInputTest < ::Test::Unit::TestCase
include Fluent
def setup
Fluent::Test.setup
end
def create_driver(conf = '')
Fluent::Test::InputTestDriver.new(Fluent::Input).configure(conf, true)
end
def test_router
d = create_driver
assert_equal Engine.root_agent.event_router, d.instance.router
d = nil
assert_nothing_raised {
d = create_driver('@label @known')
}
expected = Engine.root_agent.find_label('@known').event_router
assert_equal expected, d.instance.router
# TestDriver helps to create a label instance automatically, so directly test here
assert_raise(ArgumentError) {
Fluent::Input.new.configure(Config.parse('@label @unknown', '(test)', '(test_dir)', true))
}
end
end
Version data entries
293 entries across 293 versions & 8 rubygems