Adds activity tracking for plugin execution

Enables activity tracking for plugin execution to monitor and diagnose plugin performance and identify bottlenecks. This change wraps the execution of various plugin types within `AppDiagnostics.StartActivity` to provide more granular tracing information.

Author: niemyjski

src/Exceptionless.Core/Pipeline/Base/PipelineBase.cs

@@ -1,4 +1,4 @@
-using System.Collections.Concurrent;
+using System.Collections.Concurrent;
 using Exceptionless.Core.Extensions;
 using Exceptionless.Core.Helpers;
 using Microsoft.Extensions.DependencyInjection;
@@ -58,6 +58,8 @@ public virtual async Task<ICollection<TContext>> RunAsync(ICollection<TContext>
 
         foreach (var action in _actions)
         {
+            using var _ = AppDiagnostics.StartActivity(action.Name);
+
             string metricName = String.Concat(_metricPrefix, action.Name.ToLower());
             var contextsToProcess = contexts.Where(c => c.IsCancelled == false && !c.HasError).ToList();
             await AppDiagnostics.TimeAsync(() => action.ProcessBatchAsync(contextsToProcess), metricName);

src/Exceptionless.Core/Plugins/EventParser/EventParserPluginManager.cs

@@ -25,6 +25,7 @@ public List<PersistentEvent> ParseEvents(string input, int apiVersion, string? u
 
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 List<PersistentEvent>? events = null;
                 AppDiagnostics.Time(() => events = plugin.ParseEvents(input, apiVersion, userAgent), metricName);
                 if (events is null)

src/Exceptionless.Core/Plugins/EventProcessor/EventPluginManager.cs

@@ -15,6 +15,7 @@ public async Task StartupAsync()
         {
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 string metricName = String.Concat(_metricPrefix, plugin.Name.ToLower());
                 await AppDiagnostics.TimeAsync(() => plugin.StartupAsync(), metricName);
             }
@@ -39,7 +40,9 @@ public async Task EventBatchProcessingAsync(ICollection<EventContext> contexts)
             string metricName = String.Concat(_metricPrefix, plugin.Name.ToLower());
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 await AppDiagnostics.TimeAsync(() => plugin.EventBatchProcessingAsync(contextsToProcess), metricName);
+
                 if (contextsToProcess.All(c => c.IsCancelled || c.HasError))
                     break;
             }
@@ -64,7 +67,9 @@ public async Task EventBatchProcessedAsync(ICollection<EventContext> contexts)
             string metricName = String.Concat(_metricPrefix, plugin.Name.ToLower());
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 await AppDiagnostics.TimeAsync(() => plugin.EventBatchProcessedAsync(contextsToProcess), metricName);
+
                 if (contextsToProcess.All(c => c.IsCancelled || c.HasError))
                     break;
             }

src/Exceptionless.Core/Plugins/EventUpgrader/EventUpgraderPluginManager.cs

@@ -17,6 +17,7 @@ public void Upgrade(EventUpgraderContext context)
             string metricName = String.Concat(metricPrefix, plugin.Name.ToLower());
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 AppDiagnostics.Time(() => plugin.Upgrade(context), metricName);
             }
             catch (Exception ex)

src/Exceptionless.Core/Plugins/Formatting/FormattingPluginManager.cs

@@ -18,6 +18,7 @@ public SummaryData GetStackSummaryData(Stack stack)
 
             try
             {
+                using var __ = AppDiagnostics.StartActivity(plugin.Name);
                 var result = plugin.GetStackSummaryData(stack);
                 if (result is not null)
                     return result;
@@ -42,6 +43,7 @@ public SummaryData GetEventSummaryData(PersistentEvent ev)
 
             try
             {
+                using var __ = AppDiagnostics.StartActivity(plugin.Name);
                 var result = plugin.GetEventSummaryData(ev);
                 if (result is not null)
                     return result;
@@ -66,6 +68,7 @@ public string GetStackTitle(PersistentEvent ev)
 
             try
             {
+                using var __ = AppDiagnostics.StartActivity(plugin.Name);
                 string? result = plugin.GetStackTitle(ev);
                 if (!String.IsNullOrEmpty(result))
                     return result;
@@ -90,6 +93,7 @@ public MailMessageData GetEventNotificationMailMessageData(PersistentEvent ev, b
 
             try
             {
+                using var __ = AppDiagnostics.StartActivity(plugin.Name);
                 var result = plugin.GetEventNotificationMailMessageData(ev, isCritical, isNew, isRegression);
                 if (result is not null)
                     return result;
@@ -114,6 +118,7 @@ public SlackMessage GetSlackEventNotificationMessage(PersistentEvent ev, Project
 
             try
             {
+                using var __ = AppDiagnostics.StartActivity(plugin.Name);
                 var message = plugin.GetSlackEventNotification(ev, project, isCritical, isNew, isRegression);
                 if (message is not null)
                     return message;

src/Exceptionless.Core/Plugins/WebHook/WebHookDataPluginManager.cs

@@ -17,6 +17,7 @@ public WebHookDataPluginManager(IServiceProvider serviceProvider, AppOptions opt
             string metricName = String.Concat(metricPrefix, plugin.Name.ToLower());
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 object? data = null;
                 await AppDiagnostics.TimeAsync(async () => data = await plugin.CreateFromEventAsync(context), metricName);
                 if (context.IsCancelled)
@@ -47,6 +48,7 @@ public WebHookDataPluginManager(IServiceProvider serviceProvider, AppOptions opt
             string metricName = String.Concat(metricPrefix, plugin.Name.ToLower());
             try
             {
+                using var _ = AppDiagnostics.StartActivity(plugin.Name);
                 object? data = null;
                 await AppDiagnostics.TimeAsync(async () => data = await plugin.CreateFromStackAsync(context), metricName);
                 if (context.IsCancelled)

src/Exceptionless.Core/Utility/AppDiagnostics.cs

@@ -17,6 +17,16 @@ public static class AppDiagnostics
     private static readonly ConcurrentDictionary<string, GaugeInfo> _gauges = new();
     private static readonly ConcurrentDictionary<string, Histogram<double>> _timers = new();
 
+    /// <summary>
+    /// Starts a new Activity span with the specified name.
+    /// </summary>
+    /// <param name="name">The friendly name for the span.</param>
+    /// <returns>The started Activity, or null if no listeners are registered.</returns>
+    public static Activity? StartActivity(string name)
+    {
+        return ActivitySource.StartActivity(name, ActivityKind.Internal, Activity.Current?.Id);
+    }
+
     public static void Counter(string name, int value = 1)
     {
         if (!_counters.TryGetValue(_metricsPrefix + name, out var counter))