8 instantiations of WatchLogsRequest
Aspire.Dashboard (1)
Api\TelemetryApiService.cs (1)
319var watchRequest = new WatchLogsRequest
Aspire.Dashboard.Tests (7)
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (7)
512await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 573await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 918await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 978await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1069await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1152await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest 1254await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token))
7 references to WatchLogsRequest
Aspire.Dashboard (6)
Api\TelemetryApiService.cs (1)
319var watchRequest = new WatchLogsRequest
Otlp\Storage\ITelemetryRepository.cs (1)
68IAsyncEnumerable<OtlpLogEntry> WatchLogsAsync(WatchLogsRequest request, CancellationToken cancellationToken);
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (4)
275WatchLogsRequest request, 382var request = watcher.Request; 429private sealed class LogWatcher(WatchLogsRequest request, Channel<OtlpLogEntry> channel) 431public WatchLogsRequest Request => request;
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
56public IAsyncEnumerable<OtlpLogEntry> WatchLogsAsync(WatchLogsRequest request, CancellationToken cancellationToken) => inner.WatchLogsAsync(request, cancellationToken);