136 references to ResourceKey
Aspire.Dashboard (26)
Api\TelemetryApiService.cs (2)
346
DisplayName = r.
ResourceKey
.GetCompositeName(),
592
resourceKey = matches[0].
ResourceKey
;
Components\Controls\PropertyValues\ResourceNameButtonValue.razor.cs (1)
45
_resource = DataSource.ResourceRepository.GetResource(Resource.
ResourceKey
.ToString());
Components\Dialogs\ManageDataDialog.razor.cs (3)
133
var compositeName = otlpResource.
ResourceKey
.GetCompositeName();
238
var resourceName = otlpResource.
ResourceKey
.GetCompositeName();
245
Name = otlpResource.
ResourceKey
.GetCompositeName(),
Components\ResourcesGridColumns\UnreadLogErrorsBadge.razor.cs (1)
45
if (!UnviewedErrorCounts.TryGetValue(otlpResource.
ResourceKey
, out var count) || count == 0)
Model\Otlp\ResourcesSelectHelpers.cs (2)
95
Id = ResourceTypeDetails.CreateSingleton(resource.
ResourceKey
.ToString(), resourceName),
113
Id = ResourceTypeDetails.CreateReplicaInstance(replica.
ResourceKey
.ToString(), resourceName),
Model\TelemetryExportService.cs (8)
78
.Where(r => selectedResources.TryGetValue(r.
ResourceKey
.GetCompositeName(), out var types) && types.Contains(AspireDataType.StructuredLogs))
82
.Where(r => selectedResources.TryGetValue(r.
ResourceKey
.GetCompositeName(), out var types) && types.Contains(AspireDataType.Traces))
86
.Where(r => selectedResources.TryGetValue(r.
ResourceKey
.GetCompositeName(), out var types) && types.Contains(AspireDataType.Metrics))
158
var logs = await _dataSource.TelemetryRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.
ResourceKey
), cancellationToken).ConfigureAwait(false);
174
var tracesResponse = await _dataSource.TelemetryRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.
ResourceKey
), cancellationToken).ConfigureAwait(false);
190
var instrumentSummaries = _dataSource.TelemetryRepository.GetInstrumentSummaries(resource.
ResourceKey
);
203
ResourceKey = resource.
ResourceKey
,
833
return span.GetDestination()?.
ResourceKey
.GetCompositeName() ?? span.Attributes.GetPeerAddress();
Otlp\Model\OtlpResource.cs (3)
167
ReferenceEquals(x, y) || x is not null && y is not null && x.
ResourceKey
== y.
ResourceKey
;
169
public int GetHashCode(OtlpResource obj) => obj.
ResourceKey
.GetHashCode();
Otlp\Model\OtlpResourceView.cs (1)
15
public ResourceKey ResourceKey => Resource.
ResourceKey
;
Otlp\Model\OtlpSpan.cs (1)
164
return $@"SpanId = {SpanId}, StartTime = {StartTime.ToLocalTime():h:mm:ss.fff tt}, ParentSpanId = {ParentSpanId}, Resource = {Source.ResourceKey}, UninstrumentedPeerResource = {UninstrumentedPeer?.
ResourceKey
}, TraceId = {Trace.TraceId}";
Otlp\Storage\SqliteTelemetryRepository.Resources.cs (4)
18
public OtlpResource? GetResourceByCompositeName(string compositeName) => GetResources(includeUninstrumentedPeers: true).SingleOrDefault(resource => resource.
ResourceKey
.EqualsCompositeName(compositeName));
20
public OtlpResource? GetResource(ResourceKey key) => GetResources(includeUninstrumentedPeers: true).SingleOrDefault(resource => resource.
ResourceKey
== key);
26
: GetResources(includeUninstrumentedPeers).Where(resource => resource.
ResourceKey
== key).ToList();
115
.OrderBy(resource => resource.
ResourceKey
)
Aspire.Dashboard.Components.Tests (5)
Controls\GenAIVisualizerDialogTests.cs (2)
211
ResourceKeys = [resource.
ResourceKey
],
295
ResourceKeys = [resource.
ResourceKey
],
Pages\MetricsTests.cs (3)
111
builder.Add(component => component.ResourceKey, resource.
ResourceKey
);
225
builder.Add(component => component.ResourceKey, resource.
ResourceKey
);
313
builder.Add(component => component.ResourceKey, resource.
ResourceKey
);
Aspire.Dashboard.Tests (105)
Integration\OtlpHttpJsonTests.cs (6)
529
ResourceKeys = [resource.
ResourceKey
],
589
ResourceKeys = [resource.
ResourceKey
],
666
ResourceKeys = [resource.
ResourceKey
],
714
var instruments = telemetryRepository.GetInstrumentSummaries(resource.
ResourceKey
);
765
var instruments = telemetryRepository.GetInstrumentSummaries(resource.
ResourceKey
);
771
ResourceKey = resource.
ResourceKey
,
Model\TelemetryExportServiceTests.cs (20)
62
ResourceKeys = [resource.
ResourceKey
],
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);
299
ResourceKeys = [resource.
ResourceKey
],
370
var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.
ResourceKey
), cancellationToken: CancellationToken.None);
418
var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.
ResourceKey
), cancellationToken: CancellationToken.None);
468
var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.
ResourceKey
), cancellationToken: CancellationToken.None);
546
var instrumentSummaries = repositoryContext.Repository.GetInstrumentSummaries(resource.
ResourceKey
);
554
ResourceKey = resource.
ResourceKey
,
634
var instrumentSummaries = repositoryContext.Repository.GetInstrumentSummaries(resource.
ResourceKey
);
642
ResourceKey = resource.
ResourceKey
,
1054
var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0];
1107
var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0];
1108
var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).Items;
1168
var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).PagedResult.Items[0];
1169
var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).Items;
1210
var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).PagedResult.Items[0];
1247
var logEntry = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].
ResourceKey
), cancellationToken: CancellationToken.None)).Items[0];
1282
r => r.
ResourceKey
.GetCompositeName(),
Model\TelemetryImportServiceTests.cs (9)
91
var logs = await repository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].
ResourceKey
), cancellationToken: CancellationToken.None);
116
var traces = await repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resources[0].
ResourceKey
), cancellationToken: CancellationToken.None);
140
var instruments = repository.GetInstrumentSummaries(resources[0].
ResourceKey
);
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);
454
var traces = await sourceRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(resources[0].
ResourceKey
), cancellationToken: CancellationToken.None);
474
var importedTraces = await targetRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(importedResources[0].
ResourceKey
), cancellationToken: CancellationToken.None);
TelemetryApiServiceTests.cs (2)
952
var replica1Key = resources.First(r => r.
ResourceKey
.InstanceId == "replica-1").
ResourceKey
.ToString();
TelemetryRepositoryTests\LogTests.cs (11)
69
ResourceKeys = [resources[0].
ResourceKey
],
90
var propertyKeys = await repositoryContext.Repository.GetLogPropertyKeysAsync(resources[0].
ResourceKey
, TestContext.Current.CancellationToken);
200
Assert.Equal(new ResourceKey("frontend", "frontend-1"), summary.Resource.
ResourceKey
);
744
repositoryContext.Repository.OnNewLogs(resources[0].
ResourceKey
, SubscriptionType.Read, () =>
774
ResourceKeys = [resources[0].
ResourceKey
],
916
ResourceKeys = [resources[0].
ResourceKey
],
1059
var resourceKey = repositoryContext.Repository.GetResources().First().
ResourceKey
;
1109
ResourceKeys = [repositoryContext.Repository.GetResources().Single().
ResourceKey
],
1146
var resourceKey = repositoryContext.Repository.GetResources().First().
ResourceKey
;
1220
ResourceKeys = [resources[0].
ResourceKey
],
1243
ResourceKeys = [resources[1].
ResourceKey
],
TelemetryRepositoryTests\MetricsTests.cs (20)
76
var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].
ResourceKey
);
107
var instrumentSummary = repositoryContext.Repository.GetInstrumentSummary(resources[0].
ResourceKey
, "test-meter2", "test2");
110
Assert.Null(repositoryContext.Repository.GetInstrumentSummary(resources[0].
ResourceKey
, "test-meter2", "missing"));
163
ResourceKey = resources[0].
ResourceKey
,
264
ResourceKey = resources[0].
ResourceKey
,
315
ResourceKey = resource.
ResourceKey
,
382
ResourceKey = resources[0].
ResourceKey
,
417
ResourceKey = resources[0].
ResourceKey
,
484
ResourceKey = resource.
ResourceKey
,
520
var resourceKey = Assert.Single(repositoryContext.Repository.GetResources()).
ResourceKey
;
591
ResourceKey = resources[0].
ResourceKey
,
1376
ResourceKey = resources.
ResourceKey
,
1574
var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].
ResourceKey
);
1775
ResourceKey = resource.
ResourceKey
,
1825
ResourceKey = resource.
ResourceKey
,
1904
ResourceKey = resource.
ResourceKey
,
1939
ResourceKey = resource.
ResourceKey
,
1995
ResourceKey = resource.
ResourceKey
,
2061
ResourceKey = resource.
ResourceKey
,
2116
ResourceKey = resource.
ResourceKey
,
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (4)
111
var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.
ResourceKey
), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans);
112
var instrument = Assert.Single(repositoryContext.Repository.GetInstrumentSummaries(cachedResource.
ResourceKey
));
215
var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(firstResource.
ResourceKey
));
261
var instrument = Assert.Single(reopenedContext.Repository.GetInstrumentSummaries(resource.
ResourceKey
));
TelemetryRepositoryTests\TelemetryLimitTests.cs (2)
157
var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].
ResourceKey
);
181
instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].
ResourceKey
);
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (1)
56
Assert.NotEmpty(repositoryContext.Repository.GetInstrumentSummaries(resource.
ResourceKey
));
TelemetryRepositoryTests\TraceTests.cs (30)
82
ResourceKeys = [resources[0].
ResourceKey
],
185
Assert.Equal(new ResourceKey("frontend", "frontend-1"), summary.RootResource.
ResourceKey
);
191
Assert.Equal(new ResourceKey("frontend", "frontend-1"), resource.Resource.
ResourceKey
);
197
Assert.Equal(new ResourceKey("backend", "backend-1"), resource.Resource.
ResourceKey
);
374
TraceHelpers.GetOrderedResources(trace).Select(resource => resource.Resource.
ResourceKey
),
375
summary.Resources.Select(resource => resource.Resource.
ResourceKey
));
553
ResourceKeys = [resources[0].
ResourceKey
],
607
ResourceKeys = [resources[0].
ResourceKey
],
718
ResourceKeys = [resources[0].
ResourceKey
],
788
ResourceKeys = [resources[0].
ResourceKey
],
864
ResourceKeys = [resources[0].
ResourceKey
],
905
ResourceKeys = [resources[0].
ResourceKey
],
1251
ResourceKeys = [resources[0].
ResourceKey
],
1375
ResourceKeys = [resources[0].
ResourceKey
],
1608
Assert.Contains(resources, resource => resource.
ResourceKey
== new ResourceKey("resource", InstanceId: null));
1609
Assert.Contains(resources, resource => resource.
ResourceKey
== new ResourceKey("resource", InstanceId: string.Empty));
1641
ResourceKeys = [resource.
ResourceKey
],
2197
ResourceKeys = [resource.
ResourceKey
],
2661
ResourceKeys = [uninstrumentedPeerApp.
ResourceKey
],
2850
await repositoryContext.Repository.AsWriter().ClearTracesAsync(peerResource.
ResourceKey
);
2922
ResourceKeys = [resources[0].
ResourceKey
],
2963
ResourceKeys = [uninstrumentedPeerApp.
ResourceKey
],
3024
Assert.Equal(peerResource.
ResourceKey
, span.UninstrumentedPeer?.
ResourceKey
);
3070
Assert.Equal(peerResource.
ResourceKey
, span.UninstrumentedPeer?.
ResourceKey
);
3086
ResourceKeys = [peerResource.
ResourceKey
],
3438
ResourceKeys = [serviceA.
ResourceKey
],
4784
Assert.Equal(trace.RootOrFirstSpan.Source.Resource.
ResourceKey
, summary.RootResource.
ResourceKey
);