test/plugin/test_in_opensearch.rb in test-opensearch-0.0.0.2 vs test/plugin/test_in_opensearch.rb in test-opensearch-0.0.0.3
- old
+ new
@@ -37,11 +37,11 @@
include Fluent::Test::Helpers
CONFIG = %[
tag raw.opensearch
interval 2
- infinite_check_connection false
+ check_connection false
]
def setup
Fluent::Test.setup
@driver = nil
@@ -189,11 +189,11 @@
scheme https
path /es/
user john
password doe
tag raw.opensearch
- infinite_check_connection false
+ check_connection false
}
instance = driver(config).instance
expected_query = { "sort" => [ "_doc" ]}
assert_equal 'logs.google.com', instance.host
@@ -228,11 +228,11 @@
config = %{
host logs.google.com
user john
password doe
tag raw.opensearch
- infinite_check_connection false
+ check_connection false
}
instance = driver(config).instance
assert_equal 1, instance.get_connection_options[:hosts].length
host1 = instance.get_connection_options[:hosts][0]
@@ -250,11 +250,11 @@
config = %{
host logs.google.com
user %{j+hn}
password %{d@e}
tag raw.opensearch
- infinite_check_connection false
+ check_connection false
}
instance = driver(config).instance
assert_equal 1, instance.get_connection_options[:hosts].length
host1 = instance.get_connection_options[:hosts][0]
@@ -273,11 +273,11 @@
hosts host1:50,host2:100,host3
scheme https
path /es/
port 123
tag raw.opensearch
- infinite_check_connection false
+ check_connection false
}
instance = driver(config).instance
assert_equal 3, instance.get_connection_options[:hosts].length
host1, host2, host3 = instance.get_connection_options[:hosts]
@@ -298,11 +298,11 @@
hosts https://john:password@host1:443/elastic/,http://host2
path /default_path
user default_user
password default_password
tag raw.opensearch
- infinite_check_connection false
+ check_connection false
}
instance = driver(config).instance
assert_equal 2, instance.get_connection_options[:hosts].length
host1, host2 = instance.get_connection_options[:hosts]
@@ -327,10 +327,10 @@
hosts https://%{j+hn}:%{passw@rd}@host1:443/elastic/,http://host2
path /default_path
user default_user
password default_password
tag raw.opensearch
- infinite_check_connection false
+ check_connection false
}
instance = driver(config).instance
assert_equal 2, instance.get_connection_options[:hosts].length
host1, host2 = instance.get_connection_options[:hosts]