change port

Author: Watson1978

test/fluent/plugin/test_in_otlp.rb

@@ -11,7 +11,7 @@ def config
       tag otlp.test
       <http>
         bind 127.0.0.1
-        port 4318
+        port 14318
       </http>
     CONFIG
   end
@@ -38,7 +38,7 @@ def test_configure
     d = create_driver
     assert_equal "otlp.test", d.instance.tag
     assert_equal "127.0.0.1", d.instance.http_config.bind
-    assert_equal 4318, d.instance.http_config.port
+    assert_equal 14318, d.instance.http_config.port
   end
 
   data("metrics" => {
@@ -163,7 +163,7 @@ def config
         tag otlp.test
         <http>
           bind 127.0.0.1
-          port 4318
+          port 14318
         </http>
         <transport tls>
           ca_path "#{File.expand_path(File.dirname(__FILE__) + '/../resources/certs/ca.crt')}"
@@ -205,7 +205,7 @@ def compress(data)
 
   def post_https_json(path, json, headers: {})
     headers = headers.merge({ "Content-Type" => "application/json" })
-    post(path, json, endpoint: "https://127.0.0.1:4318", headers: headers, options: https_option)
+    post(path, json, endpoint: "https://127.0.0.1:14318", headers: headers, options: https_option)
   end
 
   def post_json(path, json, headers: {}, options: {})
@@ -215,15 +215,15 @@ def post_json(path, json, headers: {}, options: {})
 
   def post_https_protobuf(path, binary, headers: {}, options: {})
     headers = headers.merge({ "Content-Type" => "application/x-protobuf" })
-    post(path, binary, endpoint: "https://127.0.0.1:4318", headers: headers, options: options)
+    post(path, binary, endpoint: "https://127.0.0.1:14318", headers: headers, options: options)
   end
 
   def post_protobuf(path, binary, headers: {}, options: {})
     headers = headers.merge({ "Content-Type" => "application/x-protobuf" })
     post(path, binary, headers: headers, options: options)
   end
 
-  def post(path, body, endpoint: "http://127.0.0.1:4318", headers: {}, options: {})
+  def post(path, body, endpoint: "http://127.0.0.1:14318", headers: {}, options: {})
     connection = Excon.new("#{endpoint}#{path}", body: body, headers: headers, **options)
     connection.post
   end

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:4318"
+        endpoint "http://127.0.0.1:14318"
       </http>
     CONFIG
   end
 
   def server_config
-    config = { BindAddress: "127.0.0.1", Port: "4318" }
+    config = { BindAddress: "127.0.0.1", Port: "14318" }
     # Suppress webrick logs
     config[:Logger] = DEFAULT_LOGGER
     config[:AccessLog] = []
@@ -83,7 +83,7 @@ def create_driver(conf = config)
 
   def test_configure
     d = create_driver
-    assert_equal "http://127.0.0.1:4318", d.instance.http_config.endpoint
+    assert_equal "http://127.0.0.1:14318", d.instance.http_config.endpoint
   end
 
   def test_send_logs
@@ -152,7 +152,7 @@ def test_unrecoverable_error
       d.feed(event)
     end
 
-    assert_match(%r{got unrecoverable error response from 'http://127.0.0.1:4318/v1/logs', response code is 500},
+    assert_match(%r{got unrecoverable error response from 'http://127.0.0.1:14318/v1/logs', response code is 500},
                  d.instance.log.out.logs.join)
 
     d.instance_shutdown
@@ -164,15 +164,15 @@ def test_error_with_disabled_unrecoverable
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:4318"
+        endpoint "http://127.0.0.1:14318"
         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:4318/v1/logs', response code is 500},
+    assert_match(%r{got error response from 'http://127.0.0.1:14318/v1/logs', response code is 500},
                  d.instance.log.out.logs.join)
 
     d.instance_shutdown
@@ -187,7 +187,7 @@ def test_write_with_retryable_response
 
     d = create_driver(%[
       <http>
-        endpoint "http://127.0.0.1:4318"
+        endpoint "http://127.0.0.1:14318"
         retryable_response_codes [503]
       </http>
     ])