3 implementations of WatchSpansAsync
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
218public async IAsyncEnumerable<OtlpSpan> WatchSpansAsync(
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
55public IAsyncEnumerable<OtlpSpan> WatchSpansAsync(WatchSpansRequest request, CancellationToken cancellationToken) => inner.WatchSpansAsync(request, cancellationToken);
Aspire.Dashboard.Tests (1)
tests\Shared\Telemetry\InMemoryTelemetryRepository.Watchers.cs (1)
35public async IAsyncEnumerable<OtlpSpan> WatchSpansAsync(
9 references to WatchSpansAsync
Aspire.Dashboard (1)
Api\TelemetryApiService.cs (1)
267await foreach (var span in telemetryRepository.WatchSpansAsync(watchRequest, cancellationToken).ConfigureAwait(false))
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
55public IAsyncEnumerable<OtlpSpan> WatchSpansAsync(WatchSpansRequest request, CancellationToken cancellationToken) => inner.WatchSpansAsync(request, cancellationToken);
Aspire.Dashboard.Tests (7)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (7)
394await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 456await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 665await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 743await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 812await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1")], Filters = [] }, cts.Token)) 887await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 1351await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = filters }, cts.Token))