[Instrumentation.Remoting] initial implementation

src/OpenTelemetry.Instrumentation.Remoting/.publicApi/PublicAPI.Unshipped.txt

@@ -0,0 +1,13 @@
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.Enrich.get -> System.Action<System.Diagnostics.Activity!, string!, System.Runtime.Remoting.Messaging.IMethodMessage!>?
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.Enrich.set -> void
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.Filter.get -> System.Func<System.Runtime.Remoting.Messaging.IMessage!, bool>?
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.Filter.set -> void
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.Propagator.get -> OpenTelemetry.Context.Propagation.TextMapPropagator!
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.Propagator.set -> void
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.RecordException.get -> bool
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.RecordException.set -> void
+OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions.RemotingInstrumentationOptions() -> void
+OpenTelemetry.Trace.TracerProviderBuilderExtensions
+static OpenTelemetry.Trace.TracerProviderBuilderExtensions.AddRemotingInstrumentation(this OpenTelemetry.Trace.TracerProviderBuilder! builder) -> OpenTelemetry.Trace.TracerProviderBuilder!
+static OpenTelemetry.Trace.TracerProviderBuilderExtensions.AddRemotingInstrumentation(this OpenTelemetry.Trace.TracerProviderBuilder! builder, System.Action<OpenTelemetry.Instrumentation.Remoting.RemotingInstrumentationOptions!>? configure) -> OpenTelemetry.Trace.TracerProviderBuilder!

src/OpenTelemetry.Instrumentation.Remoting/CHANGELOG.md

@@ -2,4 +2,6 @@
 
 ## Unreleased
 
+* This is the first release of `OpenTelemetry.Instrumentation.Remoting` package.
+
 For more details, please refer to the [README](README.md).

src/OpenTelemetry.Instrumentation.Remoting/Implementation/RemotingInstrumentationEnrichEventNames.cs

@@ -0,0 +1,20 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+namespace OpenTelemetry.Instrumentation.Remoting;
+
+/// <summary>
+/// Defines the event names used by the Remoting instrumentation Enrich callback.
+/// </summary>
+internal static class RemotingInstrumentationEnrichEventNames
+{
+    /// <summary>
+    /// Event name for when a remoting message starts processing.
+    /// </summary>
+    internal const string OnMessageStart = "OnMessageStart";
+
+    /// <summary>
+    /// Event name for when a remoting message finishes processing.
+    /// </summary>
+    internal const string OnMessageFinish = "OnMessageFinish";
+}

src/OpenTelemetry.Instrumentation.Remoting/Implementation/RemotingInstrumentationEventSource.cs

@@ -0,0 +1,58 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+using System.Diagnostics.Tracing;
+using OpenTelemetry.Internal;
+
+namespace OpenTelemetry.Contrib.Instrumentation.Remoting.Implementation;
+
+[EventSource(Name = "OpenTelemetry-Instrumentation-Remoting")]
+internal class RemotingInstrumentationEventSource : EventSource
+{
+    public static readonly RemotingInstrumentationEventSource Log = new();
+
+    [NonEvent]
+    public void MessageFilterException(Exception ex)
+    {
+        if (this.IsEnabled(EventLevel.Error, (EventKeywords)(-1)))
+        {
+            this.MessageFilterException(ex.ToInvariantString());
+        }
+    }
+
+    [Event(1, Message = "InstrumentationFilter threw an exception. Message will not be collected. Exception {0}.", Level = EventLevel.Error)]
+    public void MessageFilterException(string exception)
+    {
+        this.WriteEvent(1, exception);
+    }
+
+    [NonEvent]
+    public void DynamicSinkException(Exception ex)
+    {
+        if (this.IsEnabled(EventLevel.Error, (EventKeywords)(-1)))
+        {
+            this.DynamicSinkException(ex.ToInvariantString());
+        }
+    }
+
+    [Event(2, Message = "DynamicSink message processor threw an exception. Remoting activity will not be recorded. Exception {0}.", Level = EventLevel.Error)]
+    public void DynamicSinkException(string exception)
+    {
+        this.WriteEvent(2, exception);
+    }
+
+    [NonEvent]
+    public void EnrichmentException(Exception ex)
+    {
+        if (this.IsEnabled(EventLevel.Error, (EventKeywords)(-1)))
+        {
+            this.EnrichmentException(ex.ToInvariantString());
+        }
+    }
+
+    [Event(3, Message = "Enrichment threw exception. Exception {0}.", Level = EventLevel.Error)]
+    public void EnrichmentException(string exception)
+    {
+        this.WriteEvent(3, exception);
+    }
+}