Adds activity tracking to plugins

Adds activity tracking to pipeline actions and plugin execution.

This change introduces activity tracking using `AppDiagnostics.StartActivity`
to provide better insight into the performance and execution flow of
pipeline actions and various plugins. This will help identify potential
bottlenecks and performance issues.

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))