Exporting tags consistently

src/OpenTelemetry.Exporter.Jaeger/Implementation/JaegerActivityExtensions.cs

@@ -230,20 +230,6 @@ public static JaegerSpanRef ToJaegerSpanRef(this in ActivityLink link)
             return new JaegerSpanRef(refType, traceId.Low, traceId.High, spanId.Low);
         }
 
-        public static JaegerTag ToJaegerTag(this KeyValuePair<string, object> attribute)
-        {
-            return attribute.Value switch
-            {
-                string s => new JaegerTag(attribute.Key, JaegerTagType.STRING, vStr: s),
-                int i => new JaegerTag(attribute.Key, JaegerTagType.LONG, vLong: Convert.ToInt64(i)),
-                long l => new JaegerTag(attribute.Key, JaegerTagType.LONG, vLong: l),
-                float f => new JaegerTag(attribute.Key, JaegerTagType.DOUBLE, vDouble: Convert.ToDouble(f)),
-                double d => new JaegerTag(attribute.Key, JaegerTagType.DOUBLE, vDouble: d),
-                bool b => new JaegerTag(attribute.Key, JaegerTagType.BOOL, vBool: b),
-                _ => new JaegerTag(attribute.Key, JaegerTagType.STRING, vStr: attribute.Value.ToString()),
-            };
-        }
-
         public static long ToEpochMicroseconds(this DateTime utcDateTime)
         {
             // Truncate sub-microsecond precision before offsetting by the Unix Epoch to avoid
@@ -260,42 +246,6 @@ public static long ToEpochMicroseconds(this DateTimeOffset timestamp)
             return microseconds - UnixEpochMicroseconds;
         }
 
