feat: add on ending span processor functionality

This change creates a new ExtendedBaseProcessor that allows users
to implement onEnding functionality to their processor, as per
the spec: https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/trace/sdk.md#onending

Author: majanjua-amzn

OpenTelemetry.sln

@@ -308,6 +308,7 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "experimental-apis", "experi
 		docs\diagnostics\experimental-apis\OTEL1000.md = docs\diagnostics\experimental-apis\OTEL1000.md
 		docs\diagnostics\experimental-apis\OTEL1001.md = docs\diagnostics\experimental-apis\OTEL1001.md
 		docs\diagnostics\experimental-apis\OTEL1004.md = docs\diagnostics\experimental-apis\OTEL1004.md
+		docs\diagnostics\experimental-apis\OTEL1005.md = docs\diagnostics\experimental-apis\OTEL1005.md
 		docs\diagnostics\experimental-apis\README.md = docs\diagnostics\experimental-apis\README.md
 	EndProjectSection
 EndProject

build/Common.props

@@ -12,7 +12,7 @@
     <NuGetAuditMode>all</NuGetAuditMode>
     <NuGetAuditLevel>low</NuGetAuditLevel>
     <!-- Suppress warnings for repo code using experimental features -->
-    <NoWarn>$(NoWarn);OTEL1000;OTEL1001;OTEL1002;OTEL1004</NoWarn>
+    <NoWarn>$(NoWarn);OTEL1000;OTEL1001;OTEL1002;OTEL1004;OTEL1005</NoWarn>
     <AnalysisLevel>latest-All</AnalysisLevel>
   </PropertyGroup>
 

docs/diagnostics/experimental-apis/OTEL1005.md

