14 references to ForResourceKey
Aspire.Dashboard (1)
Model\TelemetryExportService.cs (1)
174var tracesResponse = await _dataSource.TelemetryRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken).ConfigureAwait(false);
Aspire.Dashboard.Tests (13)
Model\TelemetryExportServiceTests.cs (7)
370var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 418var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 468var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 1054var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0]; 1107var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0]; 1168var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0]; 1210var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0];
Model\TelemetryImportServiceTests.cs (3)
116var traces = await repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 454var traces = await sourceRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 474var importedTraces = await targetRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(importedResources[0].ResourceKey), cancellationToken: CancellationToken.None);
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (3)
111var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans); 357var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 363var trace = Assert.Single((await historicalContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items);