WIP

Author: Watson1978

lib/fluent/plugin/in_opentelemetry_metrics.rb

@@ -51,24 +51,9 @@ def metrics_data
             {
               "resource" => {
                 "attributes" => [
-                  {
-                    "key" => "service.name",
-                    "value" => {
-                      "stringValue" => "fluentd"
-                    }
-                  },
-                  {
-                    "key" => "service.version",
-                    "value" => {
-                      "stringValue" => Fluent::VERSION
-                    }
-                  },
-                  {
-                    "key" => "process.pid",
-                    "value" => {
-                      "intValue" => Process.pid
-                    }
-                  }
+                  string_value_attribute("service.name", "fluentd"),
+                  string_value_attribute("service.version", Fluent::VERSION),
+                  int_value_attribute("process.pid", Process.pid)
                 ]
               },
               "scopeMetrics" => scope_metrics
@@ -104,14 +89,7 @@ def scope_metrics
       end
 
       def metrics_value(time, record, attrs, metrics = [])
-        attributes = attrs.map do |k, v|
-          {
-            "key" => k.to_s,
-            "value" => {
-              "stringValue" => v.to_s
-            }
-          }
-        end
+        attributes = attrs.map { |k, v| string_value_attribute(k, v) }
 
         record.each do |key, value|
           if value.is_a?(Numeric)
@@ -133,6 +111,24 @@ def metrics_value(time, record, attrs, metrics = [])
           end
         end
       end
+
+      def string_value_attribute(key, value)
+        {
+          "key" => key.to_s,
+          "value" => {
+            "stringValue" => value.to_s
+          }
+        }
+      end
+
+      def int_value_attribute(key, value)
+        {
+          "key" => key.to_s,
+          "value" => {
+            "intValue" => value
+          }
+        }
+      end
     end
 
     class MonitorInfo