@@ -0,0 +1,31 @@
+# OpenTelemetry .NET Diagnostic: OTEL1004
+
+## Overview
+
+This is an experimental API for modifying spans before they end/close
+
+### Details
+
+#### ExtendedBaseProcessor
+
+The abstract class `ExtendedBaseProcessor` provides an extension of the
+`BaseProcessor` that allows spans to be modified before they end as per the
+OpenTelemetry specification. It provides the `OnEnding` function that is called
+during the span `End()` operation. The end timestamp MUST have been computed
+(the `OnEnding` method duration is not included in the span duration). The Span
+object MUST still be mutable (i.e., `SetAttribute`, `AddLink`, `AddEvent` can be
+called) while `OnEnding` is called. This method MUST be called synchronously
+within the [`Span.End()` API](api.md#end), therefore it should not block or
+throw an exception. If multiple `SpanProcessors` are registered, their
+`OnEnding` callbacks are invoked in the order they have been registered. The
+SDK MUST guarantee that the span can no longer be modified by any other thread
+before invoking `OnEnding` of the first `SpanProcessor`. From that point on,
+modifications are only allowed synchronously from within the invoked `OnEnding`
+callbacks. All registered SpanProcessor `OnEnding` callbacks are executed before
+any SpanProcessor's `OnEnd` callback is invoked.
+
+**Parameters:**
+
+* `span` - a read/write span object for the span which is about to be ended.
+
+**Returns:** `Void`

docs/diagnostics/experimental-apis/README.md

@@ -33,6 +33,12 @@ Description: ExemplarReservoir Support
 
 Details: [OTEL1004](./OTEL1004.md)
 
+### OTEL1005
+
+Description: OnEnding Implementation
+
+Details: [OTEL1005](./OTEL1005.md)
+
 ## Inactive
 
 Experimental APIs which have been released stable or removed:

src/OpenTelemetry/.publicApi/Experimental/PublicAPI.Unshipped.txt

@@ -25,3 +25,7 @@ OpenTelemetry.Metrics.MetricStreamConfiguration.ExemplarReservoirFactory.set ->
 [OTEL1000]static Microsoft.Extensions.Logging.OpenTelemetryLoggingExtensions.UseOpenTelemetry(this Microsoft.Extensions.Logging.ILoggingBuilder! builder, System.Action<OpenTelemetry.Logs.LoggerProviderBuilder!>? configureBuilder, System.Action<OpenTelemetry.Logs.OpenTelemetryLoggerOptions!>? configureOptions) -> Microsoft.Extensions.Logging.ILoggingBuilder!
 [OTEL1001]static OpenTelemetry.Sdk.CreateLoggerProviderBuilder() -> OpenTelemetry.Logs.LoggerProviderBuilder!
 [OTEL1004]virtual OpenTelemetry.Metrics.FixedSizeExemplarReservoir.OnCollected() -> void
+[OTEL1005]OpenTelemetry.ExtendedBaseProcessor<T>
+[OTEL1005]OpenTelemetry.ExtendedBaseProcessor<T>.ExtendedBaseProcessor() -> void
+[OTEL1005]virtual OpenTelemetry.ExtendedBaseProcessor<T>.OnEnding(T data) -> void
+[OTEL1005]override OpenTelemetry.CompositeProcessor<T>.OnEnding(T data) -> void

src/OpenTelemetry/CHANGELOG.md

@@ -15,6 +15,9 @@ Notes](../../RELEASENOTES.md).
 * Add support for .NET 10.0.
   ([#6307](https://github.com/open-telemetry/opentelemetry-dotnet/pull/6307))
 
+* feat: add on ending span processor functionality
+  ([#6617](https://github.com/open-telemetry/opentelemetry-dotnet/pull/6617))
+
 ## 1.13.1
 
 Released 2025-Oct-09

src/OpenTelemetry/CompositeProcessor.cs

@@ -1,6 +1,9 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
+#if EXPOSE_EXPERIMENTAL_FEATURES
+using System.Diagnostics.CodeAnalysis;
+#endif
 using System.Diagnostics;
 using OpenTelemetry.Internal;
 
@@ -10,7 +13,11 @@ namespace OpenTelemetry;
 /// Represents a chain of <see cref="BaseProcessor{T}"/>s.
 /// </summary>
 /// <typeparam name="T">The type of object to be processed.</typeparam>
+#if EXPOSE_EXPERIMENTAL_FEATURES
+public class CompositeProcessor<T> : ExtendedBaseProcessor<T>
+#else
 public class CompositeProcessor<T> : BaseProcessor<T>
+#endif
 {
     internal readonly DoublyLinkedListNode Head;
     private DoublyLinkedListNode tail;
@@ -69,6 +76,21 @@ public override void OnEnd(T data)
         }
     }
 
+#if EXPOSE_EXPERIMENTAL_FEATURES
+    /// <inheritdoc/>
+    [Experimental(DiagnosticDefinitions.ExtendedBaseProcessorExperimentalApi, UrlFormat = DiagnosticDefinitions.ExperimentalApiUrlFormat)]
+    public override void OnEnding(T data)
+    {
+        for (var cur = this.Head; cur != null; cur = cur.Next)
+        {
+            if (typeof(ExtendedBaseProcessor<T>).IsAssignableFrom(cur.Value.GetType()))
+            {
+                ((ExtendedBaseProcessor<T>)cur.Value).OnEnding(data);
+            }
+        }
+    }
+#endif
+
     /// <inheritdoc/>
     public override void OnStart(T data)
     {

src/OpenTelemetry/ExtendedBaseProcessor.cs

@@ -0,0 +1,34 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#if EXPOSE_EXPERIMENTAL_FEATURES
+using System.Diagnostics.CodeAnalysis;
+using OpenTelemetry.Internal;
+
+namespace OpenTelemetry;
+
+/// <summary>
+/// Extended base processor base class.
+/// </summary>
+/// <typeparam name="T">The type of object to be processed.</typeparam>
+[Experimental(DiagnosticDefinitions.ExtendedBaseProcessorExperimentalApi, UrlFormat = DiagnosticDefinitions.ExperimentalApiUrlFormat)]
+#pragma warning disable CA1012 // Abstract types should not have public constructors
+public abstract class ExtendedBaseProcessor<T> : BaseProcessor<T>
+#pragma warning restore CA1012 // Abstract types should not have public constructors
+{
+    /// <summary>
+    /// Called synchronously before a telemetry object ends.
+    /// </summary>
+    /// <param name="data">
+    /// The started telemetry object.
+    /// </param>
+    /// <remarks>
+    /// This function is called synchronously on the thread which ended
+    /// the telemetry object. This function should be thread-safe, and
+    /// should not block indefinitely or throw exceptions.
+    /// </remarks>
+    public virtual void OnEnding(T data)
+    {
+    }
+}
+#endif

src/OpenTelemetry/Trace/TracerProviderSdk.cs

@@ -189,6 +189,11 @@ internal TracerProviderSdk(
 
                 if (SuppressInstrumentationScope.DecrementIfTriggered() == 0)
                 {
+                    if (typeof(ExtendedBaseProcessor<Activity>).IsAssignableFrom(this.processor?.GetType()))
+                    {
+                        (this.processor as ExtendedBaseProcessor<Activity>)?.OnEnding(activity);
+                    }
+
                     this.processor?.OnEnd(activity);
                 }
             };
@@ -224,6 +229,11 @@ internal TracerProviderSdk(
 
                 if (SuppressInstrumentationScope.DecrementIfTriggered() == 0)
                 {
+                    if (typeof(ExtendedBaseProcessor<Activity>).IsAssignableFrom(this.processor?.GetType()))
+                    {
+                        (this.processor as ExtendedBaseProcessor<Activity>)?.OnEnding(activity);
+                    }
+
                     this.processor?.OnEnd(activity);
                 }
             };

src/Shared/DiagnosticDefinitions.cs

@@ -10,6 +10,7 @@ internal static class DiagnosticDefinitions
     public const string LoggerProviderExperimentalApi = "OTEL1000";
     public const string LogsBridgeExperimentalApi = "OTEL1001";
     public const string ExemplarReservoirExperimentalApi = "OTEL1004";
+    public const string ExtendedBaseProcessorExperimentalApi = "OTEL1005";
 
     /* Definitions which have been released stable:
     public const string ExemplarExperimentalApi = "OTEL1002";