-        private static void ProcessJaegerTagArray(ref PooledList<JaegerTag> tags, KeyValuePair<string, object> activityTag)
-        {
-            if (activityTag.Value is int[] intArray)
-            {
-                foreach (var item in intArray)
-                {
-                    JaegerTag jaegerTag = new JaegerTag(activityTag.Key, JaegerTagType.LONG, vLong: Convert.ToInt64(item));
-                    PooledList<JaegerTag>.Add(ref tags, jaegerTag);
-                }
-            }
-            else if (activityTag.Value is string[] stringArray)
-            {
-                foreach (var item in stringArray)
-                {
-                    JaegerTag jaegerTag = new JaegerTag(activityTag.Key, JaegerTagType.STRING, vStr: item);
-                    PooledList<JaegerTag>.Add(ref tags, jaegerTag);
-                }
-            }
-            else if (activityTag.Value is bool[] boolArray)
-            {
-                foreach (var item in boolArray)
-                {
-                    JaegerTag jaegerTag = new JaegerTag(activityTag.Key, JaegerTagType.BOOL, vBool: item);
-                    PooledList<JaegerTag>.Add(ref tags, jaegerTag);
-                }
-            }
-            else if (activityTag.Value is double[] doubleArray)
-            {
-                foreach (var item in doubleArray)
-                {
-                    JaegerTag jaegerTag = new JaegerTag(activityTag.Key, JaegerTagType.DOUBLE, vDouble: item);
-                    PooledList<JaegerTag>.Add(ref tags, jaegerTag);
-                }
-            }
-        }
-
         private struct TagEnumerationState : IActivityEnumerator<KeyValuePair<string, object>>, PeerServiceResolver.IPeerServiceState
         {
             public PooledList<JaegerTag> Tags;
@@ -316,14 +266,15 @@ private struct TagEnumerationState : IActivityEnumerator<KeyValuePair<string, ob
 
             public bool ForEach(KeyValuePair<string, object> activityTag)
             {
-                if (activityTag.Value is Array)
-                {
-                    ProcessJaegerTagArray(ref this.Tags, activityTag);
-                }
-                else if (activityTag.Value != null)
+                if (activityTag.Value != null)
                 {
                     var key = activityTag.Key;
-                    var jaegerTag = activityTag.ToJaegerTag();
+
+                    if (!JaegerTagTransformer.Instance.TryTransformTag(activityTag, out var jaegerTag))
+                    {
+                        return true;
+                    }
+
                     if (jaegerTag.VStr != null)
                     {
                         PeerServiceResolver.InspectTag(ref this, key, jaegerTag.VStr);
@@ -400,18 +351,14 @@ private struct EventTagsEnumerationState : IActivityEnumerator<KeyValuePair<stri
 
             public bool ForEach(KeyValuePair<string, object> tag)
             {
-                if (tag.Value is Array)
-                {
-                    ProcessJaegerTagArray(ref this.Tags, tag);
-                }
-                else if (tag.Value != null)
+                if (JaegerTagTransformer.Instance.TryTransformTag(tag, out var result))
                 {
-                    PooledList<JaegerTag>.Add(ref this.Tags, tag.ToJaegerTag());
-                }
+                    PooledList<JaegerTag>.Add(ref this.Tags, result);
 
-                if (tag.Key == "event")
-                {
-                    this.HasEvent = true;
+                    if (tag.Key == "event")
+                    {
+                        this.HasEvent = true;
+                    }
                 }
 
                 return true;

src/OpenTelemetry.Exporter.Jaeger/Implementation/JaegerTagTransformer.cs

@@ -0,0 +1,49 @@
+// <copyright file="JaegerTagTransformer.cs" company="OpenTelemetry Authors">
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+// </copyright>
+
+using OpenTelemetry.Internal;
+
+namespace OpenTelemetry.Exporter.Jaeger.Implementation
+{
+    internal class JaegerTagTransformer : TagTransformer<JaegerTag>
+    {
+        public static JaegerTagTransformer Instance = new();
+
+        private JaegerTagTransformer()
+        {
+        }
+
+        protected override JaegerTag TransformIntegralTag(string key, long value)
+        {
+            return new JaegerTag(key, JaegerTagType.LONG, vLong: value);
+        }
+
+        protected override JaegerTag TransformFloatingPointTag(string key, double value)
+        {
+            return new JaegerTag(key, JaegerTagType.DOUBLE, vDouble: value);
+        }
+
+        protected override JaegerTag TransformBooleanTag(string key, bool value)
+        {
+            return new JaegerTag(key, JaegerTagType.BOOL, vBool: value);
+        }
+
+        protected override JaegerTag TransformStringTag(string key, string value)
+        {
+            return new JaegerTag(key, JaegerTagType.STRING, vStr: value);
+        }
+    }
+}

src/OpenTelemetry.Exporter.Jaeger/Implementation/Process.cs

@@ -29,20 +29,6 @@ public Process(string serviceName)
             this.ServiceName = serviceName;
         }
 
-        public Process(string serviceName, IEnumerable<KeyValuePair<string, object>> processTags)
-            : this(serviceName, processTags?.Select(pt => pt.ToJaegerTag()).ToDictionary(pt => pt.Key, pt => pt))
-        {
-        }
-
-        internal Process(string serviceName, Dictionary<string, JaegerTag> processTags)
-            : this(serviceName)
-        {
-            if (processTags != null)
-            {
-                this.Tags = processTags;
-            }
-        }
-
         public string ServiceName { get; internal set; }
 
         internal Dictionary<string, JaegerTag> Tags { get; set; }

src/OpenTelemetry.Exporter.Jaeger/JaegerExporter.cs

@@ -145,12 +145,15 @@ internal void SetResourceAndInitializeBatch(Resource resource)
                     }
                 }
 
-                if (process.Tags == null)
+                if (JaegerTagTransformer.Instance.TryTransformTag(label, out var result))
                 {
-                    process.Tags = new Dictionary<string, JaegerTag>();
-                }
+                    if (process.Tags == null)
+                    {
+                        process.Tags = new Dictionary<string, JaegerTag>();
+                    }
 
-                process.Tags[key] = label.ToJaegerTag();
+                    process.Tags[key] = result;
+                }
             }
 
             if (serviceName != null)

src/OpenTelemetry.Exporter.Jaeger/OpenTelemetry.Exporter.Jaeger.csproj

