compress option

Author: Watson1978

lib/fluent/plugin/out_otlp.rb

@@ -33,15 +33,15 @@ class RetryableResponse < StandardError; end
       config_param :error_response_as_unrecoverable, :bool, default: true
       desc "The list of retryable response code"
       config_param :retryable_response_codes, :array, value_type: :integer, default: nil
+
+      desc "Compress request body"
+      config_param :compress, :enum, list: %i[text gzip], default: :text
     end
 
     config_section :transport, required: false, multi: false, init: true, param_name: :transport_config do
       config_argument :protocol, :enum, list: [:tls], default: nil
     end
 
-    desc "Compress request body"
-    config_param :compress, :enum, list: %i[text gzip], default: :text
-
     def configure(conf)
       super
 
@@ -115,7 +115,7 @@ def create_connection(chunk)
       end
 
       headers = { Otlp::CONTENT_TYPE => Otlp::CONTENT_TYPE_PROTOBUF }
-      if @compress == :gzip
+      if @http_config.compress == :gzip
         headers[Otlp::CONTENT_ENCODING] = Otlp::CONTENT_ENCODING_GZIP
         gz = Zlib::GzipWriter.new(StringIO.new)
         gz << body

test/fluent/plugin/test_out_otlp.rb

@@ -131,7 +131,12 @@ def test_send_traces
   def test_send_compressed_message
     event = { "type" => "otlp_logs", "message" => TestData::JSON::LOGS }
 
-    d = create_driver(config + "compress gzip")
+    d = create_driver(%[
+      <http>
+        endpoint "http://127.0.0.1:14318"
+        compress gzip
+      </http>
+    ])
     d.run(default_tag: "otlp.test") do
       d.feed(event)
     end