port number

Author: Watson1978

test/fluent/plugin/test_out_otlp.rb

@@ -16,13 +16,13 @@ class Fluent::Plugin::OtlpOutputTest < Test::Unit::TestCase
   def config
     <<~CONFIG
       <http>
-        endpoint "http://127.0.0.1:14318"
+        endpoint "http://127.0.0.1:24318"
       </http>
     CONFIG
   end
 
   def server_config
-    config = { BindAddress: "127.0.0.1", Port: "14318" }
+    config = { BindAddress: "127.0.0.1", Port: "24318" }
     # Suppress webrick logs
     config[:Logger] = DEFAULT_LOGGER
     config[:AccessLog] = []
@@ -71,8 +71,8 @@ def setup
   end
 
   def teardown
-    @@server_request = nil
-    @@server_response_code = 200
+    p "!" * 80
+    p @@http_server_thread
     @@http_server_thread.kill
     @@http_server_thread = nil
   end
@@ -83,7 +83,7 @@ def create_driver(conf = config)
 
   def test_configure
     d = create_driver
-    assert_equal "http://127.0.0.1:14318", d.instance.http_config.endpoint
+    assert_equal "http://127.0.0.1:24318", d.instance.http_config.endpoint
   end
 
   def test_send_logs
@@ -133,7 +133,7 @@ def test_send_compressed_message
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:14318"
+        endpoint "http://127.0.0.1:24318"
         compress gzip
       </http>
     ])
@@ -157,7 +157,7 @@ def test_unrecoverable_error
       d.feed(event)
     end
 
-    assert_match(%r{got unrecoverable error response from 'http://127.0.0.1:14318/v1/logs', response code is 500},
+    assert_match(%r{got unrecoverable error response from 'http://127.0.0.1:24318/v1/logs', response code is 500},
                  d.instance.log.out.logs.join)
 
     d.instance_shutdown
@@ -169,15 +169,15 @@ def test_error_with_disabled_unrecoverable
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:14318"
+        endpoint "http://127.0.0.1:24318"
         error_response_as_unrecoverable false
       </http>
     ])
     d.run(default_tag: "otlp.test", shutdown: false) do
       d.feed(event)
     end
 
-    assert_match(%r{got error response from 'http://127.0.0.1:14318/v1/logs', response code is 500},
+    assert_match(%r{got error response from 'http://127.0.0.1:24318/v1/logs', response code is 500},
                  d.instance.log.out.logs.join)
 
     d.instance_shutdown
@@ -192,7 +192,7 @@ def test_write_with_retryable_response
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:14318"
+        endpoint "http://127.0.0.1:24318"
         retryable_response_codes [503]
       </http>
     ])
@@ -211,7 +211,7 @@ def test_write_with_retryable_response
   sub_test_case "HTTPS" do
     def server_config
       config = super
-      config[:Port] = "14318"
+      config[:Port] = "24318"
       # WEBrick supports self-generated self-signed certificate
       config[:SSLEnable] = true
       config[:SSLCertName] = [["CN", WEBrick::Utils.getservername]]
@@ -221,7 +221,7 @@ def server_config
     def config
       <<~"CONFIG"
         <http>
-          endpoint "https://127.0.0.1:14318"
+          endpoint "https://127.0.0.1:24318"
         </http>
         <transport tls>
           cert_path "#{File.expand_path(File.dirname(__FILE__) + '/../resources/certs/ca.crt')}"