107 instantiations of ResourceKey
Aspire.Dashboard (12)
Model\ResourceTypeDetails.cs (1)
32return new ResourceKey(ReplicaSetName, InstanceId: null);
Otlp\Model\OtlpHelpers.cs (1)
115return new ResourceKey(serviceName, serviceInstanceId);
Otlp\Model\OtlpResource.cs (1)
43public ResourceKey ResourceKey => new ResourceKey(ResourceName, InstanceId);
Otlp\Storage\ResourceKey.cs (4)
14return new ResourceKey(Name: name, InstanceId: null); 25return new ResourceKey(name, instanceId.Substring(name.Length + 1)); 34return new ResourceKey(Name: instanceId, InstanceId: null); 37return new ResourceKey(Name: instanceId.Substring(0, separator), InstanceId: instanceId.Substring(separator + 1));
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (1)
605var key = new ResourceKey(record.ResourceName, record.InstanceId);
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (1)
733var key = new ResourceKey(resource.ResourceName, resource.InstanceId);
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (1)
760var key = new ResourceKey(resource.ResourceName, resource.InstanceId);
Otlp\Storage\SqliteTelemetryRepository.Traces.Writes.cs (2)
1002var key = new ResourceKey(resource.ResourceName, resource.InstanceId); 1202peerKey = new ResourceKey(name, InstanceId: null);
Aspire.Dashboard.Components.Tests (1)
Dialogs\ManageDataDialogTests.cs (1)
164var resourceKey = new ResourceKey("orphan", "instance");
Aspire.Dashboard.Tests (94)
TelemetryRepositoryTests\LogTests.cs (20)
200Assert.Equal(new ResourceKey("frontend", "frontend-1"), summary.Resource.ResourceKey); 502Assert.True(unviewedCounts1.TryGetValue(new ResourceKey("TestService", "1"), out var unviewedCount1)); 505Assert.True(unviewedCounts1.TryGetValue(new ResourceKey("TestService", "2"), out var unviewedCount2)); 508repositoryContext.Repository.MarkViewedErrorLogs(new ResourceKey("TestService", "1")); 512Assert.False(unviewedCounts2.TryGetValue(new ResourceKey("TestService", "1"), out _)); 514Assert.True(unviewedCounts2.TryGetValue(new ResourceKey("TestService", "2"), out unviewedCount2)); 521Assert.False(unviewedCounts3.TryGetValue(new ResourceKey("TestService", "1"), out _)); 522Assert.False(unviewedCounts3.TryGetValue(new ResourceKey("TestService", "2"), out _)); 573Assert.False(unviewedCounts.TryGetValue(new ResourceKey("TestService", "1"), out _)); 574Assert.False(unviewedCounts.TryGetValue(new ResourceKey("TestService", "2"), out _)); 582using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: new ResourceKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 625Assert.False(unviewedCounts.TryGetValue(new ResourceKey("TestService", "1"), out _)); 626Assert.True(unviewedCounts.TryGetValue(new ResourceKey("TestService", "2"), out var unviewedCount)); 663Assert.True(unviewedCounts.TryGetValue(new ResourceKey("TestService", "1"), out var unviewedCount)); 676ResourceKeys = [new ResourceKey("TestService", "UnknownResource")], 693var propertyKeys = await repositoryContext.Repository.GetLogPropertyKeysAsync(new ResourceKey("TestService", "UnknownResource"), TestContext.Current.CancellationToken); 1316var resourceKey = new ResourceKey("resource1", InstanceId: null); 1467await repositoryContext.Repository.AsWriter().ClearStructuredLogsAsync(new ResourceKey("resource1", "123")); 1541await repositoryContext.Repository.AsWriter().ClearStructuredLogsAsync(new ResourceKey("resource1", null)); 1948ResourceKeys = [new ResourceKey(resourceName, null)],
TelemetryRepositoryTests\MetricsTests.cs (18)
689var resourceKey = new ResourceKey("resource1", InstanceId: null); 799var resource1Key = new ResourceKey("resource1", InstanceId: null); 803var resource2Key = new ResourceKey("resource2", InstanceId: null); 869await repositoryContext.Repository.AsWriter().ClearMetricsAsync(new ResourceKey("resource1", "456")); 874var resource1Key = new ResourceKey("resource1", InstanceId: null); 909var resource2Key = new ResourceKey("resource2", InstanceId: null); 1019await repositoryContext.Repository.AsWriter().ClearMetricsAsync(new ResourceKey("resource1", null)); 1024var resource1Key = new ResourceKey("resource1", InstanceId: null); 1050var resource2Key = new ResourceKey("resource2", InstanceId: null); 1131var resource1Key = new ResourceKey("resource1", InstanceId: null); 1186ResourceKey = new ResourceKey("TestService", "TestId"), 1250ResourceKey = new ResourceKey("TestService", "TestId"), 1296ResourceKey = new ResourceKey("TestService", "TestId"), 1445ResourceKey = new ResourceKey("TestService", "TestId"), 1508ResourceKey = new ResourceKey("TestService", "TestId"), 1525ResourceKey = new ResourceKey("TestService", "TestId"), 1619ResourceKey = new ResourceKey("TestService", "TestId"), 1663ResourceKey = new ResourceKey("TestService", null),
TelemetryRepositoryTests\ResourceKeyTests.cs (2)
32var key = new ResourceKey(name, instanceId); 51var key = new ResourceKey(name, instanceId);
TelemetryRepositoryTests\ResourceTests.cs (2)
68var resources1 = repositoryContext.Repository.GetResources(new ResourceKey("app1", InstanceId: null)); 84var resources2 = repositoryContext.Repository.GetResources(new ResourceKey("app2", InstanceId: null));
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (5)
174reopenedContext.Repository.GetResource(new ResourceKey("backend", "TestId"))); 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); 410var resourceKey = new ResourceKey("TestService", "TestId"); 496ResourceKey = new ResourceKey("TestService", "TestId"),
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (24)
41var resourceKey = new ResourceKey("resource", "resource"); 214Assert.True(unviewedBefore.TryGetValue(new ResourceKey("resource1", "123"), out var errorCount1)); 216Assert.True(unviewedBefore.TryGetValue(new ResourceKey("resource2", "456"), out var errorCount2)); 228Assert.False(unviewedAfter.TryGetValue(new ResourceKey("resource1", "123"), out _)); 229Assert.True(unviewedAfter.TryGetValue(new ResourceKey("resource2", "456"), out errorCount2)); 240var resource1Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "123")); 244var resource2Key = new ResourceKey("resource2", "456"); 252var resource2Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource2", "456")); 283var resource1Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "111")); 286var resource3Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource3", "333")); 290var resource2 = repositoryContext.Repository.GetResource(new ResourceKey("resource2", "222")); 303var resourceBefore = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 314var resourceAfter = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 345var resourceAfter = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 355var metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "123")); 812await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1")], Filters = [] }, cts.Token)) 836var key1 = new ResourceKey("resource1", "inst1"); 837var key2 = new ResourceKey("resource2", "inst2"); 860ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], 887await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 918await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token))
TelemetryRepositoryTests\TraceTests.cs (23)
185Assert.Equal(new ResourceKey("frontend", "frontend-1"), summary.RootResource.ResourceKey); 191Assert.Equal(new ResourceKey("frontend", "frontend-1"), resource.Resource.ResourceKey); 197Assert.Equal(new ResourceKey("backend", "backend-1"), resource.Resource.ResourceKey); 1545var resourceKey = new ResourceKey("resource1", InstanceId: null); 1608Assert.Contains(resources, resource => resource.ResourceKey == new ResourceKey("resource", InstanceId: null)); 1609Assert.Contains(resources, resource => resource.ResourceKey == new ResourceKey("resource", InstanceId: string.Empty)); 1699var resourceKey = new ResourceKey("resource1", InstanceId: null); 1788var resourceKey = new ResourceKey("resource1", InstanceId: null); 1862ResourceKeys = [new ResourceKey("resource1", InstanceId: null)], 1916var resourceKey = new ResourceKey("resource1", InstanceId: null); 1970ResourceKeys = [new ResourceKey("resource1", InstanceId: null)], 1993ResourceKeys = [new ResourceKey("TestService", "TestId")], 2385await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", "123")); 2490await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", null)); 2581await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", null)); 4030var resourceKey = new ResourceKey("service1", InstanceId: null); 4080var resourceKey = new ResourceKey("service1", InstanceId: null); 4131var resourceKey = new ResourceKey("service1", InstanceId: null); 4217var resourceKey = new ResourceKey("service1", InstanceId: null); 4272var resourceKey = new ResourceKey("service1", InstanceId: null); 4327var resourceKey = new ResourceKey("service1", InstanceId: null); 4452var resourceKey = new ResourceKey("service1", InstanceId: null); 4904[new ResourceKey("frontend", "TestId").GetCompositeName()] = [AspireDataType.Resource]
151 references to ResourceKey
Aspire.Dashboard (102)
Api\TelemetryApiService.cs (4)
518private async Task<List<ResourceKey>> WaitForResourceKeysAsync(string[]? resourceNames, CancellationToken cancellationToken) 552private static List<ResourceKey>? ResolveResourceKeys(IReadOnlyList<OtlpResource> resources, string[]? resourceNames) 559var keys = new List<ResourceKey>(); 581out ResourceKey? resourceKey)
Components\Controls\Chart\ChartContainer.razor.cs (5)
27private (ResourceKey ResourceKey, string MeterName, string InstrumentName)? _dataEndTimeKey; 28private (ResourceKey ResourceKey, string MeterName, string InstrumentName, TimeSpan Duration)? _instrumentRequestKey; 35public required ResourceKey ResourceKey { get; set; } 261var resourceKey = ResourceKey; 350private void EnsureDataEndTime(ResourceKey resourceKey, string meterName, string instrumentName)
Components\Controls\ClearSignalsButton.razor.cs (1)
32public required Func<ResourceKey?, Task> HandleClearSignal { get; set; }
Components\Controls\SignalsActionsDisplay.razor.cs (1)
30public required Func<ResourceKey?, Task> HandleClearSignal { get; set; }
Components\Pages\ConsoleLogs.razor.cs (1)
1235private async Task ClearConsoleLogs(ResourceKey? key)
Components\Pages\Metrics.razor.cs (1)
242private Task ClearMetrics(ResourceKey? key)
Components\Pages\Resources.razor.cs (2)
43private Dictionary<ResourceKey, int>? _resourceUnviewedErrorCounts; 601private bool ResourceErrorCountsChanged(Dictionary<ResourceKey, int> newResourceUnviewedErrorCounts)
Components\Pages\StructuredLogs.razor.cs (1)
586private Task ClearStructureLogs(ResourceKey? key)
Components\Pages\Traces.razor.cs (1)
404private Task ClearTraces(ResourceKey? key)
Components\ResourcesGridColumns\StateColumnDisplay.razor.cs (1)
18public required Dictionary<ResourceKey, int>? UnviewedErrorCounts { get; set; }
Components\ResourcesGridColumns\UnreadLogErrorsBadge.razor.cs (1)
20public required Dictionary<ResourceKey, int>? UnviewedErrorCounts { get; set; }
Model\ResourceTypeDetails.cs (2)
24public ResourceKey GetResourceKey() 35return ResourceKey.Create(name: ReplicaSetName, instanceId: InstanceId);
Model\StructuredLogsViewModel.cs (2)
17private ResourceKey? _resourceKey; 29public ResourceKey? ResourceKey { get => _resourceKey; set => SetValue(ref _resourceKey, value); }
Model\TracesViewModel.cs (2)
16private ResourceKey? _resourceKey; 27public ResourceKey? ResourceKey { get => _resourceKey; set => SetValue(ref _resourceKey, value); }
Otlp\Model\OtlpHelpers.cs (1)
80public static ResourceKey GetResourceKey(this Resource resource)
Otlp\Model\OtlpResource.cs (1)
43public ResourceKey ResourceKey => new ResourceKey(ResourceName, InstanceId);
Otlp\Model\OtlpResourceView.cs (1)
15public ResourceKey ResourceKey => Resource.ResourceKey;
Otlp\Storage\GetInstrumentRequest.cs (1)
19public required ResourceKey ResourceKey { get; init; }
Otlp\Storage\GetLogsContext.cs (2)
10public required IReadOnlyList<ResourceKey> ResourceKeys { get; init; } 23public static GetLogsContext ForResourceKey(ResourceKey resourceKey) => new()
Otlp\Storage\GetSpansRequest.cs (1)
10public required IReadOnlyList<ResourceKey> ResourceKeys { get; init; }
Otlp\Storage\GetTracesRequest.cs (2)
10public required IReadOnlyList<ResourceKey> ResourceKeys { get; init; } 22public static GetTracesRequest ForResourceKey(ResourceKey resourceKey) => new()
Otlp\Storage\ITelemetryRepository.cs (12)
27OtlpResource? GetResource(ResourceKey key); 28List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false); 29Dictionary<ResourceKey, int> GetResourceUnviewedErrorLogsCount(); 30void MarkViewedErrorLogs(ResourceKey? key); 33Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 34Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 35Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback); 42Task<List<string>> GetLogPropertyKeysAsync(ResourceKey? resourceKey, CancellationToken cancellationToken); 43Task<List<string>> GetTracePropertyKeysAsync(ResourceKey? resourceKey, CancellationToken cancellationToken); 53List<OtlpInstrumentSummary> GetInstrumentSummaries(ResourceKey key); 62OtlpInstrumentSummary? GetInstrumentSummary(ResourceKey resourceKey, string meterName, string instrumentName); 65DateTime? GetInstrumentLatestEndTime(ResourceKey resourceKey, string meterName, string instrumentName);
Otlp\Storage\ITelemetryRepositoryWriter.cs (3)
54Task ClearTracesAsync(ResourceKey? resourceKey = null); 61Task ClearStructuredLogsAsync(ResourceKey? resourceKey = null); 68Task ClearMetricsAsync(ResourceKey? resourceKey = null);
Otlp\Storage\ResourceKey.cs (3)
6public readonly record struct ResourceKey(string Name, string? InstanceId) : IComparable<ResourceKey> 8public static ResourceKey Create(string name, string instanceId) 40public int CompareTo(ResourceKey other)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (7)
23private readonly Dictionary<ResourceKey, CachedResource> _cachedResourcesByKey = []; 32ResourceKey resourceKey, 605var key = new ResourceKey(record.ResourceName, record.InstanceId); 618private CachedResource CreateCachedResource(long resourceId, ResourceKey key, bool uninstrumentedPeer) 687private List<OtlpInstrumentSummary> GetCachedInstrumentSummaries(ResourceKey key) 701private List<CachedInstrument> GetCachedInstruments(ResourceKey resourceKey, string meterName, string instrumentName) 741private IEnumerable<CachedResource> GetCachedResources(ResourceKey key)
Otlp\Storage\SqliteTelemetryRepository.cs (8)
210public Task<List<string>> GetLogPropertyKeysAsync(ResourceKey? resourceKey, CancellationToken cancellationToken) => 212public Task<List<string>> GetTracePropertyKeysAsync(ResourceKey? resourceKey, CancellationToken cancellationToken) => 228public List<OtlpInstrumentSummary> GetInstrumentSummaries(ResourceKey key) => GetCachedInstrumentSummaries(key); 229public OtlpInstrumentSummary? GetInstrumentSummary(ResourceKey resourceKey, string meterName, string instrumentName) => 233public DateTime? GetInstrumentLatestEndTime(ResourceKey resourceKey, string meterName, string instrumentName) => 248public async Task ClearTracesAsync(ResourceKey? resourceKey = null) 256public async Task ClearStructuredLogsAsync(ResourceKey? resourceKey = null) 265public async Task ClearMetricsAsync(ResourceKey? resourceKey = null)
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (5)
41var resourceKey = resourceLogsItem.Resource.GetResourceKey(); 440private List<string> GetLogPropertyKeysFromDatabase(ResourceKey? resourceKey, CancellationToken cancellationToken) 506var key = context.ResourceKeys[i]; 733var key = new ResourceKey(resource.ResourceName, resource.InstanceId); 750private async Task ClearStructuredLogsFromDatabaseAsync(ResourceKey? resourceKey)
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)
142private DateTime? GetInstrumentLatestEndTimeFromDatabase(ResourceKey resourceKey, string meterName, string instrumentName)
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (2)
760var key = new ResourceKey(resource.ResourceName, resource.InstanceId); 768private async Task ClearMetricsFromDatabaseAsync(ResourceKey? resourceKey)
Otlp\Storage\SqliteTelemetryRepository.Resources.cs (3)
20public OtlpResource? GetResource(ResourceKey key) => GetResources(includeUninstrumentedPeers: true).SingleOrDefault(resource => resource.ResourceKey == key); 22public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false) 29private async Task DeleteTelemetryResourceFromDatabaseAsync(ResourceKey resourceKey)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (10)
22private readonly Dictionary<ResourceKey, int> _resourceUnviewedErrorLogs = []; 53public Dictionary<ResourceKey, int> GetResourceUnviewedErrorLogsCount() 61public void MarkViewedErrorLogs(ResourceKey? key) 90private void ClearUnviewedErrorCounts(ResourceKey? key) 100foreach (var resourceKey in _resourceUnviewedErrorLogs.Keys 115foreach (var resourceKey in _resourceUnviewedErrorLogs.Keys.ToList()) 129public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => 132public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => 135public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => 140ResourceKey? resourceKey,
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (3)
187var key = context.ResourceKeys[index]; 447var key = context.ResourceKeys[index]; 558private List<string> GetTracePropertyKeysFromDatabase(ResourceKey? resourceKey, CancellationToken cancellationToken)
Otlp\Storage\SqliteTelemetryRepository.Traces.Writes.cs (7)
58var resourceKey = resourceSpansItem.Resource.GetResourceKey(); 564if (TryResolvePeerResourceKey(span.Attributes, out var peerKey)) 1002var key = new ResourceKey(resource.ResourceName, resource.InstanceId); 1111TryResolvePeerResourceKey(attributeArray, out var peerKey)) 1185private bool TryResolvePeerResourceKey(KeyValuePair<string, string>[] attributes, out ResourceKey peerKey) 1196peerKey = ResourceKey.Create(matchedResource.DisplayName, matchedResource.Name); 1211private async Task ClearTracesFromDatabaseAsync(ResourceKey? resourceKey)
Otlp\Storage\Subscription.cs (2)
23public ResourceKey? ResourceKey { get; } 27public Subscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, ILogger logger, TimeSpan minExecuteInterval)
Otlp\Storage\WatchLogsRequest.cs (1)
10public required IReadOnlyList<ResourceKey> ResourceKeys { get; init; }
Otlp\Storage\WatchSpansRequest.cs (1)
10public required IReadOnlyList<ResourceKey> ResourceKeys { get; init; }
Aspire.Dashboard.Components.Tests (14)
Dialogs\ManageDataDialogTests.cs (1)
164var resourceKey = new ResourceKey("orphan", "instance");
Pages\ResourcesTests.cs (1)
544var resourceKey = Assert.Single(unviewedErrorCounts.Keys);
Shared\TestTelemetryRepository.cs (12)
23public OtlpResource? GetResource(ResourceKey key) => inner.GetResource(key); 24public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false) => inner.GetResources(key, includeUninstrumentedPeers); 25public Dictionary<ResourceKey, int> GetResourceUnviewedErrorLogsCount() => inner.GetResourceUnviewedErrorLogsCount(); 26public void MarkViewedErrorLogs(ResourceKey? key) => inner.MarkViewedErrorLogs(key); 29public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewLogs(resourceKey, subscriptionType, callback); 30public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewMetrics(resourceKey, subscriptionType, callback); 31public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) => inner.OnNewTraces(resourceKey, subscriptionType, callback); 39public Task<List<string>> GetLogPropertyKeysAsync(ResourceKey? resourceKey, CancellationToken cancellationToken) => inner.GetLogPropertyKeysAsync(resourceKey, cancellationToken); 40public Task<List<string>> GetTracePropertyKeysAsync(ResourceKey? resourceKey, CancellationToken cancellationToken) => inner.GetTracePropertyKeysAsync(resourceKey, cancellationToken); 50public List<OtlpInstrumentSummary> GetInstrumentSummaries(ResourceKey key) => inner.GetInstrumentSummaries(key); 51public OtlpInstrumentSummary? GetInstrumentSummary(ResourceKey resourceKey, string meterName, string instrumentName) => inner.GetInstrumentSummary(resourceKey, meterName, instrumentName); 53public DateTime? GetInstrumentLatestEndTime(ResourceKey resourceKey, string meterName, string instrumentName) => inner.GetInstrumentLatestEndTime(resourceKey, meterName, instrumentName);
Aspire.Dashboard.Tests (35)
Model\ApplicationsSelectHelpersTests.cs (1)
277var key = OtlpHelpers.GetResourceKey(resource);
TelemetryRepositoryTests\LogTests.cs (3)
1059var resourceKey = repositoryContext.Repository.GetResources().First().ResourceKey; 1146var resourceKey = repositoryContext.Repository.GetResources().First().ResourceKey; 1316var resourceKey = new ResourceKey("resource1", InstanceId: null);
TelemetryRepositoryTests\MetricsTests.cs (10)
520var resourceKey = Assert.Single(repositoryContext.Repository.GetResources()).ResourceKey; 689var resourceKey = new ResourceKey("resource1", InstanceId: null); 799var resource1Key = new ResourceKey("resource1", InstanceId: null); 803var resource2Key = new ResourceKey("resource2", InstanceId: null); 874var resource1Key = new ResourceKey("resource1", InstanceId: null); 909var resource2Key = new ResourceKey("resource2", InstanceId: null); 1024var resource1Key = new ResourceKey("resource1", InstanceId: null); 1050var resource2Key = new ResourceKey("resource2", InstanceId: null); 1131var resource1Key = new ResourceKey("resource1", InstanceId: null); 2222var resourceKey = CreateResource().GetResourceKey();
TelemetryRepositoryTests\ResourceKeyTests.cs (4)
18var key = ResourceKey.Create(name, instanceId); 32var key = new ResourceKey(name, instanceId); 51var key = new ResourceKey(name, instanceId);
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (1)
410var resourceKey = new ResourceKey("TestService", "TestId");
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (4)
41var resourceKey = new ResourceKey("resource", "resource"); 244var resource2Key = new ResourceKey("resource2", "456"); 836var key1 = new ResourceKey("resource1", "inst1"); 837var key2 = new ResourceKey("resource2", "inst2");
TelemetryRepositoryTests\TraceTests.cs (12)
1545var resourceKey = new ResourceKey("resource1", InstanceId: null); 1699var resourceKey = new ResourceKey("resource1", InstanceId: null); 1788var resourceKey = new ResourceKey("resource1", InstanceId: null); 1916var resourceKey = new ResourceKey("resource1", InstanceId: null); 3888ResourceKeys = [ResourceKey.Create("nonexistent", "unknown")], 4030var resourceKey = new ResourceKey("service1", InstanceId: null); 4080var resourceKey = new ResourceKey("service1", InstanceId: null); 4131var resourceKey = new ResourceKey("service1", InstanceId: null); 4217var resourceKey = new ResourceKey("service1", InstanceId: null); 4272var resourceKey = new ResourceKey("service1", InstanceId: null); 4327var resourceKey = new ResourceKey("service1", InstanceId: null); 4452var resourceKey = new ResourceKey("service1", InstanceId: null);