fix

Author: Watson1978

lib/fluent/plugin/otlp/request.rb

@@ -18,8 +18,8 @@ def initialize(body)
         end
     end
 
-    def encode
-      Opentelemetry::Proto::Collector::Logs::V1::ExportLogsServiceRequest.encode(@request)
+    def body
+      @request.class.encode(@request)
     end
 
     def record
@@ -37,8 +37,8 @@ def initialize(body)
         end
     end
 
-    def encode
-      Opentelemetry::Proto::Collector::Metrics::V1::ExportMetricsServiceRequest.encode(@request)
+    def body
+      @request.class.encode(@request)
     end
 
     def record
@@ -56,8 +56,8 @@ def initialize(body)
         end
     end
 
-    def encode
-      Opentelemetry::Proto::Collector::Trace::V1::ExportTraceServiceRequest.encode(@request)
+    def body
+      @request.class.encode(@request)
     end
 
     def record

lib/fluent/plugin/out_otlp.rb

@@ -132,13 +132,13 @@ def create_http_connection(chunk)
           case record["type"]
           when Otlp::RECORD_TYPE_LOGS
             uri = http_logs_endpoint
-            body = Otlp::Request::Logs.new(msg).encode
+            body = Otlp::Request::Logs.new(msg).body
           when Otlp::RECORD_TYPE_METRICS
             uri = http_metrics_endpoint
-            body = Otlp::Request::Metrics.new(msg).encode
+            body = Otlp::Request::Metrics.new(msg).body
           when Otlp::RECORD_TYPE_TRACES
             uri = http_traces_endpoint
-            body = Otlp::Request::Traces.new(msg).encode
+            body = Otlp::Request::Traces.new(msg).body
           end
         rescue Google::Protobuf::ParseError => e
           # The message format does not comply with the OpenTelemetry protocol.

test/helper.rb

@@ -26,9 +26,9 @@ module JSON
   end
 
   module ProtocolBuffers
-    METRICS = Fluent::Plugin::Otlp::Request::Metrics.new(TestData::JSON::METRICS).encode
-    TRACES = Fluent::Plugin::Otlp::Request::Traces.new(TestData::JSON::TRACES).encode
-    LOGS = Fluent::Plugin::Otlp::Request::Logs.new(TestData::JSON::LOGS).encode
+    METRICS = Fluent::Plugin::Otlp::Request::Metrics.new(TestData::JSON::METRICS).body
+    TRACES = Fluent::Plugin::Otlp::Request::Traces.new(TestData::JSON::TRACES).body
+    LOGS = Fluent::Plugin::Otlp::Request::Logs.new(TestData::JSON::LOGS).body
 
     INVALID = "invalid"
   end