Sha256: a0a029e1930a3c6576b7197e876fdc00179101c55c6a30a074575dc47df34751
Contents?: true
Size: 1017 Bytes
Versions: 7
Compression:
Stored size: 1017 Bytes
Contents
require 'helper' class MysqlReplicatorInputTest < Test::Unit::TestCase def setup Fluent::Test.setup end CONFIG = %[ host localhost port 3306 interval 30 tag input.mysql query SELECT id, text from search_text record_hostname yes ] def create_driver(conf=CONFIG,tag='test') Fluent::Test::OutputTestDriver.new(Fluent::MysqlReplicatorInput, tag).configure(conf) end def test_configure assert_raise(Fluent::ConfigError) { d = create_driver('') } d = create_driver %[ host localhost port 3306 interval 30 tag input.mysql query SELECT id, text from search_text enable_delete no ] assert_equal 'localhost', d.instance.host assert_equal 3306, d.instance.port assert_equal 30, d.instance.interval assert_equal 'input.mysql', d.instance.tag assert_equal false, d.instance.enable_delete end end
Version data entries
7 entries across 7 versions & 1 rubygems