Add minimum span duration filtering

src/Aspire.Cli/Commands/TelemetryCommandHelpers.cs

@@ -102,6 +102,14 @@ internal static class TelemetryCommandHelpers
         Description = TelemetryCommandStrings.SearchOptionDescription
     };
 
+    /// <summary>
+    /// Minimum span duration option for spans and traces commands.
+    /// </summary>
+    internal static Option<double?> CreateMinimumDurationOption() => new("--min-duration", "--min-duration-ms")
+    {
+        Description = TelemetryCommandStrings.MinimumDurationOptionDescription
+    };
+
     /// <summary>
     /// Dashboard URL option for connecting directly to a standalone dashboard.
     /// </summary>

src/Aspire.Cli/Commands/TelemetrySpansCommand.cs

@@ -42,6 +42,7 @@ internal sealed class TelemetrySpansCommand : BaseCommand
     private static readonly Option<string?> s_dashboardUrlOption = TelemetryCommandHelpers.CreateDashboardUrlOption();
     private static readonly Option<string?> s_apiKeyOption = TelemetryCommandHelpers.CreateApiKeyOption();
     private static readonly Option<string?> s_searchOption = TelemetryCommandHelpers.CreateSearchOption();
+    private static readonly Option<double?> s_minimumDurationOption = TelemetryCommandHelpers.CreateMinimumDurationOption();
 
     public TelemetrySpansCommand(
         IInteractionService interactionService,
@@ -74,6 +75,7 @@ public TelemetrySpansCommand(
         Options.Add(s_dashboardUrlOption);
         Options.Add(s_apiKeyOption);
         Options.Add(s_searchOption);
+        Options.Add(s_minimumDurationOption);
     }
 
     protected override async Task<CommandResult> ExecuteAsync(ParseResult parseResult, CancellationToken cancellationToken)
@@ -90,6 +92,7 @@ protected override async Task<CommandResult> ExecuteAsync(ParseResult parseResul
         var dashboardUrl = parseResult.GetValue(s_dashboardUrlOption);
         var apiKey = parseResult.GetValue(s_apiKeyOption);
         var search = parseResult.GetValue(s_searchOption);
+        var minimumDuration = parseResult.GetValue(s_minimumDurationOption);
 
         // Validate --limit value
         if (limit.HasValue && limit.Value < 1)
@@ -105,7 +108,7 @@ protected override async Task<CommandResult> ExecuteAsync(ParseResult parseResul
             return CommandResult.FromExitCode(dashboardApi.ExitCode);
         }
 
-        return CommandResult.FromExitCode(await FetchSpansAsync(dashboardApi.BaseUrl!, dashboardApi.ApiToken!, resourceName, traceId, hasError, limit, follow, format, dashboardOnly: dashboardUrl is not null, dashboardApi.DashboardUrl!, search, cancellationToken));
+        return CommandResult.FromExitCode(await FetchSpansAsync(dashboardApi.BaseUrl!, dashboardApi.ApiToken!, resourceName, traceId, hasError, limit, follow, format, dashboardOnly: dashboardUrl is not null, dashboardApi.DashboardUrl!, search, minimumDuration, cancellationToken));
     }
 
     private async Task<int> FetchSpansAsync(
@@ -120,6 +123,7 @@ private async Task<int> FetchSpansAsync(
         bool dashboardOnly,
         string dashboardUrl,
         string? search,
+        double? minimumDuration,
         CancellationToken cancellationToken)
     {
         try
@@ -143,7 +147,7 @@ private async Task<int> FetchSpansAsync(
             // Build URL with query parameters
             int? effectiveLimit = (limit.HasValue && !follow) ? limit.Value : null;
 
-            var url = DashboardUrls.TelemetrySpansApiUrl(baseUrl, resolvedResources, traceId: traceId, hasError: hasError, limit: effectiveLimit, follow: follow ? true : null, search: search);
+            var url = DashboardUrls.TelemetrySpansApiUrl(baseUrl, resolvedResources, traceId: traceId, hasError: hasError, limit: effectiveLimit, follow: follow ? true : null, search: search, minDurationMs: minimumDuration);
 
             _logger.LogDebug("Fetching spans from {Url}", url);
 

src/Aspire.Cli/Commands/TelemetryTracesCommand.cs

@@ -42,6 +42,7 @@ internal sealed class TelemetryTracesCommand : BaseCommand
     private static readonly Option<string?> s_dashboardUrlOption = TelemetryCommandHelpers.CreateDashboardUrlOption();
     private static readonly Option<string?> s_apiKeyOption = TelemetryCommandHelpers.CreateApiKeyOption();
     private static readonly Option<string?> s_searchOption = TelemetryCommandHelpers.CreateSearchOption();
+    private static readonly Option<double?> s_minimumDurationOption = TelemetryCommandHelpers.CreateMinimumDurationOption();
 
     public TelemetryTracesCommand(
         IInteractionService interactionService,
@@ -73,6 +74,7 @@ public TelemetryTracesCommand(
         Options.Add(s_dashboardUrlOption);
         Options.Add(s_apiKeyOption);
         Options.Add(s_searchOption);
+        Options.Add(s_minimumDurationOption);
     }
 
     protected override async Task<CommandResult> ExecuteAsync(ParseResult parseResult, CancellationToken cancellationToken)
@@ -88,6 +90,7 @@ protected override async Task<CommandResult> ExecuteAsync(ParseResult parseResul
         var dashboardUrl = parseResult.GetValue(s_dashboardUrlOption);
         var apiKey = parseResult.GetValue(s_apiKeyOption);
         var search = parseResult.GetValue(s_searchOption);
+        var minimumDuration = parseResult.GetValue(s_minimumDurationOption);
 
         // Validate --limit value
         if (limit.HasValue && limit.Value < 1)
@@ -107,11 +110,11 @@ protected override async Task<CommandResult> ExecuteAsync(ParseResult parseResul
         {
             if (!string.IsNullOrEmpty(traceId))
             {
-                return CommandResult.FromExitCode(await FetchSingleTraceAsync(dashboardApi.BaseUrl!, dashboardApi.ApiToken!, traceId, format, dashboardApi.DashboardUrl!, cancellationToken));
+                return CommandResult.FromExitCode(await FetchSingleTraceAsync(dashboardApi.BaseUrl!, dashboardApi.ApiToken!, traceId, format, dashboardApi.DashboardUrl!, minimumDuration, cancellationToken));
             }
             else
             {
-                return CommandResult.FromExitCode(await FetchTracesAsync(dashboardApi.BaseUrl!, dashboardApi.ApiToken!, resourceName, hasError, limit, format, dashboardApi.DashboardUrl!, search, cancellationToken));
+                return CommandResult.FromExitCode(await FetchTracesAsync(dashboardApi.BaseUrl!, dashboardApi.ApiToken!, resourceName, hasError, limit, format, dashboardApi.DashboardUrl!, search, minimumDuration, cancellationToken));
             }
         }
         catch (HttpRequestException ex)
@@ -129,6 +132,7 @@ private async Task<int> FetchSingleTraceAsync(
         string traceId,
         OutputFormat format,
         string dashboardUrl,
+        double? minimumDuration,
         CancellationToken cancellationToken)
     {
         using var client = TelemetryCommandHelpers.CreateApiClient(_httpClientFactory, apiToken);
@@ -140,7 +144,7 @@ private async Task<int> FetchSingleTraceAsync(
         // Pre-resolve colors so assignment is deterministic regardless of data order
         TelemetryCommandHelpers.ResolveResourceColors(_resourceColorMap, allOtlpResources);
 
-        var url = DashboardUrls.TelemetryTraceDetailApiUrl(baseUrl, traceId);
+        var url = DashboardUrls.TelemetryTraceDetailApiUrl(baseUrl, traceId, minDurationMs: minimumDuration);
 
         _logger.LogDebug("Fetching trace {TraceId} from {Url}", traceId, url);
 
@@ -190,6 +194,7 @@ private async Task<int> FetchTracesAsync(
         OutputFormat format,
         string dashboardUrl,
         string? search,
+        double? minimumDuration,
         CancellationToken cancellationToken)
     {
         using var client = TelemetryCommandHelpers.CreateApiClient(_httpClientFactory, apiToken);
@@ -209,7 +214,7 @@ private async Task<int> FetchTracesAsync(
         // Pre-resolve colors so assignment is deterministic regardless of data order
         TelemetryCommandHelpers.ResolveResourceColors(_resourceColorMap, allOtlpResources);
 
-        var url = DashboardUrls.TelemetryTracesApiUrl(baseUrl, resolvedResources, hasError: hasError, limit: limit, search: search);
+        var url = DashboardUrls.TelemetryTracesApiUrl(baseUrl, resolvedResources, hasError: hasError, limit: limit, search: search, minDurationMs: minimumDuration);
 
         _logger.LogDebug("Fetching traces from {Url}", url);
 

src/Aspire.Cli/Resources/TelemetryCommandStrings.resx

@@ -156,6 +156,9 @@
   <data name="SearchOptionDescription" xml:space="preserve">
     <value>Full-text search across telemetry text fields, such as log messages, attribute values, names, source, and IDs</value>
   </data>
+  <data name="MinimumDurationOptionDescription" xml:space="preserve">
+    <value>Filter by minimum span duration in milliseconds</value>
+  </data>
   <data name="LimitMustBePositive" xml:space="preserve">
     <value>The --limit value must be a positive number.</value>
   </data>