in_opentelemetry: use String for record keys (#6)

Signed-off-by: Shizuo Fujita <[email protected]>

Author: Watson1978

lib/fluent/plugin/in_opentelemetry.rb

@@ -59,13 +59,13 @@ def start
         http_handler = Opentelemetry::HttpInputHandler.new
         http_server_create_http_server(:in_opentelemetry_http_server, addr: @http_config.bind, port: @http_config.port, logger: log) do |serv|
           serv.post("/v1/logs") do |req|
-            http_handler.logs(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: Opentelemetry::RECORD_TYPE_LOGS, message: record }) }
+            http_handler.logs(req) { |record| router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_LOGS, "message" => record }) }
           end
           serv.post("/v1/metrics") do |req|
-            http_handler.metrics(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: Opentelemetry::RECORD_TYPE_METRICS, message: record }) }
+            http_handler.metrics(req) { |record| router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_METRICS, "message" => record }) }
           end
           serv.post("/v1/traces") do |req|
-            http_handler.traces(req) { |record| router.emit(@tag, Fluent::EventTime.now, { type: Opentelemetry::RECORD_TYPE_TRACES, message: record }) }
+            http_handler.traces(req) { |record| router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_TRACES, "message" => record }) }
           end
         end
       end
@@ -75,13 +75,13 @@ def start
           grpc_handler = Opentelemetry::GrpcInputHandler.new(@grpc_config, log)
           grpc_handler.run(
             logs: lambda { |record|
-              router.emit(@tag, Fluent::EventTime.now, { type: Opentelemetry::RECORD_TYPE_LOGS, message: record })
+              router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_LOGS, "message" => record })
             },
             metrics: lambda { |record|
-              router.emit(@tag, Fluent::EventTime.now, { type: Opentelemetry::RECORD_TYPE_METRICS, message: record })
+              router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_METRICS, "message" => record })
             },
             traces: lambda { |record|
-              router.emit(@tag, Fluent::EventTime.now, { type: Opentelemetry::RECORD_TYPE_TRACES, message: record })
+              router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_TRACES, "message" => record })
             }
           )
         end

test/fluent/plugin/test_in_opentelemetry.rb

@@ -154,7 +154,7 @@ def test_receive_json(data)
         post_json(data[:request_path], data[:request_data])
       end
 
-      expected_events = [["opentelemetry.test", @event_time, { type: data[:record_type], message: data[:record_data] }]]
+      expected_events = [["opentelemetry.test", @event_time, { "type" => data[:record_type], "message" => data[:record_data] }]]
       assert_equal(200, res.status)
       assert_equal(expected_events, d.events)
     end
@@ -165,7 +165,7 @@ def test_receive_compressed_json
         post_json("/v1/logs", compress(TestData::JSON::LOGS), headers: { "Content-Encoding" => "gzip" })
       end
 
-      expected_events = [["opentelemetry.test", @event_time, { type: "opentelemetry_logs", message: TestData::JSON::LOGS }]]
+      expected_events = [["opentelemetry.test", @event_time, { "type" => "opentelemetry_logs", "message" => TestData::JSON::LOGS }]]
       assert_equal(200, res.status)
       assert_equal(expected_events, d.events)
     end
@@ -203,7 +203,7 @@ def test_receive_protocol_buffers(data)
         post_protobuf(data[:request_path], data[:request_data])
       end
 
-      expected_events = [["opentelemetry.test", @event_time, { type: data[:record_type], message: data[:record_data] }]]
+      expected_events = [["opentelemetry.test", @event_time, { "type" => data[:record_type], "message" => data[:record_data] }]]
       assert_equal(200, res.status)
       assert_equal(expected_events, d.events)
     end
@@ -214,7 +214,7 @@ def test_receive_compressed_protocol_buffers
         post_protobuf("/v1/logs", compress(TestData::ProtocolBuffers::LOGS), headers: { "Content-Encoding" => "gzip" })
       end
 
-      expected_events = [["opentelemetry.test", @event_time, { type: "opentelemetry_logs", message: TestData::JSON::LOGS }]]
+      expected_events = [["opentelemetry.test", @event_time, { "type" => "opentelemetry_logs", "message" => TestData::JSON::LOGS }]]
       assert_equal(200, res.status)
       assert_equal(expected_events, d.events)
     end
@@ -270,7 +270,7 @@ def test_https_receive_json
         post_https_json("/v1/logs", TestData::JSON::LOGS)
       end
 
-      expected_events = [["opentelemetry.test", @event_time, { type: "opentelemetry_logs", message: TestData::JSON::LOGS }]]
+      expected_events = [["opentelemetry.test", @event_time, { "type" => "opentelemetry_logs", "message" => TestData::JSON::LOGS }]]
       assert_equal(200, res.status)
       assert_equal(expected_events, d.events)
     end
@@ -281,7 +281,7 @@ def test_https_receive_protocol_buffers
         post_https_protobuf("/v1/logs", TestData::ProtocolBuffers::LOGS)
       end
 
-      expected_events = [["opentelemetry.test", @event_time, { type: "opentelemetry_logs", message: TestData::JSON::LOGS }]]
+      expected_events = [["opentelemetry.test", @event_time, { "type" => "opentelemetry_logs", "message" => TestData::JSON::LOGS }]]
       assert_equal(200, res.status)
       assert_equal(expected_events, d.events)
     end