54 instantiations of GetLogsContext
Aspire.Dashboard (10)
Api\TelemetryApiService.cs (1)
208var result = await telemetryRepository.GetLogsAsync(new GetLogsContext
Components\Pages\StructuredLogs.razor.cs (1)
610var matchingLogs = await telemetryRepository.GetLogsAsync(new GetLogsContext
Components\Pages\TraceDetail.razor.cs (1)
284var result = (await TelemetryRepository.GetLogSummariesAsync(new GetLogsContext
Model\GenAI\GenAIVisualizerDialogViewModel.cs (1)
599var logsContext = new GetLogsContext
Model\StructuredLogsViewModel.cs (1)
86logs = await _dataSource.TelemetryRepository.GetLogSummariesAsync(new GetLogsContext
Otlp\Storage\GetLogsContext.cs (1)
23public static GetLogsContext ForResourceKey(ResourceKey resourceKey) => new()
Otlp\Storage\SqliteTelemetryRepository.cs (2)
183var result = await GetLogsAsync(new GetLogsContext 198var result = await GetLogsAsync(new GetLogsContext
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
292var existingLogs = await GetLogsAsync(new GetLogsContext 386matchingIds.UnionWith(GetMatchingLogIdsFromDatabase(new GetLogsContext
Aspire.Dashboard.Tests (44)
Integration\OtlpHttpJsonTests.cs (2)
587var logs = await telemetryRepository.GetLogsAsync(new GetLogsContext 664var logs = await telemetryRepository.GetLogsAsync(new GetLogsContext
Model\DashboardDataSourceTests.cs (1)
1113Assert.Equal("Test Value!", Assert.Single((await dataSource.TelemetryRepository.GetLogsAsync(new GetLogsContext
Model\StructuredLogsPageViewModelTests.cs (1)
251var logs = await repository.GetLogsAsync(new GetLogsContext
Model\TelemetryExportServiceTests.cs (1)
60var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext
TelemetryRepositoryTests\LogTests.cs (31)
67var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 178var context = new GetLogsContext 217var latestContext = new GetLogsContext 252var filtered = await repositoryContext.Repository.GetLogSummariesAsync(new GetLogsContext 270var emptyPage = await repositoryContext.Repository.GetLogSummariesAsync(new GetLogsContext 280var emptyLogsPage = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 317var logs = (await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 374var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 426var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 674var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 772var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 914var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1062Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1070Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1107var result = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1149Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1157Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1218var logs1 = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1241var logs2 = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1317var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1407var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1472var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1546var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1586var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1627var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1668var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1711var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1753var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1811var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1865var logs = (await repository.GetLogSummariesAsync(new GetLogsContext 1946var logs = (await repository.GetLogsAsync(new GetLogsContext
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (1)
967return new GetLogsContext
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (7)
42Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 53Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 233var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 245var resource2Logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 274var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 318var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 349var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None);
28 references to GetLogsContext
Aspire.Dashboard (11)
Model\GenAI\GenAIVisualizerDialogViewModel.cs (1)
599var logsContext = new GetLogsContext
Model\TelemetryExportService.cs (1)
158var logs = await _dataSource.TelemetryRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken).ConfigureAwait(false);
Otlp\Storage\GetLogsContext.cs (1)
23public static GetLogsContext ForResourceKey(ResourceKey resourceKey) => new()
Otlp\Storage\ITelemetryRepository.cs (2)
37Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken); 38Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken);
Otlp\Storage\SqliteTelemetryRepository.cs (2)
176public Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken) => 178public Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken) =>
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (4)
196private PagedResult<OtlpLogEntry> GetLogsFromDatabase(GetLogsContext context, CancellationToken cancellationToken) 276private PagedResult<LogSummary> GetLogSummariesFromDatabase(GetLogsContext context, CancellationToken cancellationToken) 492private static LogQuery BuildLogQuery(GetLogsContext context) 567private HashSet<long> GetMatchingLogIdsFromDatabase(GetLogsContext context)
Aspire.Dashboard.Components.Tests (3)
Shared\TestTelemetryRepository.cs (3)
12public Func<GetLogsContext, CancellationToken, Task<PagedResult<LogSummary>>>? GetLogSummariesAsyncHandler { get; init; } 33public Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken) => inner.GetLogsAsync(context, cancellationToken); 34public Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken) =>
Aspire.Dashboard.Tests (14)
Model\TelemetryExportServiceTests.cs (6)
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 (2)
178var context = new GetLogsContext 217var latestContext = new GetLogsContext
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (1)
965private static GetLogsContext CreateLogsContext()