PagedResult

7 instantiations of PagedResult

Aspire.Dashboard (7)

Otlp\Model\OtlpHelpers.cs (1)

518return 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)

49PagedResult = new PagedResult<OtlpTrace> 170PagedResult = new PagedResult<TraceSummary> 420PagedResult = new PagedResult<OtlpSpan>

86 references to PagedResult

Aspire.Dashboard (40)

Api\TelemetryApiService.cs (1)

208var result = await telemetryRepository.GetLogsAsync(new GetLogsContext

Components\Controls\ApplicationSummary.razor.cs (5)

309var allLogs = await repository.GetLogSummariesAsync(CreateLogsContext([], 0, 0), cancellationToken).ConfigureAwait(false); 310var warningLogs = await repository.GetLogSummariesAsync(CreateLogsContext(s_warningLogFilters, 0, 0), cancellationToken).ConfigureAwait(false); 311var errorLogs = await repository.GetLogSummariesAsync(CreateLogsContext(s_errorLogFilters, 0, 0), cancellationToken).ConfigureAwait(false); 444var errorLogs = await repository.GetLogSummariesAsync(new GetLogsContext 548var latestError = await repository.GetLogSummariesAsync(new GetLogsContext

Components\Legacy\Pages\StructuredLogs.razor.cs (2)

134var logs = await ViewModel.GetLogsAsync(request.CancellationToken); 583var matchingLogs = await telemetryRepository.GetLogsAsync(new GetLogsContext

Components\Legacy\Pages\Traces.razor.cs (1)

141var traces = await TracesViewModel.GetTracesAsync(request.CancellationToken);

Components\Pages\ResourceOverview.razor.cs (3)

324var allLogs = await repository.GetLogSummariesAsync(CreateLogsContext(key, [], 0, 0), cancellationToken).ConfigureAwait(false); 329var errorLogs = await repository.GetLogSummariesAsync(CreateLogsContext(key, errorFilters, 0, 0), cancellationToken).ConfigureAwait(false); 330var warningLogs = await repository.GetLogSummariesAsync(CreateLogsContext(key, warningFilters, 0, 0), cancellationToken).ConfigureAwait(false);

Components\Pages\StructuredLogs.razor.cs (2)

149var logs = await ViewModel.GetLogsAsync(request.CancellationToken); 637var matchingLogs = await telemetryRepository.GetLogsAsync(new GetLogsContext

Components\Pages\Traces.razor.cs (1)

133var traces = await TracesViewModel.GetTracesAsync(request.CancellationToken);

Model\GenAI\GenAIVisualizerDialogViewModel.cs (1)

613var logsResult = await telemetryRepository.GetLogsAsync(logsContext, cancellationToken).ConfigureAwait(false);

Model\StructuredLogsViewModel.cs (4)

16private PagedResult<LogSummary>? _logs; 99public async Task<PagedResult<LogSummary>> GetLogsAsync(CancellationToken cancellationToken) 104return PagedResult<LogSummary>.Empty; 107var logs = _logs;

Model\TelemetryExportService.cs (1)

158var logs = await _dataSource.TelemetryRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken).ConfigureAwait(false);

Model\TracesViewModel.cs (4)

15private PagedResult<TraceSummary>? _traces; 97public async Task<PagedResult<TraceSummary>> GetTracesAsync(CancellationToken cancellationToken) 102return PagedResult<TraceSummary>.Empty; 105var traces = _traces;

Otlp\Model\OtlpHelpers.cs (2)

499public static PagedResult<T> GetItems<T>(IEnumerable<T> results, int startIndex, int count, bool isFull) 504public 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)

40Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken); 41Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken);

Otlp\Storage\PagedResult.cs (1)

8public static readonly PagedResult<T> Empty = new()

Otlp\Storage\SqliteTelemetryRepository.cs (4)

212public Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken) => 214public Task<PagedResult<LogSummary>> GetLogSummariesAsync(GetLogsContext context, CancellationToken cancellationToken) => 219var result = await GetLogsAsync(new GetLogsContext 234var 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; } 47public Task<PagedResult<OtlpLogEntry>> GetLogsAsync(GetLogsContext context, CancellationToken cancellationToken) => inner.GetLogsAsync(context, cancellationToken); 48public 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)

235var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 247var resource2Logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 276var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 320var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 351var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None);