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