9 instantiations of WatchSpansRequest
Aspire.Dashboard (1)
Api\TelemetryApiService.cs (1)
257var watchRequest = new WatchSpansRequest
Aspire.Dashboard.Tests (8)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (8)
396await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 459await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 669await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 747await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 816await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1")], Filters = [] }, cts.Token)) 891await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 1359await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1493await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token))
7 references to WatchSpansRequest
Aspire.Dashboard (6)
Api\TelemetryApiService.cs (1)
257var watchRequest = new WatchSpansRequest
Otlp\Storage\ITelemetryRepository.cs (1)
76IAsyncEnumerable<OtlpSpan> WatchSpansAsync(WatchSpansRequest request, CancellationToken cancellationToken);
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (4)
218WatchSpansRequest request, 345var request = watcher.Request; 423private sealed class SpanWatcher(WatchSpansRequest request, Channel<OtlpSpan> channel) 425public WatchSpansRequest Request => request;
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
71public IAsyncEnumerable<OtlpSpan> WatchSpansAsync(WatchSpansRequest request, CancellationToken cancellationToken) => inner.WatchSpansAsync(request, cancellationToken);