fix style

Author: Watson1978

lib/fluent/plugin/in_otlp.rb

@@ -92,13 +92,13 @@ def start
       handler = HttpHandler.new
       http_server_create_http_server(:in_otel_http_server_helper, addr: @http_config.bind, port: @http_config.port, logger: log) do |serv|
         serv.post("/v1/logs") do |req|
-          handler.logs(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: "otlp_logs", message: record }) }
+          handler.logs(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: Otlp::RECORD_TYPE_LOGS, message: record }) }
         end
         serv.post("/v1/metrics") do |req|
-          handler.metrics(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: "otlp_metrics", message: record }) }
+          handler.metrics(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: Otlp::RECORD_TYPE_METRICS, message: record }) }
         end
         serv.post("/v1/traces") do |req|
-          handler.traces(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: "otlp_traces", message: record }) }
+          handler.traces(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: Otlp::RECORD_TYPE_TRACES, message: record }) }
         end
       end
     end

lib/fluent/plugin/otlp/constant.rb

@@ -6,4 +6,8 @@ module Fluent::Plugin::Otlp
   CONTENT_TYPE_JSON = "application/json"
 
   CONTENT_ENCODING_GZIP = "gzip"
+
+  RECORD_TYPE_LOGS = "otlp_logs"
+  RECORD_TYPE_METRICS = "otlp_metrics"
+  RECORD_TYPE_TRACES = "otlp_traces"
 end

lib/fluent/plugin/out_otlp.rb

@@ -43,7 +43,7 @@ def format(tag, time, record)
     end
 
     def write(chunk)
-      uri, req = create_request(chunk)
+      uri, req = create_uri_request(chunk)
 
       Net::HTTP.start(uri.host, uri.port) do |http|
         http.request(req)
@@ -52,18 +52,18 @@ def write(chunk)
 
     private
 
-    def create_request(chunk)
+    def create_uri_request(chunk)
       record = JSON.parse(chunk.read)
       msg = record["message"]
 
       case record["type"]
-      when "otlp_logs"
+      when Otlp::RECORD_TYPE_LOGS
         uri = HTTP_LOGS_ENDPOINT
         body = Otlp::Request::Logs.new(msg).encode
-      when "otlp_metrics"
+      when Otlp::RECORD_TYPE_METRICS
         uri = HTTP_METRICS_ENDPOINT
         body = Otlp::Request::Metrics.new(msg).encode
-      when "otlp_traces"
+      when Otlp::RECORD_TYPE_TRACES
         uri = HTTP_TRACES_ENDPOINT
         body = Otlp::Request::Traces.new(msg).encode
       end