2 implementations of WatchLogsAsync
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
274public async IAsyncEnumerable<OtlpLogEntry> WatchLogsAsync(
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
72public IAsyncEnumerable<OtlpLogEntry> WatchLogsAsync(WatchLogsRequest request, CancellationToken cancellationToken) => inner.WatchLogsAsync(request, cancellationToken);
9 references to WatchLogsAsync
Aspire.Dashboard (1)
Api\TelemetryApiService.cs (1)
327await foreach (var log in telemetryRepository.WatchLogsAsync(watchRequest, cancellationToken).ConfigureAwait(false))
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
72public IAsyncEnumerable<OtlpLogEntry> WatchLogsAsync(WatchLogsRequest request, CancellationToken cancellationToken) => inner.WatchLogsAsync(request, cancellationToken);
Aspire.Dashboard.Tests (7)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (7)
515await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 577await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 922await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 982await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1074await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1158await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest 1261await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token))