@@ -33,10 +33,12 @@
     <Compile Include="$(RepoRoot)\src\OpenTelemetry\Internal\PeerServiceResolver.cs" Link="Includes\PeerServiceResolver.cs" />
     <Compile Include="$(RepoRoot)\src\OpenTelemetry\Internal\ResourceSemanticConventions.cs" Link="Includes\ResourceSemanticConventions.cs" />
     <Compile Include="$(RepoRoot)\src\OpenTelemetry\Internal\ServiceProviderExtensions.cs" Link="Includes\ServiceProviderExtensions.cs" />
+    <Compile Include="$(RepoRoot)\src\OpenTelemetry\Internal\TagTransformer.cs" Link="Includes\TagTransformer.cs" />
   </ItemGroup>
 
   <ItemGroup>
     <PackageReference Include="System.Threading.Tasks.Extensions" Version="$(SystemThreadingTasksExtensionsPkgVer)" Condition="'$(TargetFramework)' != 'netstandard2.1'" />
+    <PackageReference Include="System.Text.Json" Version="$(SystemTextJsonPkgVer)" Condition="'$(TargetFramework)' != 'net6.0'" />
   </ItemGroup>
 
   <ItemGroup>

src/OpenTelemetry.Exporter.OpenTelemetryProtocol/Implementation/ActivityExtensions.cs

@@ -355,8 +355,7 @@ public bool ForEach(KeyValuePair<string, object> activityTag)
                     this.Created = true;
                 }
 
-                var attribute = activityTag.ToOtlpAttribute();
-                if (attribute != null)
+                if (OtlpKeyValueTransformer.Instance.TryTransformTag(activityTag, out var attribute))
                 {
                     PooledList<OtlpCommon.KeyValue>.Add(ref this.Tags, attribute);
 

src/OpenTelemetry.Exporter.OpenTelemetryProtocol/Implementation/LogRecordExtensions.cs

@@ -105,8 +105,10 @@ internal static OtlpLogs.LogRecord ToOtlpLog(this LogRecord logRecord)
                         }
                         else
                         {
-                            var otlpAttribute = stateValue.ToOtlpAttribute();
-                            otlpLogRecord.Attributes.Add(otlpAttribute);
+                            if (OtlpKeyValueTransformer.Instance.TryTransformTag(stateValue, out var result))
+                            {
+                                otlpLogRecord.Attributes.Add(result);
+                            }
                         }
                     }
                 }
@@ -150,8 +152,10 @@ void ProcessScope(LogRecordScope scope, OtlpLogs.LogRecord otlpLog)
                     foreach (var scopeItem in scope)
                     {
                         var scopeItemWithDepthInfo = new KeyValuePair<string, object>($"[Scope.{scopeDepth}]:{scopeItem.Key}", scopeItem.Value);
-                        var otlpAttribute = scopeItemWithDepthInfo.ToOtlpAttribute();
-                        otlpLog.Attributes.Add(otlpAttribute);
+                        if (OtlpKeyValueTransformer.Instance.TryTransformTag(scopeItemWithDepthInfo, out var result))
+                        {
+                            otlpLog.Attributes.Add(result);
+                        }
                     }
                 }
             }

src/OpenTelemetry.Exporter.OpenTelemetryProtocol/Implementation/MetricItemExtensions.cs

@@ -279,7 +279,10 @@ private static void AddAttributes(ReadOnlyTagCollection tags, RepeatedField<Otlp
         {
             foreach (var tag in tags)
             {
-                attributes.Add(tag.ToOtlpAttribute());
+                if (OtlpKeyValueTransformer.Instance.TryTransformTag(tag, out var result))
+                {
+                    attributes.Add(result);
+                }
             }
         }
 

src/OpenTelemetry.Exporter.OpenTelemetryProtocol/Implementation/OpenTelemetryProtocolExporterEventSource.cs

@@ -79,11 +79,5 @@ public void CouldNotTranslateLogRecord(string exceptionMessage)
         {
             this.WriteEvent(9, exceptionMessage);
         }
-
-        [Event(10, Message = "Unsupported attribute type '{0}' for '{1}'. Attribute will not be exported.", Level = EventLevel.Warning)]
-        public void UnsupportedAttributeType(string type, string key)
-        {
-            this.WriteEvent(10, type.ToString(), key);
-        }
     }
 }