7 instantiations of PagedResult
Aspire.Dashboard (7)
Otlp\Model\OtlpHelpers.cs (1)
491return new PagedResult<TResult>
Otlp\Storage\PagedResult.cs (1)
8public static readonly PagedResult<T> Empty = new()
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (2)
268return new PagedResult<OtlpLogEntry> 382return new PagedResult<LogSummary>
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (3)
47PagedResult = new PagedResult<OtlpTrace> 165PagedResult = new PagedResult<TraceSummary> 407PagedResult = new PagedResult<OtlpSpan>
73 references to PagedResult
Aspire.Dashboard (27)
Api\TelemetryApiService.cs (1)
208var result = await telemetryRepository.GetLogsAsync(new GetLogsContext
Components\Pages\StructuredLogs.razor.cs (2)
134var logs = await ViewModel.GetLogsAsync(request.CancellationToken); 610var matchingLogs = await telemetryRepository.GetLogsAsync(new GetLogsContext
Components\Pages\Traces.razor.cs (1)
140var traces = await TracesViewModel.GetTracesAsync(request.CancellationToken);
Model\GenAI\GenAIVisualizerDialogViewModel.cs (1)
613var logsResult = await telemetryRepository.GetLogsAsync(logsContext, cancellationToken).ConfigureAwait(false);
Model\StructuredLogsViewModel.cs (3)
16private PagedResult<LogSummary>? _logs; 79public async Task<PagedResult<LogSummary>> GetLogsAsync(CancellationToken cancellationToken) 81var logs = _logs;
Model\TelemetryExportService.cs (1)
158var logs = await _dataSource.TelemetryRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken).ConfigureAwait(false);
Model\TracesViewModel.cs (3)
15private PagedResult<TraceSummary>? _traces; 77public async Task<PagedResult<TraceSummary>> GetTracesAsync(CancellationToken cancellationToken) 79var traces = _traces;
Otlp\Model\OtlpHelpers.cs (2)
472public static PagedResult<T> GetItems<T>(IEnumerable<T> results, int startIndex, int count, bool isFull) 477public static PagedResult<TResult> GetItems<TSource, TResult>(IEnumerable<TSource> results, int startIndex, int count, bool isFull, Func<TSource, TResult>? select)
Otlp\Storage\GetSpansResponse.cs (1)
10public required PagedResult<OtlpSpan> PagedResult { get; init; }
Otlp\Storage\GetTracesResponse.cs (1)
10public required PagedResult<OtlpTrace> PagedResult { get; init; }
Otlp\Storage\GetTraceSummariesResponse.cs (1)
11public required PagedResult<TraceSummary> PagedResult { get; init; }
Otlp\Storage\ITelemetryRepository.cs (2)
37Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken); 38Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken);
Otlp\Storage\PagedResult.cs (1)
8public static readonly PagedResult<T> Empty = new()
Otlp\Storage\SqliteTelemetryRepository.cs (4)
176public Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken) => 178public Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken) => 183var result = await GetLogsAsync(new GetLogsContext 198var result = await GetLogsAsync(new GetLogsContext
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (2)
196private PagedResult<OtlpLogEntry> GetLogsFromDatabase(GetLogsContext context, CancellationToken cancellationToken) 276private PagedResult<LogSummary> GetLogSummariesFromDatabase(GetLogsContext context, CancellationToken cancellationToken)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
292var existingLogs = await GetLogsAsync(new GetLogsContext
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 (43)
Integration\OtlpHttpJsonTests.cs (2)
587var logs = await telemetryRepository.GetLogsAsync(new GetLogsContext 664var logs = await telemetryRepository.GetLogsAsync(new GetLogsContext
Model\StructuredLogsPageViewModelTests.cs (1)
251var logs = await repository.GetLogsAsync(new GetLogsContext
Model\TelemetryExportServiceTests.cs (4)
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);
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 (26)
67var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 185var summaries = await repositoryContext.Repository.GetLogSummariesAsync(context, cancellationToken: CancellationToken.None); 186var logs = await repositoryContext.Repository.GetLogsAsync(context, cancellationToken: CancellationToken.None); 225var latestSummaries = await repositoryContext.Repository.GetLogSummariesAsync(latestContext, cancellationToken: CancellationToken.None); 226var latestLogs = await repositoryContext.Repository.GetLogsAsync(latestContext, cancellationToken: CancellationToken.None); 252var filtered = await repositoryContext.Repository.GetLogSummariesAsync(new GetLogsContext 270var emptyPage = await repositoryContext.Repository.GetLogSummariesAsync(new GetLogsContext 280var emptyLogsPage = 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 1107var result = 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
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (5)
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);