Implemented interface member:
method
GetLogsAsync
Aspire.Dashboard.Otlp.Storage.ITelemetryRepository.GetLogsAsync(Aspire.Dashboard.Otlp.Storage.GetLogsContext, System.Threading.CancellationToken)
20 references to GetLogsAsync
Aspire.Dashboard (3)
Otlp\Storage\SqliteTelemetryRepository.cs (2)
183var result = await GetLogsAsync(new GetLogsContext 198var result = await GetLogsAsync(new GetLogsContext
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
292var existingLogs = await GetLogsAsync(new GetLogsContext
Aspire.Dashboard.Tests (17)
Model\StructuredLogsPageViewModelTests.cs (1)
251var logs = await repository.GetLogsAsync(new GetLogsContext
Model\TelemetryExportServiceTests.cs (7)
60var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 128var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 176var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 249var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 1108var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items; 1169var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items; 1247var logEntry = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items[0];
Model\TelemetryImportServiceTests.cs (5)
91var logs = await repository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 322var logs = await sourceRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 343var importedLogs = await targetRepository.GetLogsAsync(GetLogsContext.ForResourceKey(importedResources[0].ResourceKey), cancellationToken: CancellationToken.None); 375var logs = await sourceRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 416var importedLogs = await targetRepository.GetLogsAsync(GetLogsContext.ForResourceKey(importedResources[0].ResourceKey), cancellationToken: CancellationToken.None);
TelemetryRepositoryTests\LogTests.cs (1)
1946var logs = (await repository.GetLogsAsync(new GetLogsContext
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (3)
110var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 293var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 299var log = Assert.Single((await historicalContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items);