WIP

Author: Watson1978

lib/fluent/plugin/in_opentelemetry_metrics.rb

@@ -101,7 +101,7 @@ def metrics
         @monitor_info.plugins_info_all.each do |record|
           attributes = {
             plugin_id: record["plugin_id"],
-            plugin: "#{record['plugin_category']}_#{record['type']}",
+            plugin: plugin_name(record["plugin_category"], record["type"]),
             plugin_category: record["plugin_category"],
             plugin_type: record["type"]
           }.map { |k, v| string_value_attribute(k, v) }
@@ -130,6 +130,20 @@ def metrics
         metrics
       end
 
+      def plugin_name(category, type)
+        prefix =
+          case category
+          when "input"
+            "in"
+          when "output"
+            "out"
+          else
+            category
+          end
+
+        "#{prefix}_#{type}"
+      end
+
       def string_value_attribute(key, value)
         {
           "key" => key.to_s,